Class cascading.MergePipesPlatformTest

all > cascading > MergePipesPlatformTest

tests

failures

ignored

15m40.45s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testHashJoinMergeIntoHashJoinAccumulated	46.880s	passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated	1m4.86s	passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge	1m3.19s	passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed	59.874s	passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge	1m13.59s	passed
testHashJoinMergeIntoHashJoinStreamed	42.874s	passed
testHashJoinMergeIntoHashJoinStreamedAccumulated	1m2.18s	passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge	1m8.23s	passed
testHashJoinMergeIntoHashJoinStreamedStreamed	42.754s	passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge	1m27.64s	passed
testMergeIntoHashJoinAccumulated	47.141s	passed
testMergeIntoHashJoinStreamed	20.793s	passed
testSameSourceMergeThreeChainGroup	51.712s	passed
testSimpleMerge	46.398s	passed
testSimpleMergeFail	0.022s	passed
testSimpleMergeThree	27.997s	passed
testSimpleMergeThreeChain	27.633s	passed
testSimpleMergeThreeChainCoGroup	31.364s	passed
testSimpleMergeThreeChainGroup	31.806s	passed
testSplitSameSourceMerged	17.396s	passed
testSplitSameSourceMergedComplex	26.121s	passed

Standard output

