Class cascading.MergePipesPlatformTest

21

tests

0

failures

0

ignored

13m9.50s

duration

100%

successful

Tests

Test Duration Result
testHashJoinMergeIntoHashJoinAccumulated 34.967s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated 52.294s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 58.483s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed 53.198s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 56.392s passed
testHashJoinMergeIntoHashJoinStreamed 38.193s passed
testHashJoinMergeIntoHashJoinStreamedAccumulated 56.311s passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 59.351s passed
testHashJoinMergeIntoHashJoinStreamedStreamed 39.718s passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge 1m9.91s passed
testMergeIntoHashJoinAccumulated 34.969s passed
testMergeIntoHashJoinStreamed 18.656s passed
testSameSourceMergeThreeChainGroup 46.157s passed
testSimpleMerge 32.563s passed
testSimpleMergeFail 0.015s passed
testSimpleMergeThree 25.178s passed
testSimpleMergeThreeChain 25.415s passed
testSimpleMergeThreeChainCoGroup 28.372s passed
testSimpleMergeThreeChainGroup 28.737s passed
testSplitSameSourceMerged 15.525s passed
testSplitSameSourceMergedComplex 15.094s passed

Standard output

2015-05-20 19:36:05,645 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 19:36:05,678 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 19:36:05,678 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest
2015-05-20 19:36:05,699 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 19:36:06,275 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-05-20 19:36:06,769 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 19:36:11,361 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-05-20 19:36:12,565 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-05-20 19:36:13,713 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-05-20 19:36:14,893 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-05-20 19:36:17,527 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:36:17,528 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:36:17,534 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 37A6F6BD85B248D9B186FA27B77B97E4
2015-05-20 19:36:17,637 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 19:36:17,637 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 19:36:17,638 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:36:17,638 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:36:17,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge"]
2015-05-20 19:36:17,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-05-20 19:36:17,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-05-20 19:36:17,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-05-20 19:36:17,640 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-05-20 19:36:18,149 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432175769503_0001
2015-05-20 19:36:18,149 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0001/
2015-05-20 19:36:36,354 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0001_01_000005 is : 143
2015-05-20 19:36:36,466 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0001_01_000007 is : 143
2015-05-20 19:36:36,513 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0001_01_000002 is : 143
2015-05-20 19:36:36,622 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0001_01_000006 is : 143
2015-05-20 19:36:36,680 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0001_01_000003 is : 143
2015-05-20 19:36:36,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0001_01_000004 is : 143
2015-05-20 19:36:38,155 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge/_temporary
2015-05-20 19:36:38,235 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/simplemerge
2015-05-20 19:36:38,301 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:36:38,301 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:36:38,391 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-05-20 19:36:38,391 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:36:38,391 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:36:38,392 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:36:38,392 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-05-20 19:36:38,392 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true
2015-05-20 19:36:38,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3
2015-05-20 19:36:38,393 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3
2015-05-20 19:36:38,396 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-05-20 19:36:38,529 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432175769503_0002
2015-05-20 19:36:38,529 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0002/
2015-05-20 19:36:56,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0002_01_000004 is : 143
2015-05-20 19:36:56,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0002_01_000007 is : 143
2015-05-20 19:36:56,919 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0002_01_000002 is : 143
2015-05-20 19:36:56,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0002_01_000005 is : 143
2015-05-20 19:36:57,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0002_01_000003 is : 143
2015-05-20 19:36:57,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0002_01_000006 is : 143
2015-05-20 19:36:59,018 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-05-20 19:36:59,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432175769503_0003
2015-05-20 19:36:59,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0003/
2015-05-20 19:37:17,093 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0003_01_000002 is : 143
2015-05-20 19:37:17,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0003_01_000003 is : 143
2015-05-20 19:37:17,505 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0003_01_000007 is : 143
2015-05-20 19:37:17,537 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0003_01_000005 is : 143
2015-05-20 19:37:17,705 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0003_01_000004 is : 143
2015-05-20 19:37:17,803 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0003_01_000006 is : 143
2015-05-20 19:37:19,013 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-05-20 19:37:19,131 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432175769503_0004
2015-05-20 19:37:19,131 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0004/
2015-05-20 19:37:35,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0004_01_000006 is : 143
2015-05-20 19:37:35,301 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0004_01_000004 is : 143
2015-05-20 19:37:35,332 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0004_01_000002 is : 143
2015-05-20 19:37:35,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0004_01_000005 is : 143
2015-05-20 19:37:35,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0004_01_000003 is : 143
2015-05-20 19:37:36,711 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-05-20 19:37:36,732 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-05-20 19:37:36,763 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:37:36,764 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:37:36,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-05-20 19:37:36,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:37:36,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:37:36,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:37:36,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-05-20 19:37:36,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true
2015-05-20 19:37:36,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3
2015-05-20 19:37:36,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3
2015-05-20 19:37:36,826 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-05-20 19:37:36,966 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432175769503_0005
2015-05-20 19:37:36,966 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0005/
2015-05-20 19:37:54,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0005_01_000007 is : 143
2015-05-20 19:37:54,400 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0005_01_000006 is : 143
2015-05-20 19:37:54,595 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0005_01_000004 is : 143
2015-05-20 19:37:54,629 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0005_01_000005 is : 143
2015-05-20 19:37:54,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0005_01_000003 is : 143
2015-05-20 19:37:54,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0005_01_000002 is : 143
2015-05-20 19:37:56,026 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-05-20 19:37:56,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432175769503_0006
2015-05-20 19:37:56,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0006/
2015-05-20 19:38:19,249 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000009 is : 143
2015-05-20 19:38:19,328 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000007 is : 143
2015-05-20 19:38:19,532 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000010 is : 143
2015-05-20 19:38:19,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000006 is : 143
2015-05-20 19:38:19,598 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000008 is : 143
2015-05-20 19:38:19,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000005 is : 143
2015-05-20 19:38:19,915 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000002 is : 143
2015-05-20 19:38:19,958 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000003 is : 143
2015-05-20 19:38:20,040 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0006_01_000004 is : 143
2015-05-20 19:38:21,245 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-05-20 19:38:21,353 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432175769503_0007
2015-05-20 19:38:21,353 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0007/
2015-05-20 19:38:44,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000007 is : 143
2015-05-20 19:38:44,621 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000006 is : 143
2015-05-20 19:38:45,013 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000002 is : 143
2015-05-20 19:38:45,078 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000005 is : 143
2015-05-20 19:38:45,148 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000010 is : 143
2015-05-20 19:38:45,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000003 is : 143
2015-05-20 19:38:45,210 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000009 is : 143
2015-05-20 19:38:45,233 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000008 is : 143
2015-05-20 19:38:45,380 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0007_01_000004 is : 143
2015-05-20 19:38:46,610 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-05-20 19:38:46,638 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-05-20 19:38:46,671 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:38:46,672 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:38:46,687 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 19:38:46,687 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:38:46,687 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:38:46,687 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:38:46,687 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree"]
2015-05-20 19:38:46,689 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-05-20 19:38:46,689 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-05-20 19:38:46,690 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-05-20 19:38:46,690 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-05-20 19:38:46,798 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432175769503_0008
2015-05-20 19:38:46,798 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0008/
2015-05-20 19:39:09,969 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000007 is : 143
2015-05-20 19:39:10,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000006 is : 143
2015-05-20 19:39:10,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000010 is : 143
2015-05-20 19:39:10,236 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000009 is : 143
2015-05-20 19:39:10,255 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000003 is : 143
2015-05-20 19:39:10,443 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000004 is : 143
2015-05-20 19:39:10,492 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000008 is : 143
2015-05-20 19:39:10,499 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000002 is : 143
2015-05-20 19:39:10,560 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0008_01_000005 is : 143
2015-05-20 19:39:11,789 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree/_temporary
2015-05-20 19:39:11,816 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethree
2015-05-20 19:39:11,857 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:39:11,857 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:39:11,893 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting
2015-05-20 19:39:11,893 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:39:11,893 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:39:11,893 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:39:11,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-05-20 19:39:11,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  parallel execution is enabled: true
2015-05-20 19:39:11,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  starting jobs: 2
2015-05-20 19:39:11,894 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  allocating threads: 2
2015-05-20 19:39:11,895 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)
2015-05-20 19:39:12,025 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1432175769503_0009
2015-05-20 19:39:12,025 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0009/
2015-05-20 19:39:30,015 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0009_01_000005 is : 143
2015-05-20 19:39:30,067 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0009_01_000004 is : 143
2015-05-20 19:39:30,334 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0009_01_000007 is : 143
2015-05-20 19:39:30,385 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0009_01_000002 is : 143
2015-05-20 19:39:30,443 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0009_01_000003 is : 143
2015-05-20 19:39:30,492 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0009_01_000006 is : 143
2015-05-20 19:39:31,710 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge
2015-05-20 19:39:31,808 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1432175769503_0010
2015-05-20 19:39:31,808 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0010/
2015-05-20 19:39:49,555 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0010_01_000007 is : 143
2015-05-20 19:39:49,581 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0010_01_000006 is : 143
2015-05-20 19:39:50,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0010_01_000004 is : 143
2015-05-20 19:39:50,085 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0010_01_000005 is : 143
2015-05-20 19:39:50,206 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0010_01_000002 is : 143
2015-05-20 19:39:50,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0010_01_000003 is : 143
2015-05-20 19:39:51,520 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-05-20 19:39:51,540 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-05-20 19:39:51,574 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:39:51,574 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:39:51,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-05-20 19:39:51,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:39:51,588 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:39:51,589 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:39:51,589 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain"]
2015-05-20 19:39:51,589 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-05-20 19:39:51,590 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1
2015-05-20 19:39:51,590 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1
2015-05-20 19:39:51,591 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain
2015-05-20 19:39:51,697 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432175769503_0011
2015-05-20 19:39:51,697 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0011/
2015-05-20 19:40:15,183 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000002 is : 143
2015-05-20 19:40:15,291 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000006 is : 143
2015-05-20 19:40:15,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000003 is : 143
2015-05-20 19:40:15,316 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000008 is : 143
2015-05-20 19:40:15,487 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000005 is : 143
2015-05-20 19:40:15,548 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000004 is : 143
2015-05-20 19:40:15,553 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000010 is : 143
2015-05-20 19:40:15,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000009 is : 143
2015-05-20 19:40:15,694 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0011_01_000007 is : 143
2015-05-20 19:40:16,926 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain/_temporary
2015-05-20 19:40:16,951 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechain
2015-05-20 19:40:16,992 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:40:16,992 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:40:17,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-05-20 19:40:17,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:40:17,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:40:17,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:40:17,040 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-05-20 19:40:17,040 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true
2015-05-20 19:40:17,040 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3
2015-05-20 19:40:17,040 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3
2015-05-20 19:40:17,042 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-05-20 19:40:17,140 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432175769503_0012
2015-05-20 19:40:17,140 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0012/
2015-05-20 19:40:34,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0012_01_000007 is : 143
2015-05-20 19:40:34,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0012_01_000006 is : 143
2015-05-20 19:40:35,070 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0012_01_000004 is : 143
2015-05-20 19:40:35,096 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0012_01_000003 is : 143
2015-05-20 19:40:35,236 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0012_01_000002 is : 143
2015-05-20 19:40:35,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0012_01_000005 is : 143
2015-05-20 19:40:36,470 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-05-20 19:40:36,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432175769503_0013
2015-05-20 19:40:36,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0013/
2015-05-20 19:40:54,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0013_01_000007 is : 143
2015-05-20 19:40:54,235 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0013_01_000005 is : 143
2015-05-20 19:40:54,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0013_01_000004 is : 143
2015-05-20 19:40:54,403 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0013_01_000002 is : 143
2015-05-20 19:40:54,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0013_01_000003 is : 143
2015-05-20 19:40:54,511 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0013_01_000006 is : 143
2015-05-20 19:40:55,713 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-05-20 19:40:55,815 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432175769503_0014
2015-05-20 19:40:55,815 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0014/
2015-05-20 19:41:11,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0014_01_000004 is : 143
2015-05-20 19:41:11,817 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0014_01_000002 is : 143
2015-05-20 19:41:11,875 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0014_01_000005 is : 143
2015-05-20 19:41:11,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0014_01_000003 is : 143
2015-05-20 19:41:12,049 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0014_01_000006 is : 143
2015-05-20 19:41:13,249 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-05-20 19:41:13,270 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-05-20 19:41:13,302 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:41:13,303 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:41:13,317 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 19:41:13,317 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 19:41:13,317 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged"]
2015-05-20 19:41:13,318 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-05-20 19:41:13,318 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1
2015-05-20 19:41:13,318 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1
2015-05-20 19:41:13,319 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged
2015-05-20 19:41:13,423 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432175769503_0015
2015-05-20 19:41:13,423 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0015/
2015-05-20 19:41:27,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0015_01_000003 is : 143
2015-05-20 19:41:27,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0015_01_000002 is : 143
2015-05-20 19:41:27,419 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0015_01_000004 is : 143
2015-05-20 19:41:27,584 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0015_01_000005 is : 143
2015-05-20 19:41:28,779 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged/_temporary
2015-05-20 19:41:28,798 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemerged
2015-05-20 19:41:28,817 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:41:28,817 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:41:28,840 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-05-20 19:41:28,841 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:41:28,841 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:41:28,841 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:41:28,842 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]
2015-05-20 19:41:28,842 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-05-20 19:41:28,843 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 2
2015-05-20 19:41:28,843 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 2
2015-05-20 19:41:28,844 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)
2015-05-20 19:41:28,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432175769503_0016
2015-05-20 19:41:28,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0016/
2015-05-20 19:41:46,181 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0016_01_000007 is : 143
2015-05-20 19:41:46,426 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0016_01_000006 is : 143
2015-05-20 19:41:46,466 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0016_01_000004 is : 143
2015-05-20 19:41:46,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0016_01_000005 is : 143
2015-05-20 19:41:46,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0016_01_000003 is : 143
2015-05-20 19:41:46,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0016_01_000002 is : 143
2015-05-20 19:41:47,874 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed
2015-05-20 19:41:47,975 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432175769503_0017
2015-05-20 19:41:47,975 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0017/
2015-05-20 19:42:05,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0017_01_000007 is : 143
2015-05-20 19:42:05,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0017_01_000006 is : 143
2015-05-20 19:42:05,560 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0017_01_000002 is : 143
2015-05-20 19:42:05,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0017_01_000003 is : 143
2015-05-20 19:42:05,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0017_01_000005 is : 143
2015-05-20 19:42:05,775 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0017_01_000004 is : 143
2015-05-20 19:42:06,967 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary
2015-05-20 19:42:06,988 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed
2015-05-20 19:42:07,009 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:42:07,010 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:42:07,013 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergefail
2015-05-20 19:42:07,024 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:42:07,025 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:42:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-05-20 19:42:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:42:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:42:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:42:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup"]
2015-05-20 19:42:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-05-20 19:42:07,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1
2015-05-20 19:42:07,048 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1
2015-05-20 19:42:07,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-05-20 19:42:07,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432175769503_0018
2015-05-20 19:42:07,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0018/
2015-05-20 19:42:29,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000007 is : 143
2015-05-20 19:42:29,430 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000006 is : 143
2015-05-20 19:42:29,684 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000004 is : 143
2015-05-20 19:42:29,784 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000003 is : 143
2015-05-20 19:42:29,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000009 is : 143
2015-05-20 19:42:29,848 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000010 is : 143
2015-05-20 19:42:29,901 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000002 is : 143
2015-05-20 19:42:29,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000005 is : 143
2015-05-20 19:42:29,984 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000008 is : 143
2015-05-20 19:42:34,572 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0018_01_000011 is : 143
2015-05-20 19:42:35,732 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup/_temporary
2015-05-20 19:42:35,746 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup
2015-05-20 19:42:35,772 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:42:35,772 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:42:35,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-05-20 19:42:35,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:42:35,809 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:42:35,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:42:35,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-05-20 19:42:35,810 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true
2015-05-20 19:42:35,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3
2015-05-20 19:42:35,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3
2015-05-20 19:42:35,812 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-05-20 19:42:35,931 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432175769503_0019
2015-05-20 19:42:35,931 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0019/
2015-05-20 19:42:53,501 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0019_01_000007 is : 143
2015-05-20 19:42:53,528 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0019_01_000005 is : 143
2015-05-20 19:42:53,821 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0019_01_000003 is : 143
2015-05-20 19:42:53,839 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0019_01_000004 is : 143
2015-05-20 19:42:53,912 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0019_01_000006 is : 143
2015-05-20 19:42:54,062 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0019_01_000002 is : 143
2015-05-20 19:42:55,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-05-20 19:42:55,362 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432175769503_0020
2015-05-20 19:42:55,362 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0020/
2015-05-20 19:43:10,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0020_01_000005 is : 143
2015-05-20 19:43:10,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0020_01_000004 is : 143
2015-05-20 19:43:10,734 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0020_01_000006 is : 143
2015-05-20 19:43:10,773 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0020_01_000002 is : 143
2015-05-20 19:43:10,958 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0020_01_000003 is : 143
2015-05-20 19:43:12,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge
2015-05-20 19:43:12,250 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432175769503_0021
2015-05-20 19:43:12,250 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0021/
2015-05-20 19:43:27,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0021_01_000006 is : 143
2015-05-20 19:43:27,518 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0021_01_000005 is : 143
2015-05-20 19:43:27,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0021_01_000002 is : 143
2015-05-20 19:43:27,709 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0021_01_000004 is : 143
2015-05-20 19:43:27,751 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0021_01_000003 is : 143
2015-05-20 19:43:28,921 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-05-20 19:43:28,939 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-05-20 19:43:28,967 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:43:28,968 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:43:28,983 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-05-20 19:43:28,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:43:28,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:43:28,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:43:28,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed"]
2015-05-20 19:43:28,985 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-05-20 19:43:28,985 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1
2015-05-20 19:43:28,985 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1
2015-05-20 19:43:28,986 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-05-20 19:43:29,091 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432175769503_0022
2015-05-20 19:43:29,091 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0022/
2015-05-20 19:43:45,927 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0022_01_000002 is : 143
2015-05-20 19:43:46,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0022_01_000007 is : 143
2015-05-20 19:43:46,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0022_01_000004 is : 143
2015-05-20 19:43:46,235 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0022_01_000005 is : 143
2015-05-20 19:43:46,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0022_01_000006 is : 143
2015-05-20 19:43:46,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0022_01_000003 is : 143
2015-05-20 19:43:47,574 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed/_temporary
2015-05-20 19:43:47,594 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed
2015-05-20 19:43:47,617 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:43:47,618 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:43:47,634 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-05-20 19:43:47,635 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:43:47,635 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:43:47,635 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:43:47,635 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup"]
2015-05-20 19:43:47,636 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-05-20 19:43:47,636 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1
2015-05-20 19:43:47,636 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1
2015-05-20 19:43:47,637 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-05-20 19:43:47,752 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432175769503_0023
2015-05-20 19:43:47,752 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0023/
2015-05-20 19:44:09,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000008 is : 143
2015-05-20 19:44:09,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000002 is : 143
2015-05-20 19:44:09,775 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000006 is : 143
2015-05-20 19:44:09,842 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000004 is : 143
2015-05-20 19:44:09,893 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000007 is : 143
2015-05-20 19:44:09,930 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000010 is : 143
2015-05-20 19:44:09,957 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000005 is : 143
2015-05-20 19:44:09,980 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000009 is : 143
2015-05-20 19:44:10,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000003 is : 143
2015-05-20 19:44:14,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0023_01_000011 is : 143
2015-05-20 19:44:15,961 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup/_temporary
2015-05-20 19:44:15,974 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup
2015-05-20 19:44:15,990 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:44:15,990 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:44:16,005 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-05-20 19:44:16,006 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:44:16,006 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup"]
2015-05-20 19:44:16,006 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-05-20 19:44:16,006 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 2
2015-05-20 19:44:16,007 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 2
2015-05-20 19:44:16,008 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)
2015-05-20 19:44:16,100 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432175769503_0024
2015-05-20 19:44:16,100 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0024/
2015-05-20 19:44:31,512 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0024_01_000002 is : 143
2015-05-20 19:44:31,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0024_01_000003 is : 143
2015-05-20 19:44:31,675 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0024_01_000006 is : 143
2015-05-20 19:44:31,699 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0024_01_000005 is : 143
2015-05-20 19:44:31,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0024_01_000004 is : 143
2015-05-20 19:44:36,895 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0024_01_000007 is : 143
2015-05-20 19:44:38,054 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup
2015-05-20 19:44:38,167 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432175769503_0025
2015-05-20 19:44:38,167 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0025/
2015-05-20 19:44:55,359 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000005 is : 143
2015-05-20 19:44:55,420 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000003 is : 143
2015-05-20 19:44:55,492 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000007 is : 143
2015-05-20 19:44:55,511 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000002 is : 143
2015-05-20 19:44:55,527 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000006 is : 143
2015-05-20 19:44:55,578 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000004 is : 143
2015-05-20 19:45:00,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0025_01_000008 is : 143
2015-05-20 19:45:02,116 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup/_temporary
2015-05-20 19:45:02,131 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/samemergethreechaingroup
2015-05-20 19:45:02,150 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:45:02,150 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:45:02,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-05-20 19:45:02,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:45:02,189 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:45:02,189 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:45:02,189 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-05-20 19:45:02,189 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true
2015-05-20 19:45:02,190 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3
2015-05-20 19:45:02,190 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3
2015-05-20 19:45:02,191 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-05-20 19:45:02,302 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432175769503_0026
2015-05-20 19:45:02,302 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0026/
2015-05-20 19:45:19,349 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0026_01_000004 is : 143
2015-05-20 19:45:19,456 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0026_01_000007 is : 143
2015-05-20 19:45:19,704 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0026_01_000005 is : 143
2015-05-20 19:45:19,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0026_01_000006 is : 143
2015-05-20 19:45:19,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0026_01_000003 is : 143
2015-05-20 19:45:19,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0026_01_000002 is : 143
2015-05-20 19:45:21,112 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-05-20 19:45:21,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432175769503_0027
2015-05-20 19:45:21,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0027/
2015-05-20 19:45:38,402 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0027_01_000007 is : 143
2015-05-20 19:45:38,476 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0027_01_000002 is : 143
2015-05-20 19:45:38,588 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0027_01_000003 is : 143
2015-05-20 19:45:38,811 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0027_01_000004 is : 143
2015-05-20 19:45:38,837 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0027_01_000005 is : 143
2015-05-20 19:45:38,845 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0027_01_000006 is : 143
2015-05-20 19:45:40,050 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-05-20 19:45:40,156 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432175769503_0028
2015-05-20 19:45:40,156 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0028/
2015-05-20 19:45:56,764 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0028_01_000002 is : 143
2015-05-20 19:45:56,973 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0028_01_000003 is : 143
2015-05-20 19:45:57,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0028_01_000007 is : 143
2015-05-20 19:45:57,218 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0028_01_000006 is : 143
2015-05-20 19:45:57,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0028_01_000004 is : 143
2015-05-20 19:45:57,313 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0028_01_000005 is : 143
2015-05-20 19:45:58,498 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-05-20 19:45:58,516 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-05-20 19:45:58,543 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:45:58,543 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:45:58,559 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-05-20 19:45:58,559 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:45:58,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:45:58,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:45:58,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated"]
2015-05-20 19:45:58,568 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true
2015-05-20 19:45:58,568 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2
2015-05-20 19:45:58,568 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2
2015-05-20 19:45:58,569 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-05-20 19:45:58,670 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432175769503_0029
2015-05-20 19:45:58,670 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0029/
2015-05-20 19:46:15,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0029_01_000007 is : 143
2015-05-20 19:46:15,212 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0029_01_000006 is : 143
2015-05-20 19:46:15,478 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0029_01_000002 is : 143
2015-05-20 19:46:15,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0029_01_000003 is : 143
2015-05-20 19:46:15,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0029_01_000004 is : 143
2015-05-20 19:46:15,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0029_01_000005 is : 143
2015-05-20 19:46:16,850 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-05-20 19:46:16,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432175769503_0030
2015-05-20 19:46:16,956 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0030/
2015-05-20 19:46:32,006 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0030_01_000002 is : 143
2015-05-20 19:46:32,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0030_01_000003 is : 143
2015-05-20 19:46:32,219 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0030_01_000005 is : 143
2015-05-20 19:46:32,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0030_01_000006 is : 143
2015-05-20 19:46:32,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0030_01_000004 is : 143
2015-05-20 19:46:33,471 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated/_temporary
2015-05-20 19:46:33,488 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated
2015-05-20 19:46:33,510 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:46:33,511 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:46:33,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 19:46:33,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 19:46:33,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex"]
2015-05-20 19:46:33,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-05-20 19:46:33,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1
2015-05-20 19:46:33,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1
2015-05-20 19:46:33,524 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex
2015-05-20 19:46:33,629 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432175769503_0031
2015-05-20 19:46:33,629 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0031/
2015-05-20 19:46:47,164 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0031_01_000003 is : 143
2015-05-20 19:46:47,301 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0031_01_000004 is : 143
2015-05-20 19:46:47,363 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0031_01_000005 is : 143
2015-05-20 19:46:47,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0031_01_000002 is : 143
2015-05-20 19:46:48,567 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex/_temporary
2015-05-20 19:46:48,583 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex
2015-05-20 19:46:48,606 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:46:48,606 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:46:48,625 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-05-20 19:46:48,625 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:46:48,626 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:46:48,626 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:46:48,626 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]
2015-05-20 19:46:48,627 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true
2015-05-20 19:46:48,627 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2
2015-05-20 19:46:48,627 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2
2015-05-20 19:46:48,628 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-05-20 19:46:48,730 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432175769503_0032
2015-05-20 19:46:48,730 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0032/
2015-05-20 19:47:05,087 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0032_01_000007 is : 143
2015-05-20 19:47:05,436 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0032_01_000006 is : 143
2015-05-20 19:47:05,551 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0032_01_000004 is : 143
2015-05-20 19:47:05,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0032_01_000005 is : 143
2015-05-20 19:47:05,714 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0032_01_000003 is : 143
2015-05-20 19:47:05,763 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0032_01_000002 is : 143
2015-05-20 19:47:06,969 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-05-20 19:47:07,065 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432175769503_0033
2015-05-20 19:47:07,065 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0033/
2015-05-20 19:47:21,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0033_01_000006 is : 143
2015-05-20 19:47:22,009 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0033_01_000004 is : 143
2015-05-20 19:47:22,181 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0033_01_000003 is : 143
2015-05-20 19:47:22,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0033_01_000002 is : 143
2015-05-20 19:47:22,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0033_01_000005 is : 143
2015-05-20 19:47:23,532 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-05-20 19:47:23,549 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated
2015-05-20 19:47:23,572 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:47:23,572 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:47:23,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting
2015-05-20 19:47:23,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:47:23,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:47:23,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:47:23,609 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-05-20 19:47:23,609 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  parallel execution is enabled: true
2015-05-20 19:47:23,609 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  starting jobs: 3
2015-05-20 19:47:23,609 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  allocating threads: 3
2015-05-20 19:47:23,611 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)
2015-05-20 19:47:23,724 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1432175769503_0034
2015-05-20 19:47:23,724 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0034/
2015-05-20 19:47:40,645 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0034_01_000007 is : 143
2015-05-20 19:47:40,881 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0034_01_000004 is : 143
2015-05-20 19:47:41,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0034_01_000006 is : 143
2015-05-20 19:47:41,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0034_01_000005 is : 143
2015-05-20 19:47:41,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0034_01_000003 is : 143
2015-05-20 19:47:41,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0034_01_000002 is : 143
2015-05-20 19:47:42,371 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)
2015-05-20 19:47:42,480 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1432175769503_0035
2015-05-20 19:47:42,480 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0035/
2015-05-20 19:47:57,531 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0035_01_000005 is : 143
2015-05-20 19:47:57,643 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0035_01_000004 is : 143
2015-05-20 19:47:57,843 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0035_01_000003 is : 143
2015-05-20 19:47:57,883 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0035_01_000006 is : 143
2015-05-20 19:47:57,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0035_01_000002 is : 143
2015-05-20 19:47:59,103 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-05-20 19:47:59,200 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1432175769503_0036
2015-05-20 19:47:59,200 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0036/
2015-05-20 19:48:14,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0036_01_000003 is : 143
2015-05-20 19:48:14,473 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0036_01_000005 is : 143
2015-05-20 19:48:14,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0036_01_000004 is : 143
2015-05-20 19:48:14,596 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0036_01_000006 is : 143
2015-05-20 19:48:14,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0036_01_000002 is : 143
2015-05-20 19:48:15,827 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-05-20 19:48:15,843 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-05-20 19:48:15,867 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:48:15,867 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:48:15,906 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-05-20 19:48:15,906 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:48:15,906 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:48:15,906 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:48:15,906 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-05-20 19:48:15,909 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true
2015-05-20 19:48:15,909 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3
2015-05-20 19:48:15,909 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3
2015-05-20 19:48:15,910 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-05-20 19:48:16,021 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432175769503_0037
2015-05-20 19:48:16,021 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0037/
2015-05-20 19:48:32,920 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0037_01_000007 is : 143
2015-05-20 19:48:32,989 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0037_01_000002 is : 143
2015-05-20 19:48:33,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0037_01_000005 is : 143
2015-05-20 19:48:33,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0037_01_000003 is : 143
2015-05-20 19:48:33,280 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0037_01_000006 is : 143
2015-05-20 19:48:33,381 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0037_01_000004 is : 143
2015-05-20 19:48:34,581 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-05-20 19:48:34,689 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432175769503_0038
2015-05-20 19:48:34,689 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0038/
2015-05-20 19:48:56,047 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000009 is : 143
2015-05-20 19:48:56,109 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000008 is : 143
2015-05-20 19:48:56,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000010 is : 143
2015-05-20 19:48:56,555 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000005 is : 143
2015-05-20 19:48:56,619 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000002 is : 143
2015-05-20 19:48:56,685 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000007 is : 143
2015-05-20 19:48:56,704 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000003 is : 143
2015-05-20 19:48:56,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000006 is : 143
2015-05-20 19:48:56,833 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0038_01_000004 is : 143
2015-05-20 19:48:58,034 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-05-20 19:48:58,080 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2015-05-20 19:48:58,136 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432175769503_0039
2015-05-20 19:48:58,136 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:57223/proxy/application_1432175769503_0039/
2015-05-20 19:48:59,201 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2015-05-20 19:48:59,202 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2015-05-20 19:49:13,684 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0039_01_000004 is : 143
2015-05-20 19:49:13,709 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0039_01_000002 is : 143
2015-05-20 19:49:13,822 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0039_01_000003 is : 143
2015-05-20 19:49:13,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0039_01_000006 is : 143
2015-05-20 19:49:13,999 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432175769503_0039_01_000005 is : 143
2015-05-20 19:49:15,177 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-05-20 19:49:15,195 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge

Standard error

May 20, 2015 7:36:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 7:36:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
May 20, 2015 7:36:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 7:36:11 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 7:36:11 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"
May 20, 2015 7:36:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 7:36: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"
May 20, 2015 7:36: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.
May 20, 2015 7:36:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 20, 2015 7:36:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 7:36:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 7:36:12 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 7:36:12 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"
May 20, 2015 7:36:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 7:36:12 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"
May 20, 2015 7:36: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.
May 20, 2015 7:36: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
May 20, 2015 7:36:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 7:36:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 7:36:13 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 7:36: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"
May 20, 2015 7:36:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 7:36: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"
May 20, 2015 7:36: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.
May 20, 2015 7:36:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 20, 2015 7:36:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 7:36:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 7:36:14 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 7:36:14 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"
May 20, 2015 7:36:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 7:36:15 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"
May 20, 2015 7:36:15 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.
May 20, 2015 7:36:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 20, 2015 7:36:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 7:36:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 7:36:15 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 7:36:16 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"
May 20, 2015 7:36:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 7:36:16 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"
May 20, 2015 7:36:16 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.