Class cascading.MergePipesPlatformTest

21

tests

0

failures

0

ignored

22m45.48s

duration

100%

successful

Tests

Test Duration Result
testHashJoinMergeIntoHashJoinAccumulated 1m21.38s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated 1m58.93s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 2m9.46s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed 1m47.01s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 2m20.94s passed
testHashJoinMergeIntoHashJoinStreamed 37.178s passed
testHashJoinMergeIntoHashJoinStreamedAccumulated 1m13.93s passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 1m18.56s passed
testHashJoinMergeIntoHashJoinStreamedStreamed 38.026s passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge 41.151s passed
testMergeIntoHashJoinAccumulated 36.283s passed
testMergeIntoHashJoinStreamed 41.213s passed
testSameSourceMergeThreeChainGroup 1m23.66s passed
testSimpleMerge 1m15.94s passed
testSimpleMergeFail 0.056s passed
testSimpleMergeThree 53.211s passed
testSimpleMergeThreeChain 51.149s passed
testSimpleMergeThreeChainCoGroup 57.728s passed
testSimpleMergeThreeChainGroup 57.639s passed
testSplitSameSourceMerged 29.391s passed
testSplitSameSourceMergedComplex 32.644s passed

Standard output

2015-08-12 16:24:45,837 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 16:24:45,892 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2015-08-12 16:24:45,945 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-08-12 16:24:47,371 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 16:24:48,131 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 16:24:55,664 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 16:24:55,980 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 16:24:56,275 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 16:24:56,482 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 16:25:13,723 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-08-12 16:25:14,065 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:25:14,070 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:25:14,296 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 58DF5287794E4164887DDFD50EA79106
2015-08-12 16:25:14,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.162
2015-08-12 16:25:14,556 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:25:14,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:25:14,757 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 16:25:14,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-08-12 16:25:14,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:25:14,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:25:14,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2015-08-12 16:25:14,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2015-08-12 16:25:14,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2015-08-12 16:25:14,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2015-08-12 16:25:14,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2015-08-12 16:25:15,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1439421908211_0001
2015-08-12 16:25:15,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0001/
2015-08-12 16:25:59,875 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0001_01_000005 is : 143
2015-08-12 16:26:00,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0001_01_000002 is : 143
2015-08-12 16:26:01,656 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2015-08-12 16:26:01,659 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:46.890, using cpu time: 00:06.690
2015-08-12 16:26:01,823 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge
2015-08-12 16:26:01,956 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:26:01,966 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:26:02,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.246
2015-08-12 16:26:02,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-08-12 16:26:02,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:26:02,350 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2015-08-12 16:26:02,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:26:02,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:26:02,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:26:02,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-08-12 16:26:02,363 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  parallel execution of steps is enabled: true
2015-08-12 16:26:02,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  executing total steps: 3
2015-08-12 16:26:02,365 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  allocating management threads: 3
2015-08-12 16:26:02,384 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/3)
2015-08-12 16:26:02,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1439421908211_0002
2015-08-12 16:26:02,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0002/
2015-08-12 16:26:46,526 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0002_01_000007 is : 143
2015-08-12 16:26:50,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/3)
2015-08-12 16:26:50,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1439421908211_0003
2015-08-12 16:26:50,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0003/
2015-08-12 16:27:36,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2015-08-12 16:27:36,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1439421908211_0004
2015-08-12 16:27:36,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0004/
2015-08-12 16:28:07,778 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0004_01_000002 is : 143
2015-08-12 16:28:09,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0004_01_000004 is : 143
2015-08-12 16:28:09,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0004_01_000006 is : 143
2015-08-12 16:28:09,881 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0004_01_000005 is : 143
2015-08-12 16:28:11,237 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-08-12 16:28:11,252 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  completed in: 02:08.880, using cpu time: 00:25.600
2015-08-12 16:28:11,301 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-08-12 16:28:11,373 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:28:11,375 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:28:11,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2015-08-12 16:28:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:28:11,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:28:11,495 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2015-08-12 16:28:11,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:28:11,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:28:11,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:28:11,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-08-12 16:28:11,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  parallel execution of steps is enabled: true
2015-08-12 16:28:11,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  executing total steps: 1
2015-08-12 16:28:11,501 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  allocating management threads: 1
2015-08-12 16:28:11,503 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2015-08-12 16:28:11,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1439421908211_0005
2015-08-12 16:28:11,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0005/
2015-08-12 16:28:45,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0005_01_000007 is : 143
2015-08-12 16:28:50,061 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0005_01_000005 is : 143
2015-08-12 16:28:50,258 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0005_01_000004 is : 143
2015-08-12 16:28:51,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0005_01_000003 is : 143
2015-08-12 16:28:52,370 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-08-12 16:28:52,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  completed in: 00:40.866, using cpu time: 00:07.260
2015-08-12 16:28:52,448 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-08-12 16:28:52,523 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:28:52,524 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:28:52,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2015-08-12 16:28:52,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:28:52,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:28:52,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-08-12 16:28:52,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:28:52,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:28:52,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:28:52,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2015-08-12 16:28:52,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2015-08-12 16:28:52,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2015-08-12 16:28:52,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2015-08-12 16:28:52,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2015-08-12 16:28:52,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1439421908211_0006
2015-08-12 16:28:52,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0006/
2015-08-12 16:29:35,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0006_01_000006 is : 143
2015-08-12 16:29:41,294 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0006_01_000010 is : 143
2015-08-12 16:29:42,080 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0006_01_000009 is : 143
2015-08-12 16:29:43,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0006_01_000003 is : 143
2015-08-12 16:29:45,575 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2015-08-12 16:29:45,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:52.942, using cpu time: 00:09.860
2015-08-12 16:29:45,634 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree
2015-08-12 16:29:45,732 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:29:45,734 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:29:45,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2015-08-12 16:29:45,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:29:45,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:29:45,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting
2015-08-12 16:29:45,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:29:45,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:29:45,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:29:45,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-08-12 16:29:45,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  parallel execution of steps is enabled: true
2015-08-12 16:29:45,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  executing total steps: 1
2015-08-12 16:29:45,855 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  allocating management threads: 1
2015-08-12 16:29:45,859 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2015-08-12 16:29:46,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] submitted hadoop job: job_1439421908211_0007
2015-08-12 16:29:46,087 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0007/
2015-08-12 16:30:20,212 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0007_01_000006 is : 143
2015-08-12 16:30:21,286 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0007_01_000004 is : 143
2015-08-12 16:30:21,516 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0007_01_000005 is : 143
2015-08-12 16:30:22,328 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0007_01_000003 is : 143
2015-08-12 16:30:23,626 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-08-12 16:30:23,638 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  completed in: 00:37.776, using cpu time: 00:07.320
2015-08-12 16:30:23,686 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-08-12 16:30:23,759 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:30:23,762 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:30:23,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2015-08-12 16:30:23,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:30:23,828 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:30:23,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2015-08-12 16:30:23,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:30:23,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:30:23,852 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:30:23,854 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2015-08-12 16:30:23,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  parallel execution of steps is enabled: true
2015-08-12 16:30:23,858 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  executing total steps: 1
2015-08-12 16:30:23,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  allocating management threads: 1
2015-08-12 16:30:23,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2015-08-12 16:30:24,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1439421908211_0008
2015-08-12 16:30:24,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0008/
2015-08-12 16:31:12,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0008_01_000009 is : 143
2015-08-12 16:31:12,377 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0008_01_000003 is : 143
2015-08-12 16:31:12,703 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0008_01_000002 is : 143
2015-08-12 16:31:12,934 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0008_01_000006 is : 143
2015-08-12 16:31:13,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0008_01_000004 is : 143
2015-08-12 16:31:13,362 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0008_01_000007 is : 143
2015-08-12 16:31:14,733 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2015-08-12 16:31:14,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  completed in: 00:50.883, using cpu time: 00:10.110
2015-08-12 16:31:14,830 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2015-08-12 16:31:14,921 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:31:14,922 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:31:15,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.100
2015-08-12 16:31:15,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 16:31:15,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:31:15,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2015-08-12 16:31:15,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:31:15,075 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:31:15,075 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:31:15,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-08-12 16:31:15,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2015-08-12 16:31:15,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  executing total steps: 2
2015-08-12 16:31:15,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  allocating management threads: 2
2015-08-12 16:31:15,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/2)
2015-08-12 16:31:15,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1439421908211_0009
2015-08-12 16:31:15,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0009/
2015-08-12 16:31:52,732 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0009_01_000004 is : 143
2015-08-12 16:31:53,476 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0009_01_000005 is : 143
2015-08-12 16:31:53,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0009_01_000007 is : 143
2015-08-12 16:31:55,182 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2015-08-12 16:31:55,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1439421908211_0010
2015-08-12 16:31:55,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0010/
2015-08-12 16:32:26,057 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0010_01_000004 is : 143
2015-08-12 16:32:26,713 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0010_01_000006 is : 143
2015-08-12 16:32:27,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0010_01_000002 is : 143
2015-08-12 16:32:27,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0010_01_000003 is : 143
2015-08-12 16:32:27,399 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0010_01_000005 is : 143
2015-08-12 16:32:28,738 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-08-12 16:32:28,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  completed in: 01:13.655, using cpu time: 00:14.510
2015-08-12 16:32:28,782 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-08-12 16:32:28,880 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:32:28,885 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:32:29,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.106
2015-08-12 16:32:29,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:32:29,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:32:29,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2015-08-12 16:32:29,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 16:32:29,056 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2015-08-12 16:32:29,056 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2015-08-12 16:32:29,056 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2015-08-12 16:32:29,056 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2015-08-12 16:32:29,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2015-08-12 16:32:29,400 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1439421908211_0011
2015-08-12 16:32:29,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0011/
2015-08-12 16:32:55,670 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0011_01_000005 is : 143
2015-08-12 16:32:56,385 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0011_01_000002 is : 143
2015-08-12 16:32:58,132 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2015-08-12 16:32:58,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:29.074, using cpu time: 00:04.090
2015-08-12 16:32:58,177 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2015-08-12 16:32:58,235 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:32:58,236 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:32:58,309 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2015-08-12 16:32:58,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:32:58,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:32:58,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2015-08-12 16:32:58,348 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:32:58,350 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:32:58,351 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:32:58,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2015-08-12 16:32:58,354 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  parallel execution of steps is enabled: true
2015-08-12 16:32:58,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  executing total steps: 1
2015-08-12 16:32:58,356 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  allocating management threads: 1
2015-08-12 16:32:58,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-08-12 16:32:58,710 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1439421908211_0012
2015-08-12 16:32:58,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0012/
2015-08-12 16:33:32,587 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0012_01_000006 is : 143
2015-08-12 16:33:33,637 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0012_01_000005 is : 143
2015-08-12 16:33:35,300 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2015-08-12 16:33:35,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  completed in: 00:36.942, using cpu time: 00:07.020
2015-08-12 16:33:35,352 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2015-08-12 16:33:35,411 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:33:35,412 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:33:35,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2015-08-12 16:33:35,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 16:33:35,438 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeFail/simplemergefail
2015-08-12 16:33:35,485 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:33:35,486 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:33:35,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2015-08-12 16:33:35,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:33:35,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:33:35,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2015-08-12 16:33:35,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:33:35,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:33:35,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:33:35,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2015-08-12 16:33:35,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  parallel execution of steps is enabled: true
2015-08-12 16:33:35,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  executing total steps: 1
2015-08-12 16:33:35,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  allocating management threads: 1
2015-08-12 16:33:35,616 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-08-12 16:33:35,902 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1439421908211_0013
2015-08-12 16:33:35,902 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0013/
2015-08-12 16:34:23,285 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0013_01_000009 is : 143
2015-08-12 16:34:23,871 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0013_01_000007 is : 143
2015-08-12 16:34:25,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0013_01_000006 is : 143
2015-08-12 16:34:26,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0013_01_000002 is : 143
2015-08-12 16:34:26,171 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0013_01_000003 is : 143
2015-08-12 16:34:31,607 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0013_01_000011 is : 143
2015-08-12 16:34:33,012 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2015-08-12 16:34:33,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  completed in: 00:57.399, using cpu time: 00:12.690
2015-08-12 16:34:33,057 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2015-08-12 16:34:33,210 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:34:33,211 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:34:33,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.159
2015-08-12 16:34:33,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-08-12 16:34:33,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:34:33,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2015-08-12 16:34:33,434 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:34:33,434 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:34:33,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:34:33,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-08-12 16:34:33,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2015-08-12 16:34:33,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  executing total steps: 3
2015-08-12 16:34:33,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  allocating management threads: 3
2015-08-12 16:34:33,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/3)
2015-08-12 16:34:33,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1439421908211_0014
2015-08-12 16:34:33,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0014/
2015-08-12 16:35:09,706 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0014_01_000005 is : 143
2015-08-12 16:35:09,864 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0014_01_000007 is : 143
2015-08-12 16:35:11,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/3)
2015-08-12 16:35:11,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1439421908211_0015
2015-08-12 16:35:11,448 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0015/
2015-08-12 16:35:42,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0015_01_000002 is : 143
2015-08-12 16:35:45,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0015_01_000006 is : 143
2015-08-12 16:35:45,866 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0015_01_000004 is : 143
2015-08-12 16:35:45,999 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0015_01_000005 is : 143
2015-08-12 16:35:47,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2015-08-12 16:35:47,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1439421908211_0016
2015-08-12 16:35:47,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0016/
2015-08-12 16:36:16,811 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0016_01_000003 is : 143
2015-08-12 16:36:18,678 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0016_01_000004 is : 143
2015-08-12 16:36:20,000 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-08-12 16:36:20,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  completed in: 01:46.558, using cpu time: 00:21.000
2015-08-12 16:36:20,056 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-08-12 16:36:20,129 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:36:20,129 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:36:20,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.119
2015-08-12 16:36:20,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:36:20,274 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:36:20,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2015-08-12 16:36:20,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:36:20,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:36:20,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:36:20,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2015-08-12 16:36:20,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  parallel execution of steps is enabled: true
2015-08-12 16:36:20,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  executing total steps: 1
2015-08-12 16:36:20,321 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  allocating management threads: 1
2015-08-12 16:36:20,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-08-12 16:36:20,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1439421908211_0017
2015-08-12 16:36:20,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0017/
2015-08-12 16:36:57,532 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0017_01_000007 is : 143
2015-08-12 16:36:58,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0017_01_000006 is : 143
2015-08-12 16:36:59,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0017_01_000002 is : 143
2015-08-12 16:37:01,190 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2015-08-12 16:37:01,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  completed in: 00:40.866, using cpu time: 00:07.890
2015-08-12 16:37:01,264 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2015-08-12 16:37:01,331 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:37:01,332 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:37:01,408 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2015-08-12 16:37:01,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 16:37:01,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:37:01,473 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2015-08-12 16:37:01,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:37:01,475 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:37:01,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:37:01,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2015-08-12 16:37:01,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  parallel execution of steps is enabled: true
2015-08-12 16:37:01,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  executing total steps: 1
2015-08-12 16:37:01,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  allocating management threads: 1
2015-08-12 16:37:01,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-08-12 16:37:01,716 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1439421908211_0018
2015-08-12 16:37:01,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0018/
2015-08-12 16:37:48,584 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000007 is : 143
2015-08-12 16:37:48,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000005 is : 143
2015-08-12 16:37:49,625 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000009 is : 143
2015-08-12 16:37:49,817 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000003 is : 143
2015-08-12 16:37:51,197 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000008 is : 143
2015-08-12 16:37:51,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000006 is : 143
2015-08-12 16:37:57,646 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0018_01_000011 is : 143
2015-08-12 16:37:58,985 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2015-08-12 16:37:58,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  completed in: 00:57.508, using cpu time: 00:13.740
2015-08-12 16:37:59,018 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2015-08-12 16:37:59,057 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:37:59,059 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:37:59,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2015-08-12 16:37:59,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-08-12 16:37:59,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:37:59,181 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2015-08-12 16:37:59,182 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:37:59,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2015-08-12 16:37:59,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  parallel execution of steps is enabled: true
2015-08-12 16:37:59,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  executing total steps: 2
2015-08-12 16:37:59,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  allocating management threads: 2
2015-08-12 16:37:59,201 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/2)
2015-08-12 16:37:59,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1439421908211_0019
2015-08-12 16:37:59,475 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0019/
2015-08-12 16:38:29,013 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0019_01_000003 is : 143
2015-08-12 16:38:32,254 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0019_01_000004 is : 143
2015-08-12 16:38:32,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0019_01_000005 is : 143
2015-08-12 16:38:38,772 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0019_01_000007 is : 143
2015-08-12 16:38:40,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2015-08-12 16:38:40,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1439421908211_0020
2015-08-12 16:38:40,365 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0020/
2015-08-12 16:39:14,105 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0020_01_000006 is : 143
2015-08-12 16:39:14,172 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0020_01_000007 is : 143
2015-08-12 16:39:14,389 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0020_01_000003 is : 143
2015-08-12 16:39:21,340 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0020_01_000008 is : 143
2015-08-12 16:39:22,642 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2015-08-12 16:39:22,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  completed in: 01:23.454, using cpu time: 00:13.770
2015-08-12 16:39:22,676 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2015-08-12 16:39:22,717 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:39:22,720 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:39:22,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.217
2015-08-12 16:39:22,961 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-08-12 16:39:22,961 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:39:23,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2015-08-12 16:39:23,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:39:23,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:39:23,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:39:23,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-08-12 16:39:23,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  parallel execution of steps is enabled: true
2015-08-12 16:39:23,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  executing total steps: 3
2015-08-12 16:39:23,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  allocating management threads: 3
2015-08-12 16:39:23,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/3)
2015-08-12 16:39:23,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1439421908211_0021
2015-08-12 16:39:23,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0021/
2015-08-12 16:39:59,780 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0021_01_000007 is : 143
2015-08-12 16:40:01,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (2/3)
2015-08-12 16:40:01,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1439421908211_0022
2015-08-12 16:40:01,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0022/
2015-08-12 16:40:40,668 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0022_01_000006 is : 143
2015-08-12 16:40:43,484 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0022_01_000004 is : 143
2015-08-12 16:40:43,611 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0022_01_000007 is : 143
2015-08-12 16:40:44,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2015-08-12 16:40:45,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1439421908211_0023
2015-08-12 16:40:45,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0023/
2015-08-12 16:41:41,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0023_01_000004 is : 143
2015-08-12 16:41:43,547 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-08-12 16:41:43,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  completed in: 02:20.463, using cpu time: 00:28.350
2015-08-12 16:41:43,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-08-12 16:41:43,668 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:41:43,669 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:41:43,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2015-08-12 16:41:43,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:41:43,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:41:43,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2015-08-12 16:41:43,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:41:43,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:41:43,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:41:43,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2015-08-12 16:41:43,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  parallel execution of steps is enabled: true
2015-08-12 16:41:43,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  executing total steps: 1
2015-08-12 16:41:43,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  allocating management threads: 1
2015-08-12 16:41:43,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2015-08-12 16:41:44,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1439421908211_0024
2015-08-12 16:41:44,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0024/
2015-08-12 16:42:17,242 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0024_01_000005 is : 143
2015-08-12 16:42:17,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0024_01_000003 is : 143
2015-08-12 16:42:18,322 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0024_01_000002 is : 143
2015-08-12 16:42:18,411 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0024_01_000004 is : 143
2015-08-12 16:42:19,761 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2015-08-12 16:42:19,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  completed in: 00:35.976, using cpu time: 00:06.110
2015-08-12 16:42:19,885 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2015-08-12 16:42:19,998 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:42:20,001 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:42:20,075 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2015-08-12 16:42:20,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 16:42:20,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:42:20,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting
2015-08-12 16:42:20,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 16:42:20,104 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2015-08-12 16:42:20,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  parallel execution of steps is enabled: true
2015-08-12 16:42:20,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  executing total steps: 1
2015-08-12 16:42:20,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  allocating management threads: 1
2015-08-12 16:42:20,115 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2015-08-12 16:42:20,328 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] submitted hadoop job: job_1439421908211_0025
2015-08-12 16:42:20,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0025/
2015-08-12 16:42:50,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0025_01_000003 is : 143
2015-08-12 16:42:52,494 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2015-08-12 16:42:52,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  completed in: 00:32.390, using cpu time: 00:05.140
2015-08-12 16:42:52,540 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2015-08-12 16:42:52,617 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:42:52,620 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:42:52,717 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.091
2015-08-12 16:42:52,722 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 16:42:52,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:42:52,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2015-08-12 16:42:52,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:42:52,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:42:52,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:42:52,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2015-08-12 16:42:52,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  parallel execution of steps is enabled: true
2015-08-12 16:42:52,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  executing total steps: 2
2015-08-12 16:42:52,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  allocating management threads: 2
2015-08-12 16:42:52,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/2)
2015-08-12 16:42:53,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1439421908211_0026
2015-08-12 16:42:53,013 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0026/
2015-08-12 16:43:33,074 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0026_01_000006 is : 143
2015-08-12 16:43:33,622 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0026_01_000005 is : 143
2015-08-12 16:43:35,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2015-08-12 16:43:35,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1439421908211_0027
2015-08-12 16:43:35,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0027/
2015-08-12 16:44:07,793 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0027_01_000006 is : 143
2015-08-12 16:44:10,817 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0027_01_000004 is : 143
2015-08-12 16:44:13,855 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-08-12 16:44:13,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  completed in: 01:21.100, using cpu time: 00:15.230
2015-08-12 16:44:13,919 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2015-08-12 16:44:13,983 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:44:13,984 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:44:14,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.125
2015-08-12 16:44:14,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-08-12 16:44:14,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:44:14,205 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting
2015-08-12 16:44:14,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:44:14,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:44:14,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:44:14,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-08-12 16:44:14,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  parallel execution of steps is enabled: true
2015-08-12 16:44:14,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  executing total steps: 3
2015-08-12 16:44:14,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  allocating management threads: 3
2015-08-12 16:44:14,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (1/3)
2015-08-12 16:44:14,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1439421908211_0028
2015-08-12 16:44:14,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0028/
2015-08-12 16:44:57,587 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0028_01_000004 is : 143
2015-08-12 16:44:58,579 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0028_01_000002 is : 143
2015-08-12 16:44:58,697 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0028_01_000005 is : 143
2015-08-12 16:45:00,090 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (2/3)
2015-08-12 16:45:00,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1439421908211_0029
2015-08-12 16:45:00,347 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0029/
2015-08-12 16:45:32,876 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0029_01_000002 is : 143
2015-08-12 16:45:34,783 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0029_01_000006 is : 143
2015-08-12 16:45:35,196 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0029_01_000004 is : 143
2015-08-12 16:45:37,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2015-08-12 16:45:37,512 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1439421908211_0030
2015-08-12 16:45:37,512 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0030/
2015-08-12 16:46:08,401 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0030_01_000006 is : 143
2015-08-12 16:46:10,783 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0030_01_000002 is : 143
2015-08-12 16:46:11,106 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0030_01_000003 is : 143
2015-08-12 16:46:12,815 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-08-12 16:46:12,821 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  completed in: 01:58.606, using cpu time: 00:23.630
2015-08-12 16:46:12,857 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-08-12 16:46:12,909 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 16:46:12,910 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 16:46:13,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.115
2015-08-12 16:46:13,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-08-12 16:46:13,033 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 16:46:13,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2015-08-12 16:46:13,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 16:46:13,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 16:46:13,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 16:46:13,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-08-12 16:46:13,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  parallel execution of steps is enabled: true
2015-08-12 16:46:13,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  executing total steps: 2
2015-08-12 16:46:13,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  allocating management threads: 2
2015-08-12 16:46:13,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/2)
2015-08-12 16:46:13,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1439421908211_0031
2015-08-12 16:46:13,348 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0031/
2015-08-12 16:46:54,586 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0031_01_000007 is : 143
2015-08-12 16:46:55,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0031_01_000005 is : 143
2015-08-12 16:46:55,276 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0031_01_000004 is : 143
2015-08-12 16:46:56,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2015-08-12 16:46:56,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1439421908211_0032
2015-08-12 16:46:56,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://node1.bidemo.com:40956/proxy/application_1439421908211_0032/
2015-08-12 16:47:28,366 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0032_01_000004 is : 143
2015-08-12 16:47:29,052 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0032_01_000006 is : 143
2015-08-12 16:47:29,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439421908211_0032_01_000003 is : 143
2015-08-12 16:47:31,354 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-08-12 16:47:31,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  completed in: 01:18.269, using cpu time: 00:16.420
2015-08-12 16:47:31,413 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge

Standard error

Aug 12, 2015 4:25:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Aug 12, 2015 4:25:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 4:25:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 4:25:09 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 4:25:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Aug 12, 2015 4:25:11 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 4:25:11 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 4:25:11 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 4:25:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 4:25:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Aug 12, 2015 4:25:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 4:25:12 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 4:25:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:12 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Aug 12, 2015 4:25:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Aug 12, 2015 4:25:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Aug 12, 2015 4:25:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Aug 12, 2015 4:25:13 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Aug 12, 2015 4:25:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Aug 12, 2015 4:25:13 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.