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