2015-08-12 09:59:28,772 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-12 09:59:28,829 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-12 09:59:28,830 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tuple.hadoop.SerializedPipesPlatformTest
2015-08-12 09:59:28,869 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-12 09:59:30,023 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-08-12 09:59:31,008 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 09:59:39,151 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 09:59:39,449 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 09:59:39,635 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 09:59:39,889 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-12 09:59:57,088 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-12 09:59:57,283 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:59:57,284 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:59:57,327 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: E26F93E16FF04FD2A8F1F445496478B7
2015-08-12 09:59:57,559 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-12 09:59:57,566 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 09:59:57,568 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 09:59:57,570 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["SequenceFile[[UNKNOWN]->['ip', 'count', 'boolean']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/serialization"]
2015-08-12 09:59:57,571 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-12 09:59:57,571 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-12 09:59:57,571 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-12 09:59:57,573 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/serialization
2015-08-12 09:59:59,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439398791578_0001
2015-08-12 09:59:59,186 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0001/
2015-08-12 10:00:27,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0001_01_000005 is : 143
2015-08-12 10:00:27,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0001_01_000002 is : 143
2015-08-12 10:00:27,853 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0001_01_000003 is : 143
2015-08-12 10:00:35,229 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0001_01_000006 is : 143
2015-08-12 10:00:36,671 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/serialization/_temporary
2015-08-12 10:00:36,864 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/serialization
2015-08-12 10:00:37,031 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:00:37,032 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:00:37,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:00:37,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:00:37,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:00:37,100 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[[UNKNOWN]->[0:7]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/writablekeyvalue"]
2015-08-12 10:00:37,101 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:00:37,102 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 10:00:37,103 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 10:00:37,105 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...platform/writablekeyvalue
2015-08-12 10:00:37,735 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0002
2015-08-12 10:00:37,736 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0002/
2015-08-12 10:01:13,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0002_01_000003 is : 143
2015-08-12 10:01:13,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0002_01_000006 is : 143
2015-08-12 10:01:14,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0002_01_000002 is : 143
2015-08-12 10:01:21,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0002_01_000008 is : 143
2015-08-12 10:01:22,840 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/writablekeyvalue/_temporary
2015-08-12 10:01:22,881 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/writablekeyvalue
2015-08-12 10:01:22,927 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:01:22,929 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:01:23,027 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:01:23,027 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:01:23,028 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:01:23,028 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/false/false/false"]
2015-08-12 10:01:23,029 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:01:23,029 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:01:23,029 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:01:23,031 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:01:23,289 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0003
2015-08-12 10:01:23,289 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0003/
2015-08-12 10:01:42,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0003_01_000002 is : 143
2015-08-12 10:01:50,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0003_01_000004 is : 143
2015-08-12 10:01:52,052 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...ue/true/false/false/false
2015-08-12 10:01:52,276 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0004
2015-08-12 10:01:52,277 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0004/
2015-08-12 10:02:07,800 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0004_01_000002 is : 143
2015-08-12 10:02:16,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0004_01_000003 is : 143
2015-08-12 10:02:17,592 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/false/false/false/_temporary
2015-08-12 10:02:17,694 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/false/false/false
2015-08-12 10:02:17,735 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:02:17,737 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:02:17,777 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:02:17,777 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:02:17,777 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:02:17,778 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/byteswritablekeyvalue"]
2015-08-12 10:02:17,778 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:02:17,778 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 10:02:17,779 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 10:02:17,780 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...orm/byteswritablekeyvalue
2015-08-12 10:02:18,177 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0005
2015-08-12 10:02:18,178 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0005/
2015-08-12 10:02:50,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0005_01_000003 is : 143
2015-08-12 10:03:00,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0005_01_000008 is : 143
2015-08-12 10:03:01,410 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/byteswritablekeyvalue/_temporary
2015-08-12 10:03:01,483 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/byteswritablekeyvalue
2015-08-12 10:03:01,527 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:03:01,529 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:03:01,556 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 10:03:01,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line' | cascading.tuple.coerce.BigDecimalCoerce@62f0926b, String]->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 10:03:01,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["SequenceFile[['offset', 'count' | cascading.tuple.coerce.BigDecimalCoerce@62f0926b, long]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/bigdecimal"]
2015-08-12 10:03:01,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-12 10:03:01,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-12 10:03:01,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-12 10:03:01,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...dpipesplatform/bigdecimal
2015-08-12 10:03:01,797 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439398791578_0006
2015-08-12 10:03:01,797 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0006/
2015-08-12 10:03:26,163 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0006_01_000005 is : 143
2015-08-12 10:03:27,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0006_01_000004 is : 143
2015-08-12 10:03:34,801 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/bigdecimal/_temporary
2015-08-12 10:03:34,860 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/bigdecimal
2015-08-12 10:03:34,956 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:03:34,958 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:03:35,018 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:03:35,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:03:35,020 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:03:35,030 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/true/false"]
2015-08-12 10:03:35,032 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:03:35,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:03:35,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:03:35,044 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:03:35,256 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0007
2015-08-12 10:03:35,256 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0007/
2015-08-12 10:03:52,218 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0007_01_000002 is : 143
2015-08-12 10:03:52,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0007_01_000003 is : 143
2015-08-12 10:03:59,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0007_01_000004 is : 143
2015-08-12 10:04:01,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...alue/true/true/true/false
2015-08-12 10:04:01,555 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0008
2015-08-12 10:04:01,556 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0008/
2015-08-12 10:04:15,423 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0008_01_000002 is : 143
2015-08-12 10:04:25,073 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/true/false/_temporary
2015-08-12 10:04:25,163 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/true/false
2015-08-12 10:04:25,208 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:04:25,209 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:04:25,252 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:04:25,253 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:04:25,253 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:04:25,254 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/false/true/false/false"]
2015-08-12 10:04:25,255 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:04:25,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:04:25,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:04:25,268 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:04:25,534 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0009
2015-08-12 10:04:25,535 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0009/
2015-08-12 10:04:43,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0009_01_000002 is : 143
2015-08-12 10:04:43,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0009_01_000003 is : 143
2015-08-12 10:04:51,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0009_01_000004 is : 143
2015-08-12 10:04:52,695 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...ue/false/true/false/false
2015-08-12 10:04:52,877 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0010
2015-08-12 10:04:52,877 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0010/
2015-08-12 10:05:07,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0010_01_000002 is : 143
2015-08-12 10:05:14,854 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0010_01_000003 is : 143
2015-08-12 10:05:16,136 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/false/true/false/false/_temporary
2015-08-12 10:05:16,210 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/false/true/false/false
2015-08-12 10:05:16,244 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:05:16,245 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:05:16,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:05:16,280 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:05:16,280 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:05:16,281 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/true/true"]
2015-08-12 10:05:16,282 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:05:16,283 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:05:16,283 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:05:16,285 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:05:16,512 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0011
2015-08-12 10:05:16,513 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0011/
2015-08-12 10:05:32,806 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0011_01_000002 is : 143
2015-08-12 10:05:33,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0011_01_000003 is : 143
2015-08-12 10:05:41,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0011_01_000004 is : 143
2015-08-12 10:05:42,896 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...value/true/true/true/true
2015-08-12 10:05:43,094 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0012
2015-08-12 10:05:43,095 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0012/
2015-08-12 10:06:03,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0012_01_000003 is : 143
2015-08-12 10:06:04,734 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/true/true/_temporary
2015-08-12 10:06:04,784 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/true/true
2015-08-12 10:06:04,822 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:06:04,823 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:06:04,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:06:04,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:06:04,860 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:06:04,861 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/false/false/false/false"]
2015-08-12 10:06:04,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:06:04,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:06:04,871 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:06:04,877 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:06:05,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0013
2015-08-12 10:06:05,111 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0013/
2015-08-12 10:06:21,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0013_01_000002 is : 143
2015-08-12 10:06:28,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0013_01_000004 is : 143
2015-08-12 10:06:30,024 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...e/false/false/false/false
2015-08-12 10:06:30,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0014
2015-08-12 10:06:30,230 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0014/
2015-08-12 10:06:45,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0014_01_000002 is : 143
2015-08-12 10:06:53,300 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0014_01_000003 is : 143
2015-08-12 10:06:54,606 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/false/false/false/false/_temporary
2015-08-12 10:06:54,674 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/false/false/false/false
2015-08-12 10:06:54,750 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:06:54,753 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:06:54,788 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:06:54,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:06:54,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:06:54,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/false/false"]
2015-08-12 10:06:54,790 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:06:54,791 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:06:54,791 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:06:54,797 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:06:55,006 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0015
2015-08-12 10:06:55,007 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0015/
2015-08-12 10:07:11,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0015_01_000003 is : 143
2015-08-12 10:07:12,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0015_01_000002 is : 143
2015-08-12 10:07:18,915 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0015_01_000004 is : 143
2015-08-12 10:07:20,182 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...lue/true/true/false/false
2015-08-12 10:07:20,441 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0016
2015-08-12 10:07:20,441 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0016/
2015-08-12 10:07:35,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0016_01_000002 is : 143
2015-08-12 10:07:43,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0016_01_000003 is : 143
2015-08-12 10:07:45,224 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/false/false/_temporary
2015-08-12 10:07:45,288 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/true/false/false
2015-08-12 10:07:45,346 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:07:45,347 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:07:45,365 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-12 10:07:45,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 10:07:45,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["SequenceFile[[UNKNOWN]->['bytes', 'count']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/grouponbytes"]
2015-08-12 10:07:45,369 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-12 10:07:45,371 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-12 10:07:45,371 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-12 10:07:45,373 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ipesplatform/grouponbytes
2015-08-12 10:07:45,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439398791578_0017
2015-08-12 10:07:45,612 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0017/
2015-08-12 10:08:10,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0017_01_000002 is : 143
2015-08-12 10:08:11,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0017_01_000003 is : 143
2015-08-12 10:08:12,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0017_01_000004 is : 143
2015-08-12 10:08:18,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0017_01_000006 is : 143
2015-08-12 10:08:20,217 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/grouponbytes/_temporary
2015-08-12 10:08:20,253 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/grouponbytes
2015-08-12 10:08:20,286 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:08:20,286 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:08:20,315 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:08:20,316 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:08:20,317 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:08:20,327 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/false/false/true"]
2015-08-12 10:08:20,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:08:20,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 10:08:20,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 10:08:20,334 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2)
2015-08-12 10:08:20,514 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0018
2015-08-12 10:08:20,514 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0018/
2015-08-12 10:08:38,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0018_01_000002 is : 143
2015-08-12 10:08:38,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0018_01_000003 is : 143
2015-08-12 10:08:46,066 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0018_01_000004 is : 143
2015-08-12 10:08:47,382 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2) ...lue/true/false/false/true
2015-08-12 10:08:47,559 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0019
2015-08-12 10:08:47,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0019/
2015-08-12 10:09:08,182 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0019_01_000003 is : 143
2015-08-12 10:09:09,435 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/false/false/true/_temporary
2015-08-12 10:09:09,490 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/rawbyteskeyvalue/true/false/false/true
2015-08-12 10:09:09,520 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:09:09,520 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:09:09,544 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 10:09:09,544 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 10:09:09,545 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 10:09:09,546 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["SequenceFile[[UNKNOWN]->[0:9]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/customerwritable"]
2015-08-12 10:09:09,548 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 10:09:09,548 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 10:09:09,548 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 10:09:09,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...platform/customerwritable
2015-08-12 10:09:09,780 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439398791578_0020
2015-08-12 10:09:09,781 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:50492/proxy/application_1439398791578_0020/
2015-08-12 10:09:39,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0020_01_000003 is : 143
2015-08-12 10:09:39,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0020_01_000002 is : 143
2015-08-12 10:09:43,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439398791578_0020_01_000004 is : 143
2015-08-12 10:09:50,371 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/serializedpipesplatform/customerwritable/_temporary
2015-08-12 10:09:50,398 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/serializedpipesplatform/customerwritable