2015-05-20 15:04:09,941 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 15:04:09,976 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 15:04:09,976 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest
2015-05-20 15:04:09,996 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 15:04:10,637 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 15:04:11,193 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 15:04:14,856 WARN  fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 15:04:15,141 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:04:15,373 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:04:15,592 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:04:15,838 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:04:33,040 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:04:33,041 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 15:04:33,047 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: AF5A385088A44502BEC0B4963014A8CC
2015-05-20 15:04:33,156 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 15:04:33,157 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 15:04:33,158 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:04:33,159 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:04:33,159 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge"]
2015-05-20 15:04:33,159 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-05-20 15:04:33,159 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-05-20 15:04:33,160 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-05-20 15:04:33,161 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-05-20 15:04:33,910 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432159467419_0001
2015-05-20 15:04:33,911 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0001/
2015-05-20 15:04:44,198 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0001_01_000009
2015-05-20 15:04:44,261 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0001_01_000010
2015-05-20 15:04:54,314 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0001_01_000002 is : 143
2015-05-20 15:04:54,599 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0001_01_000006 is : 143
2015-05-20 15:04:54,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0001_01_000007 is : 143
2015-05-20 15:04:54,743 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0001_01_000004 is : 143
2015-05-20 15:04:54,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0001_01_000003 is : 143
2015-05-20 15:04:55,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0001_01_000005 is : 143
2015-05-20 15:04:56,285 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge/_temporary
2015-05-20 15:04:56,373 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/simplemerge
2015-05-20 15:04:56,432 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:04:56,433 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 15:04:56,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3
2015-05-20 15:04:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3
2015-05-20 15:04:56,524 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-05-20 15:04:56,686 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432159467419_0002
2015-05-20 15:04:56,686 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0002/
2015-05-20 15:05:05,919 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0002_01_000009
2015-05-20 15:05:06,040 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0002_01_000010
2015-05-20 15:05:15,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0002_01_000002 is : 143
2015-05-20 15:05:16,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0002_01_000003 is : 143
2015-05-20 15:05:16,408 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0002_01_000006 is : 143
2015-05-20 15:05:16,581 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0002_01_000004 is : 143
2015-05-20 15:05:16,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0002_01_000005 is : 143
2015-05-20 15:05:16,749 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0002_01_000007 is : 143
2015-05-20 15:05:17,975 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-05-20 15:05:18,136 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432159467419_0003
2015-05-20 15:05:18,136 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0003/
2015-05-20 15:05:27,593 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0003_01_000010
2015-05-20 15:05:37,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0003_01_000002 is : 143
2015-05-20 15:05:37,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0003_01_000003 is : 143
2015-05-20 15:05:37,988 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0003_01_000008 is : 143
2015-05-20 15:05:38,312 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0003_01_000005 is : 143
2015-05-20 15:05:38,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0003_01_000004 is : 143
2015-05-20 15:05:38,413 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0003_01_000006 is : 143
2015-05-20 15:05:39,639 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-05-20 15:05:39,778 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432159467419_0004
2015-05-20 15:05:39,778 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0004/
2015-05-20 15:05:57,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0004_01_000002 is : 143
2015-05-20 15:05:57,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0004_01_000003 is : 143
2015-05-20 15:05:58,052 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0004_01_000006 is : 143
2015-05-20 15:05:58,190 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0004_01_000004 is : 143
2015-05-20 15:05:58,289 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0004_01_000005 is : 143
2015-05-20 15:05:59,536 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-05-20 15:05:59,563 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-05-20 15:05:59,608 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:05:59,609 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 15:05:59,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-05-20 15:05:59,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:05:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:05:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:05:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-05-20 15:05:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true
2015-05-20 15:05:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3
2015-05-20 15:05:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3
2015-05-20 15:05:59,669 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-05-20 15:05:59,851 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432159467419_0005
2015-05-20 15:05:59,851 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0005/
2015-05-20 15:06:09,213 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0005_01_000008
2015-05-20 15:06:09,299 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0005_01_000009
2015-05-20 15:06:19,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0005_01_000005 is : 143
2015-05-20 15:06:19,474 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0005_01_000003 is : 143
2015-05-20 15:06:19,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0005_01_000002 is : 143
2015-05-20 15:06:19,759 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0005_01_000006 is : 143
2015-05-20 15:06:19,810 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0005_01_000004 is : 143
2015-05-20 15:06:20,030 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0005_01_000007 is : 143
2015-05-20 15:06:21,226 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-05-20 15:06:21,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432159467419_0006
2015-05-20 15:06:21,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0006/
2015-05-20 15:06:31,046 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0006_01_000011
2015-05-20 15:06:31,185 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0006_01_000012
2015-05-20 15:06:31,831 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0006_01_000014
2015-05-20 15:06:54,210 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000005 is : 143
2015-05-20 15:06:54,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000009 is : 143
2015-05-20 15:06:54,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000008 is : 143
2015-05-20 15:06:54,820 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000010 is : 143
2015-05-20 15:06:55,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000002 is : 143
2015-05-20 15:06:55,266 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000003 is : 143
2015-05-20 15:06:55,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000007 is : 143
2015-05-20 15:06:55,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000006 is : 143
2015-05-20 15:06:55,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0006_01_000004 is : 143
2015-05-20 15:06:56,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-05-20 15:06:56,775 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432159467419_0007
2015-05-20 15:06:56,775 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0007/
2015-05-20 15:07:06,320 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0007_01_000012
2015-05-20 15:07:06,386 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0007_01_000014
2015-05-20 15:07:06,386 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0007_01_000013
2015-05-20 15:07:24,524 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000002 is : 143
2015-05-20 15:07:25,194 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000010 is : 143
2015-05-20 15:07:25,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000005 is : 143
2015-05-20 15:07:25,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000009 is : 143
2015-05-20 15:07:25,420 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000003 is : 143
2015-05-20 15:07:25,551 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000007 is : 143
2015-05-20 15:07:25,654 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000008 is : 143
2015-05-20 15:07:25,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000006 is : 143
2015-05-20 15:07:25,836 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0007_01_000004 is : 143
2015-05-20 15:07:27,174 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-05-20 15:07:27,203 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-05-20 15:07:27,248 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:07:27,248 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 15:07:27,268 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 15:07:27,268 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:07:27,268 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:07:27,268 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:07:27,268 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree"]
2015-05-20 15:07:27,269 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-05-20 15:07:27,269 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-05-20 15:07:27,269 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-05-20 15:07:27,270 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-05-20 15:07:27,444 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432159467419_0008
2015-05-20 15:07:27,444 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0008/
2015-05-20 15:07:36,829 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0008_01_000011
2015-05-20 15:07:37,262 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0008_01_000012
2015-05-20 15:07:37,831 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0008_01_000014
2015-05-20 15:07:52,609 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000005 is : 143
2015-05-20 15:07:53,033 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000009 is : 143
2015-05-20 15:07:53,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000002 is : 143
2015-05-20 15:07:53,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000004 is : 143
2015-05-20 15:07:53,663 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000003 is : 143
2015-05-20 15:07:53,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000007 is : 143
2015-05-20 15:07:53,763 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000008 is : 143
2015-05-20 15:07:53,865 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000006 is : 143
2015-05-20 15:07:53,931 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0008_01_000010 is : 143
2015-05-20 15:07:55,176 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree/_temporary
2015-05-20 15:07:55,206 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethree
2015-05-20 15:07:55,247 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:07:55,247 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 15:07:55,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting
2015-05-20 15:07:55,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:07:55,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:07:55,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:07:55,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-05-20 15:07:55,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  parallel execution is enabled: true
2015-05-20 15:07:55,293 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  starting jobs: 2
2015-05-20 15:07:55,294 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset]  allocating threads: 2
2015-05-20 15:07:55,295 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)
2015-05-20 15:07:55,468 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1432159467419_0009
2015-05-20 15:07:55,469 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0009/
2015-05-20 15:08:04,882 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0009_01_000009
2015-05-20 15:08:14,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0009_01_000002 is : 143
2015-05-20 15:08:15,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0009_01_000006 is : 143
2015-05-20 15:08:15,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0009_01_000005 is : 143
2015-05-20 15:08:15,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0009_01_000004 is : 143
2015-05-20 15:08:15,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0009_01_000003 is : 143
2015-05-20 15:08:15,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0009_01_000007 is : 143
2015-05-20 15:08:16,703 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge
2015-05-20 15:08:16,816 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1432159467419_0010
2015-05-20 15:08:16,816 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0010/
2015-05-20 15:08:26,287 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0010_01_000008
2015-05-20 15:08:36,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0010_01_000006 is : 143
2015-05-20 15:08:36,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0010_01_000004 is : 143
2015-05-20 15:08:36,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0010_01_000005 is : 143
2015-05-20 15:08:36,591 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0010_01_000003 is : 143
2015-05-20 15:08:36,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0010_01_000002 is : 143
2015-05-20 15:08:36,725 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0010_01_000007 is : 143
2015-05-20 15:08:37,937 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-05-20 15:08:37,963 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-05-20 15:08:37,999 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:08:38,000 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 15:08:38,021 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-05-20 15:08:38,021 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:08:38,021 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:08:38,021 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:08:38,021 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain"]
2015-05-20 15:08:38,022 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-05-20 15:08:38,022 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1
2015-05-20 15:08:38,022 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1
2015-05-20 15:08:38,023 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain
2015-05-20 15:08:38,160 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432159467419_0011
2015-05-20 15:08:38,161 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0011/
2015-05-20 15:08:47,737 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0011_01_000012
2015-05-20 15:08:48,099 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0011_01_000013
2015-05-20 15:08:48,608 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0011_01_000015
2015-05-20 15:09:02,697 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000002 is : 143
2015-05-20 15:09:03,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000003 is : 143
2015-05-20 15:09:03,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000005 is : 143
2015-05-20 15:09:03,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000004 is : 143
2015-05-20 15:09:03,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000009 is : 143
2015-05-20 15:09:04,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000006 is : 143
2015-05-20 15:09:04,119 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000008 is : 143
2015-05-20 15:09:04,245 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000007 is : 143
2015-05-20 15:09:04,306 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0011_01_000011 is : 143
2015-05-20 15:09:05,566 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain/_temporary
2015-05-20 15:09:05,594 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechain
2015-05-20 15:09:05,633 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:09:05,633 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 15:09:05,700 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-05-20 15:09:05,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:09:05,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:09:05,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:09:05,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-05-20 15:09:05,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true
2015-05-20 15:09:05,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3
2015-05-20 15:09:05,702 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3
2015-05-20 15:09:05,703 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-05-20 15:09:05,825 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432159467419_0012
2015-05-20 15:09:05,825 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0012/
2015-05-20 15:09:15,132 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0012_01_000009
2015-05-20 15:09:24,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0012_01_000002 is : 143
2015-05-20 15:09:25,327 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0012_01_000006 is : 143
2015-05-20 15:09:25,384 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0012_01_000003 is : 143
2015-05-20 15:09:25,711 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0012_01_000007 is : 143
2015-05-20 15:09:25,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0012_01_000005 is : 143
2015-05-20 15:09:25,803 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0012_01_000004 is : 143
2015-05-20 15:09:27,011 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-05-20 15:09:27,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432159467419_0013
2015-05-20 15:09:27,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0013/
2015-05-20 15:09:37,396 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0013_01_000008
2015-05-20 15:09:46,547 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0013_01_000006 is : 143
2015-05-20 15:09:46,870 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0013_01_000005 is : 143
2015-05-20 15:09:46,925 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0013_01_000002 is : 143
2015-05-20 15:09:47,198 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0013_01_000004 is : 143
2015-05-20 15:09:47,266 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0013_01_000007 is : 143
2015-05-20 15:09:47,290 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0013_01_000003 is : 143
2015-05-20 15:09:48,483 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-05-20 15:09:48,597 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432159467419_0014
2015-05-20 15:09:48,597 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0014/
2015-05-20 15:09:58,273 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0014_01_000008
2015-05-20 15:10:05,905 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0014_01_000002 is : 143
2015-05-20 15:10:06,339 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0014_01_000005 is : 143
2015-05-20 15:10:06,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0014_01_000003 is : 143
2015-05-20 15:10:06,478 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0014_01_000004 is : 143
2015-05-20 15:10:06,518 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0014_01_000006 is : 143
2015-05-20 15:10:07,761 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-05-20 15:10:07,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-05-20 15:10:07,826 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:10:07,827 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 15:10:07,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 15:10:07,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:10:07,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged"]
2015-05-20 15:10:07,839 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-05-20 15:10:07,840 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1
2015-05-20 15:10:07,840 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1
2015-05-20 15:10:07,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged
2015-05-20 15:10:07,966 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432159467419_0015
2015-05-20 15:10:07,967 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0015/
2015-05-20 15:10:23,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0015_01_000002 is : 143
2015-05-20 15:10:23,640 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0015_01_000004 is : 143
2015-05-20 15:10:23,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0015_01_000003 is : 143
2015-05-20 15:10:23,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0015_01_000005 is : 143
2015-05-20 15:10:25,152 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged/_temporary
2015-05-20 15:10:25,175 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemerged
2015-05-20 15:10:25,205 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:10:25,205 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 15:10:25,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-05-20 15:10:25,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:10:25,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:10:25,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:10:25,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]
2015-05-20 15:10:25,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-05-20 15:10:25,234 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 2
2015-05-20 15:10:25,234 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 2
2015-05-20 15:10:25,235 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)
2015-05-20 15:10:25,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432159467419_0016
2015-05-20 15:10:25,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0016/
2015-05-20 15:10:34,653 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0016_01_000010
2015-05-20 15:10:44,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0016_01_000002 is : 143
2015-05-20 15:10:44,639 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0016_01_000003 is : 143
2015-05-20 15:10:45,033 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0016_01_000006 is : 143
2015-05-20 15:10:45,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0016_01_000005 is : 143
2015-05-20 15:10:45,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0016_01_000004 is : 143
2015-05-20 15:10:45,400 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0016_01_000008 is : 143
2015-05-20 15:10:46,608 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed
2015-05-20 15:10:46,725 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432159467419_0017
2015-05-20 15:10:46,725 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0017/
2015-05-20 15:10:56,188 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0017_01_000009
2015-05-20 15:11:06,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0017_01_000002 is : 143
2015-05-20 15:11:06,506 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0017_01_000005 is : 143
2015-05-20 15:11:06,533 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0017_01_000006 is : 143
2015-05-20 15:11:06,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0017_01_000003 is : 143
2015-05-20 15:11:06,652 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0017_01_000007 is : 143
2015-05-20 15:11:06,806 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0017_01_000004 is : 143
2015-05-20 15:11:08,029 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary
2015-05-20 15:11:08,051 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed
2015-05-20 15:11:08,081 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:11:08,081 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 15:11:08,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergefail
2015-05-20 15:11:08,101 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:11:08,102 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 15:11:08,128 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-05-20 15:11:08,128 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:11:08,128 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:11:08,128 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:11:08,129 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup"]
2015-05-20 15:11:08,129 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-05-20 15:11:08,129 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 1
2015-05-20 15:11:08,129 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 1
2015-05-20 15:11:08,130 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-05-20 15:11:08,264 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432159467419_0018
2015-05-20 15:11:08,264 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0018/
2015-05-20 15:11:17,576 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0018_01_000012
2015-05-20 15:11:17,676 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0018_01_000013
2015-05-20 15:11:17,820 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0018_01_000014
2015-05-20 15:11:33,257 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000002 is : 143
2015-05-20 15:11:33,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000005 is : 143
2015-05-20 15:11:33,762 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000009 is : 143
2015-05-20 15:11:33,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000004 is : 143
2015-05-20 15:11:33,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000010 is : 143
2015-05-20 15:11:33,914 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000003 is : 143
2015-05-20 15:11:33,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000007 is : 143
2015-05-20 15:11:34,005 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000006 is : 143
2015-05-20 15:11:34,032 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000008 is : 143
2015-05-20 15:11:38,686 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0018_01_000015 is : 143
2015-05-20 15:11:39,875 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup/_temporary
2015-05-20 15:11:39,890 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup
2015-05-20 15:11:39,908 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:11:39,908 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 15:11:39,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-05-20 15:11:39,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:11:39,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:11:39,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:11:39,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-05-20 15:11:39,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  parallel execution is enabled: true
2015-05-20 15:11:39,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  starting jobs: 3
2015-05-20 15:11:39,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset]  allocating threads: 3
2015-05-20 15:11:39,959 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-05-20 15:11:40,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432159467419_0019
2015-05-20 15:11:40,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0019/
2015-05-20 15:11:49,978 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0019_01_000009
2015-05-20 15:11:50,048 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0019_01_000010
2015-05-20 15:11:59,582 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0019_01_000002 is : 143
2015-05-20 15:11:59,775 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0019_01_000003 is : 143
2015-05-20 15:12:00,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0019_01_000006 is : 143
2015-05-20 15:12:00,119 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0019_01_000005 is : 143
2015-05-20 15:12:00,202 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0019_01_000004 is : 143
2015-05-20 15:12:00,361 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0019_01_000007 is : 143
2015-05-20 15:12:01,587 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-05-20 15:12:01,717 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432159467419_0020
2015-05-20 15:12:01,717 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0020/
2015-05-20 15:12:19,118 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0020_01_000003 is : 143
2015-05-20 15:12:19,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0020_01_000002 is : 143
2015-05-20 15:12:19,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0020_01_000006 is : 143
2015-05-20 15:12:19,688 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0020_01_000004 is : 143
2015-05-20 15:12:19,753 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0020_01_000005 is : 143
2015-05-20 15:12:20,966 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge
2015-05-20 15:12:21,085 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1432159467419_0021
2015-05-20 15:12:21,085 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0021/
2015-05-20 15:12:38,041 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0021_01_000003 is : 143
2015-05-20 15:12:38,069 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0021_01_000002 is : 143
2015-05-20 15:12:38,353 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0021_01_000005 is : 143
2015-05-20 15:12:38,461 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0021_01_000006 is : 143
2015-05-20 15:12:38,527 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0021_01_000004 is : 143
2015-05-20 15:12:39,740 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-05-20 15:12:39,758 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-05-20 15:12:39,785 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:12:39,785 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 15:12:39,799 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-05-20 15:12:39,800 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:12:39,800 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:12:39,800 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:12:39,800 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed"]
2015-05-20 15:12:39,800 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-05-20 15:12:39,800 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1
2015-05-20 15:12:39,801 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1
2015-05-20 15:12:39,802 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-05-20 15:12:39,926 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432159467419_0022
2015-05-20 15:12:39,926 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0022/
2015-05-20 15:12:49,373 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0022_01_000010
2015-05-20 15:12:58,631 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0022_01_000002 is : 143
2015-05-20 15:12:58,799 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0022_01_000003 is : 143
2015-05-20 15:12:58,973 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0022_01_000006 is : 143
2015-05-20 15:12:59,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0022_01_000008 is : 143
2015-05-20 15:12:59,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0022_01_000005 is : 143
2015-05-20 15:12:59,318 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0022_01_000004 is : 143
2015-05-20 15:13:00,528 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed/_temporary
2015-05-20 15:13:00,549 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed
2015-05-20 15:13:00,586 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:13:00,586 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 15:13:00,601 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-05-20 15:13:00,601 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:13:00,601 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:13:00,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:13:00,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup"]
2015-05-20 15:13:00,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  parallel execution is enabled: true
2015-05-20 15:13:00,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  starting jobs: 1
2015-05-20 15:13:00,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset]  allocating threads: 1
2015-05-20 15:13:00,609 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-05-20 15:13:00,732 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1432159467419_0023
2015-05-20 15:13:00,732 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0023/
2015-05-20 15:13:10,177 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0023_01_000013
2015-05-20 15:13:10,340 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0023_01_000014
2015-05-20 15:13:10,997 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0023_01_000016
2015-05-20 15:13:25,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000003 is : 143
2015-05-20 15:13:25,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000002 is : 143
2015-05-20 15:13:25,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000004 is : 143
2015-05-20 15:13:25,769 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000005 is : 143
2015-05-20 15:13:25,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000006 is : 143
2015-05-20 15:13:26,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000010 is : 143
2015-05-20 15:13:26,074 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000008 is : 143
2015-05-20 15:13:26,167 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000009 is : 143
2015-05-20 15:13:26,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000012 is : 143
2015-05-20 15:13:30,728 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0023_01_000017 is : 143
2015-05-20 15:13:31,908 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup/_temporary
2015-05-20 15:13:31,921 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup
2015-05-20 15:13:31,938 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:13:31,938 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 15:13:31,967 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-05-20 15:13:31,967 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:13:31,968 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup"]
2015-05-20 15:13:31,968 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  parallel execution is enabled: true
2015-05-20 15:13:31,968 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  starting jobs: 2
2015-05-20 15:13:31,968 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset]  allocating threads: 2
2015-05-20 15:13:31,969 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)
2015-05-20 15:13:32,078 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432159467419_0024
2015-05-20 15:13:32,078 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0024/
2015-05-20 15:13:48,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0024_01_000002 is : 143
2015-05-20 15:13:49,025 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0024_01_000003 is : 143
2015-05-20 15:13:49,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0024_01_000004 is : 143
2015-05-20 15:13:49,121 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0024_01_000006 is : 143
2015-05-20 15:13:49,172 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0024_01_000005 is : 143
2015-05-20 15:13:54,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0024_01_000007 is : 143
2015-05-20 15:13:55,531 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup
2015-05-20 15:13:55,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1432159467419_0025
2015-05-20 15:13:55,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0025/
2015-05-20 15:14:05,067 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0025_01_000008
2015-05-20 15:14:05,163 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0025_01_000009
2015-05-20 15:14:16,815 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000005 is : 143
2015-05-20 15:14:16,997 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000004 is : 143
2015-05-20 15:14:17,125 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000003 is : 143
2015-05-20 15:14:17,141 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000002 is : 143
2015-05-20 15:14:17,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000007 is : 143
2015-05-20 15:14:17,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000006 is : 143
2015-05-20 15:14:22,397 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0025_01_000010 is : 143
2015-05-20 15:14:23,617 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup/_temporary
2015-05-20 15:14:23,634 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/samemergethreechaingroup
2015-05-20 15:14:23,652 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:14:23,652 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 15:14:23,698 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-05-20 15:14:23,698 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:14:23,698 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:14:23,698 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:14:23,699 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-05-20 15:14:23,699 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  parallel execution is enabled: true
2015-05-20 15:14:23,699 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  starting jobs: 3
2015-05-20 15:14:23,699 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset]  allocating threads: 3
2015-05-20 15:14:23,700 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-05-20 15:14:23,836 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432159467419_0026
2015-05-20 15:14:23,837 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0026/
2015-05-20 15:14:33,856 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0026_01_000008
2015-05-20 15:14:34,386 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0026_01_000010
2015-05-20 15:14:46,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0026_01_000003 is : 143
2015-05-20 15:14:46,618 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0026_01_000002 is : 143
2015-05-20 15:14:46,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0026_01_000007 is : 143
2015-05-20 15:14:47,160 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0026_01_000005 is : 143
2015-05-20 15:14:47,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0026_01_000006 is : 143
2015-05-20 15:14:47,368 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0026_01_000004 is : 143
2015-05-20 15:14:48,634 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-05-20 15:14:48,771 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432159467419_0027
2015-05-20 15:14:48,771 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0027/
2015-05-20 15:14:59,173 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0027_01_000009
2015-05-20 15:14:59,222 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0027_01_000010
2015-05-20 15:15:12,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0027_01_000002 is : 143
2015-05-20 15:15:12,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0027_01_000003 is : 143
2015-05-20 15:15:12,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0027_01_000007 is : 143
2015-05-20 15:15:13,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0027_01_000004 is : 143
2015-05-20 15:15:13,116 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0027_01_000006 is : 143
2015-05-20 15:15:13,278 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0027_01_000005 is : 143
2015-05-20 15:15:14,482 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-05-20 15:15:14,597 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1432159467419_0028
2015-05-20 15:15:14,597 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0028/
2015-05-20 15:15:24,071 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0028_01_000008
2015-05-20 15:15:35,242 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0028_01_000006 is : 143
2015-05-20 15:15:35,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0028_01_000005 is : 143
2015-05-20 15:15:35,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0028_01_000003 is : 143
2015-05-20 15:15:35,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0028_01_000007 is : 143
2015-05-20 15:15:35,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0028_01_000004 is : 143
2015-05-20 15:15:35,948 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0028_01_000002 is : 143
2015-05-20 15:15:37,188 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-05-20 15:15:37,209 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-05-20 15:15:37,242 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:15:37,242 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 15:15:37,264 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-05-20 15:15:37,264 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:15:37,264 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:15:37,265 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:15:37,265 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated"]
2015-05-20 15:15:37,265 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true
2015-05-20 15:15:37,265 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2
2015-05-20 15:15:37,265 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2
2015-05-20 15:15:37,268 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-05-20 15:15:37,429 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432159467419_0029
2015-05-20 15:15:37,429 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0029/
2015-05-20 15:15:47,260 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0029_01_000008
2015-05-20 15:15:47,910 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0029_01_000010
2015-05-20 15:15:59,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0029_01_000003 is : 143
2015-05-20 15:15:59,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0029_01_000006 is : 143
2015-05-20 15:15:59,349 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0029_01_000007 is : 143
2015-05-20 15:15:59,548 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0029_01_000002 is : 143
2015-05-20 15:15:59,768 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0029_01_000005 is : 143
2015-05-20 15:15:59,877 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0029_01_000004 is : 143
2015-05-20 15:16:01,128 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-05-20 15:16:01,247 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432159467419_0030
2015-05-20 15:16:01,247 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0030/
2015-05-20 15:16:10,790 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0030_01_000007
2015-05-20 15:16:21,705 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0030_01_000004 is : 143
2015-05-20 15:16:22,290 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0030_01_000003 is : 143
2015-05-20 15:16:22,389 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0030_01_000002 is : 143
2015-05-20 15:16:22,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0030_01_000006 is : 143
2015-05-20 15:16:22,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0030_01_000005 is : 143
2015-05-20 15:16:24,293 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated/_temporary
2015-05-20 15:16:24,342 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated
2015-05-20 15:16:24,421 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:16:24,423 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 15:16:24,452 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 15:16:24,452 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:16:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex"]
2015-05-20 15:16:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-05-20 15:16:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 1
2015-05-20 15:16:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 1
2015-05-20 15:16:24,454 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex
2015-05-20 15:16:24,644 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432159467419_0031
2015-05-20 15:16:24,644 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0031/
2015-05-20 15:16:48,773 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0031_01_000003 is : 143
2015-05-20 15:16:48,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0031_01_000005 is : 143
2015-05-20 15:16:48,897 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0031_01_000004 is : 143
2015-05-20 15:16:49,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0031_01_000002 is : 143
2015-05-20 15:16:50,443 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex/_temporary
2015-05-20 15:16:50,470 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex
2015-05-20 15:16:50,509 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:16:50,510 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 15:16:50,551 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-05-20 15:16:50,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:16:50,552 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:16:50,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:16:50,553 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]
2015-05-20 15:16:50,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  parallel execution is enabled: true
2015-05-20 15:16:50,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  starting jobs: 2
2015-05-20 15:16:50,554 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge]  allocating threads: 2
2015-05-20 15:16:50,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-05-20 15:16:50,762 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432159467419_0032
2015-05-20 15:16:50,763 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0032/
2015-05-20 15:17:00,250 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0032_01_000008
2015-05-20 15:17:00,796 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0032_01_000009
2015-05-20 15:17:13,621 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0032_01_000002 is : 143
2015-05-20 15:17:14,179 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0032_01_000004 is : 143
2015-05-20 15:17:14,353 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0032_01_000006 is : 143
2015-05-20 15:17:14,546 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0032_01_000003 is : 143
2015-05-20 15:17:14,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0032_01_000007 is : 143
2015-05-20 15:17:14,670 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0032_01_000005 is : 143
2015-05-20 15:17:15,960 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-05-20 15:17:16,094 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1432159467419_0033
2015-05-20 15:17:16,094 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0033/
2015-05-20 15:17:25,637 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0033_01_000007
2015-05-20 15:17:35,477 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0033_01_000004 is : 143
2015-05-20 15:17:35,865 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0033_01_000003 is : 143
2015-05-20 15:17:35,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0033_01_000006 is : 143
2015-05-20 15:17:35,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0033_01_000005 is : 143
2015-05-20 15:17:36,143 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0033_01_000002 is : 143
2015-05-20 15:17:37,337 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-05-20 15:17:37,357 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated
2015-05-20 15:17:37,383 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:17:37,384 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 15:17:37,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting
2015-05-20 15:17:37,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:17:37,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:17:37,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:17:37,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-05-20 15:17:37,415 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  parallel execution is enabled: true
2015-05-20 15:17:37,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  starting jobs: 3
2015-05-20 15:17:37,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1]  allocating threads: 3
2015-05-20 15:17:37,417 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)
2015-05-20 15:17:37,496 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-05-20 15:17:37,545 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1432159467419_0034
2015-05-20 15:17:37,545 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0034/
2015-05-20 15:17:49,519 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0034_01_000008
2015-05-20 15:17:50,019 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0034_01_000010
2015-05-20 15:18:01,721 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0034_01_000003 is : 143
2015-05-20 15:18:02,206 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0034_01_000002 is : 143
2015-05-20 15:18:02,367 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0034_01_000007 is : 143
2015-05-20 15:18:02,499 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0034_01_000004 is : 143
2015-05-20 15:18:02,539 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0034_01_000006 is : 143
2015-05-20 15:18:02,695 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0034_01_000005 is : 143
2015-05-20 15:18:03,924 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)
2015-05-20 15:18:04,033 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1432159467419_0035
2015-05-20 15:18:04,033 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0035/
2015-05-20 15:18:21,296 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0035_01_000002 is : 143
2015-05-20 15:18:21,472 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0035_01_000003 is : 143
2015-05-20 15:18:21,657 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0035_01_000005 is : 143
2015-05-20 15:18:21,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0035_01_000004 is : 143
2015-05-20 15:18:21,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0035_01_000006 is : 143
2015-05-20 15:18:23,063 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-05-20 15:18:23,175 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1432159467419_0036
2015-05-20 15:18:23,175 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0036/
2015-05-20 15:18:40,469 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0036_01_000002 is : 143
2015-05-20 15:18:40,612 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0036_01_000003 is : 143
2015-05-20 15:18:40,757 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0036_01_000006 is : 143
2015-05-20 15:18:40,826 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0036_01_000004 is : 143
2015-05-20 15:18:40,998 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0036_01_000005 is : 143
2015-05-20 15:18:42,191 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-05-20 15:18:42,216 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-05-20 15:18:42,241 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:18:42,241 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 15:18:42,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-05-20 15:18:42,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 15:18:42,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 15:18:42,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 15:18:42,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-05-20 15:18:42,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  parallel execution is enabled: true
2015-05-20 15:18:42,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  starting jobs: 3
2015-05-20 15:18:42,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2]  allocating threads: 3
2015-05-20 15:18:42,282 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-05-20 15:18:42,390 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432159467419_0037
2015-05-20 15:18:42,390 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0037/
2015-05-20 15:18:51,782 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0037_01_000010
2015-05-20 15:19:01,508 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0037_01_000002 is : 143
2015-05-20 15:19:01,593 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0037_01_000003 is : 143
2015-05-20 15:19:01,928 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0037_01_000006 is : 143
2015-05-20 15:19:02,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0037_01_000005 is : 143
2015-05-20 15:19:02,171 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0037_01_000008 is : 143
2015-05-20 15:19:02,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0037_01_000004 is : 143
2015-05-20 15:19:03,424 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-05-20 15:19:03,536 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432159467419_0038
2015-05-20 15:19:03,536 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0038/
2015-05-20 15:19:13,127 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0038_01_000013
2015-05-20 15:19:13,225 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0038_01_000014
2015-05-20 15:19:13,945 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432159467419_0038_01_000016
2015-05-20 15:19:28,679 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000002 is : 143
2015-05-20 15:19:28,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000003 is : 143
2015-05-20 15:19:29,172 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000010 is : 143
2015-05-20 15:19:29,215 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000009 is : 143
2015-05-20 15:19:29,595 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000005 is : 143
2015-05-20 15:19:29,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000008 is : 143
2015-05-20 15:19:29,686 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000004 is : 143
2015-05-20 15:19:29,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000006 is : 143
2015-05-20 15:19:29,936 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0038_01_000012 is : 143
2015-05-20 15:19:31,155 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-05-20 15:19:31,264 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1432159467419_0039
2015-05-20 15:19:31,264 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Edinburgh.local:53433/proxy/application_1432159467419_0039/
2015-05-20 15:19:48,691 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0039_01_000002 is : 143
2015-05-20 15:19:48,914 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0039_01_000004 is : 143
2015-05-20 15:19:48,984 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0039_01_000006 is : 143
2015-05-20 15:19:49,202 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0039_01_000005 is : 143
2015-05-20 15:19:49,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432159467419_0039_01_000003 is : 143
2015-05-20 15:19:50,429 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-05-20 15:19:50,449 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge

Standard error

May 20, 2015 3:04:27 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
May 20, 2015 3:04:27 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
May 20, 2015 3:04:27 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:04:27 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 3:04:27 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 3:04:27 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 3:04:28 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
May 20, 2015 3:04:28 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 3:04:29 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 3:04:29 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 3:04:29 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:04:29 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 3:04:29 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 3:04:29 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 3:04:29 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 3:04:29 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 3:04:30 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 3:04:30 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:04:30 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 3:04:30 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 3:04:30 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 3:04:30 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 3:04:30 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 3:04:30 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 3:04:31 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 3:04:31 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:04:31 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 3:04:31 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 3:04:31 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 3:04:31 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 3:04:31 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 3:04:31 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 3:04:32 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 3:04:32 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:04:32 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 3:04:32 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 3:04:32 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 3:04:32 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 3:04:32 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 3:04:32 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.