Class cascading.JoinFieldedPipesPlatformTest

32

tests

0

failures

0

ignored

13m51.26s

duration

100%

successful

Tests

Test Duration Result
testCross 15.119s passed
testJoin 16.772s passed
testJoinAfterEvery 48.308s passed
testJoinAroundJoinLeftMost 34.155s passed
testJoinAroundJoinRightMost 16.387s passed
testJoinAroundJoinRightMostSwapped 47.029s passed
testJoinDiffFields 17.297s passed
testJoinFilteredBranch 1m3.61s passed
testJoinGroupBy 22.739s passed
testJoinGroupByJoin 31.512s passed
testJoinInner 17.890s passed
testJoinInnerOuter 17.186s passed
testJoinInnerSingleField 29.140s passed
testJoinMergeGroupBy 41.632s passed
testJoinMixed 0s passed
testJoinNone 17.008s passed
testJoinOuter 0s passed
testJoinOuterInner 0s passed
testJoinSamePipe 17.542s passed
testJoinSamePipe2 17.526s passed
testJoinSamePipe3 17.148s passed
testJoinSamePipeAroundGroupBy 40.290s passed
testJoinSamePipeName 16.872s passed
testJoinSameSourceIntoJoin 1m9.78s passed
testJoinSelf 34.351s passed
testJoinWithHasher 17.877s passed
testJoinWithUnknowns 17.064s passed
testJoinsIntoCoGroup 25.356s passed
testJoinsIntoCoGroupLhs 38.833s passed
testJoinsIntoCoGroupLhsSwappedJoin 21.843s passed
testJoinsIntoCoGroupRhs 38.058s passed
testJoinsIntoGroupBy 22.933s passed

Standard output

2015-05-20 19:22:13,096 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 19:22:13,128 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 19:22:13,128 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.JoinFieldedPipesPlatformTest
2015-05-20 19:22:13,147 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 19:22:13,725 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:22:14,180 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 19:22:18,454 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:22:19,614 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:22:20,746 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:22:21,891 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:22:24,516 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:22:24,517 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:22:24,523 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 2D8108D3C2564303B416B0EACD6451B6
2015-05-20 19:22:24,620 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 19:22:24,621 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:22:24,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:22:24,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower-offset.txt"]
2015-05-20 19:22:24,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle"]
2015-05-20 19:22:24,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:22:24,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:22:24,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:22:24,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...splatform/joininnersingle
2015-05-20 19:22:25,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0001
2015-05-20 19:22:25,126 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0001/
2015-05-20 19:22:40,589 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0001_01_000004 is : 143
2015-05-20 19:22:40,592 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0001_01_000006 is : 143
2015-05-20 19:22:40,688 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0001_01_000005 is : 143
2015-05-20 19:22:40,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0001_01_000003 is : 143
2015-05-20 19:22:40,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0001_01_000002 is : 143
2015-05-20 19:22:42,194 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle/_temporary
2015-05-20 19:22:42,261 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnersingle
2015-05-20 19:22:42,344 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:22:42,344 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:22:42,400 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting
2015-05-20 19:22:42,401 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:22:42,401 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:22:42,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:22:42,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost"]
2015-05-20 19:22:42,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  parallel execution is enabled: true
2015-05-20 19:22:42,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  starting jobs: 2
2015-05-20 19:22:42,402 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  allocating threads: 2
2015-05-20 19:22:42,404 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (2/2)
2015-05-20 19:22:42,582 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1432174936628_0002
2015-05-20 19:22:42,583 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0002/
2015-05-20 19:22:57,941 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0002_01_000002 is : 143
2015-05-20 19:22:58,049 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0002_01_000004 is : 143
2015-05-20 19:22:58,065 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0002_01_000006 is : 143
2015-05-20 19:22:58,230 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0002_01_000003 is : 143
2015-05-20 19:22:58,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0002_01_000005 is : 143
2015-05-20 19:22:59,477 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (1/2) ...rm/joinaroundjoinleftmost
2015-05-20 19:22:59,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1432174936628_0003
2015-05-20 19:22:59,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0003/
2015-05-20 19:23:14,780 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0003_01_000002 is : 143
2015-05-20 19:23:14,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0003_01_000003 is : 143
2015-05-20 19:23:15,041 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0003_01_000006 is : 143
2015-05-20 19:23:15,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0003_01_000005 is : 143
2015-05-20 19:23:15,180 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0003_01_000004 is : 143
2015-05-20 19:23:16,383 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost/_temporary
2015-05-20 19:23:16,429 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost
2015-05-20 19:23:16,458 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:23:16,458 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:23:16,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting
2015-05-20 19:23:16,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:23:16,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:23:16,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes"]
2015-05-20 19:23:16,479 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  parallel execution is enabled: true
2015-05-20 19:23:16,480 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  starting jobs: 1
2015-05-20 19:23:16,480 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  allocating threads: 1
2015-05-20 19:23:16,480 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] starting step: (1/1) ...ipesplatform/renamedpipes
2015-05-20 19:23:16,604 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] submitted hadoop job: job_1432174936628_0004
2015-05-20 19:23:16,605 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0004/
2015-05-20 19:23:31,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0004_01_000002 is : 143
2015-05-20 19:23:31,787 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0004_01_000003 is : 143
2015-05-20 19:23:31,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0004_01_000005 is : 143
2015-05-20 19:23:32,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0004_01_000004 is : 143
2015-05-20 19:23:32,040 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0004_01_000006 is : 143
2015-05-20 19:23:33,249 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes/_temporary
2015-05-20 19:23:33,295 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/renamedpipes
2015-05-20 19:23:33,344 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:23:33,345 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:23:33,382 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:23:33,383 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:23:33,383 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:23:33,383 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery"]
2015-05-20 19:23:33,383 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:23:33,383 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-05-20 19:23:33,383 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-05-20 19:23:33,385 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-05-20 19:23:33,385 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-05-20 19:23:33,571 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0005
2015-05-20 19:23:33,571 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0005/
2015-05-20 19:23:33,571 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0006
2015-05-20 19:23:33,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0006/
2015-05-20 19:23:50,532 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0006_01_000006 is : 143
2015-05-20 19:23:50,970 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0006_01_000005 is : 143
2015-05-20 19:23:50,997 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0006_01_000003 is : 143
2015-05-20 19:23:51,117 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0006_01_000004 is : 143
2015-05-20 19:23:51,177 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0006_01_000002 is : 143
2015-05-20 19:24:04,706 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0006_01_000007 is : 143
2015-05-20 19:24:05,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0005_01_000002 is : 143
2015-05-20 19:24:05,376 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0005_01_000003 is : 143
2015-05-20 19:24:05,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0005_01_000004 is : 143
2015-05-20 19:24:05,460 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0005_01_000006 is : 143
2015-05-20 19:24:05,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0005_01_000005 is : 143
2015-05-20 19:24:10,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0005_01_000007 is : 143
2015-05-20 19:24:11,760 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...dpipesplatform/afterevery
2015-05-20 19:24:11,883 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0007
2015-05-20 19:24:11,884 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0007/
2015-05-20 19:24:20,413 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0007_01_000002 is : 143
2015-05-20 19:24:21,592 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery/_temporary
2015-05-20 19:24:21,619 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/afterevery
2015-05-20 19:24:21,662 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:24:21,663 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:24:21,693 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-05-20 19:24:21,693 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:24:21,693 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:24:21,693 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs.txt"]
2015-05-20 19:24:21,694 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs.txt"]
2015-05-20 19:24:21,694 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin"]
2015-05-20 19:24:21,694 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-05-20 19:24:21,694 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 1
2015-05-20 19:24:21,694 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 1
2015-05-20 19:24:21,695 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-05-20 19:24:21,801 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1432174936628_0008
2015-05-20 19:24:21,801 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0008/
2015-05-20 19:24:37,300 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0008_01_000005 is : 143
2015-05-20 19:24:37,362 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0008_01_000002 is : 143
2015-05-20 19:24:37,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0008_01_000003 is : 143
2015-05-20 19:24:37,434 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0008_01_000006 is : 143
2015-05-20 19:24:37,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0008_01_000004 is : 143
2015-05-20 19:24:42,283 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0008_01_000007 is : 143
2015-05-20 19:24:43,436 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin/_temporary
2015-05-20 19:24:43,463 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin
2015-05-20 19:24:43,482 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:24:43,483 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:24:43,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs.txt"]
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs.txt"]
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs"]
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-05-20 19:24:43,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 2
2015-05-20 19:24:43,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 2
2015-05-20 19:24:43,517 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-05-20 19:24:43,638 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1432174936628_0009
2015-05-20 19:24:43,639 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0009/
2015-05-20 19:24:58,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0009_01_000005 is : 143
2015-05-20 19:24:59,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0009_01_000003 is : 143
2015-05-20 19:24:59,162 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0009_01_000006 is : 143
2015-05-20 19:24:59,238 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0009_01_000002 is : 143
2015-05-20 19:24:59,281 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0009_01_000004 is : 143
2015-05-20 19:25:00,471 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouplhs
2015-05-20 19:25:00,591 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1432174936628_0010
2015-05-20 19:25:00,591 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0010/
2015-05-20 19:25:15,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0010_01_000006 is : 143
2015-05-20 19:25:16,196 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0010_01_000005 is : 143
2015-05-20 19:25:16,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0010_01_000004 is : 143
2015-05-20 19:25:16,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0010_01_000002 is : 143
2015-05-20 19:25:16,380 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0010_01_000003 is : 143
2015-05-20 19:25:21,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0010_01_000007 is : 143
2015-05-20 19:25:22,270 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs/_temporary
2015-05-20 19:25:22,296 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs
2015-05-20 19:25:22,315 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:25:22,316 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:25:22,341 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-05-20 19:25:22,341 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:25:22,341 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:25:22,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs.txt"]
2015-05-20 19:25:22,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs.txt"]
2015-05-20 19:25:22,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs"]
2015-05-20 19:25:22,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-05-20 19:25:22,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 2
2015-05-20 19:25:22,342 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 2
2015-05-20 19:25:22,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-05-20 19:25:22,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1432174936628_0011
2015-05-20 19:25:22,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0011/
2015-05-20 19:25:38,046 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0011_01_000004 is : 143
2015-05-20 19:25:38,121 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0011_01_000006 is : 143
2015-05-20 19:25:38,213 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0011_01_000002 is : 143
2015-05-20 19:25:38,240 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0011_01_000005 is : 143
2015-05-20 19:25:38,313 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0011_01_000003 is : 143
2015-05-20 19:25:39,498 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouprhs
2015-05-20 19:25:39,602 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1432174936628_0012
2015-05-20 19:25:39,603 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0012/
2015-05-20 19:25:54,375 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0012_01_000006 is : 143
2015-05-20 19:25:54,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0012_01_000005 is : 143
2015-05-20 19:25:54,589 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0012_01_000004 is : 143
2015-05-20 19:25:54,732 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0012_01_000002 is : 143
2015-05-20 19:25:54,763 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0012_01_000003 is : 143
2015-05-20 19:25:59,146 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0012_01_000007 is : 143
2015-05-20 19:26:00,321 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs/_temporary
2015-05-20 19:26:00,354 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs
2015-05-20 19:26:00,430 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:26:00,430 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:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher"]
2015-05-20 19:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:26:00,445 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:26:00,446 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/joinhasher
2015-05-20 19:26:00,547 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0013
2015-05-20 19:26:00,547 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0013/
2015-05-20 19:26:16,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0013_01_000003 is : 143
2015-05-20 19:26:16,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0013_01_000004 is : 143
2015-05-20 19:26:16,777 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0013_01_000006 is : 143
2015-05-20 19:26:16,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0013_01_000002 is : 143
2015-05-20 19:26:16,979 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0013_01_000005 is : 143
2015-05-20 19:26:18,188 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher/_temporary
2015-05-20 19:26:18,224 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinhasher
2015-05-20 19:26:18,261 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:26:18,261 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:26:18,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting
2015-05-20 19:26:18,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:26:18,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower+upper.txt"]
2015-05-20 19:26:18,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:26:18,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin"]
2015-05-20 19:26:18,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  parallel execution is enabled: true
2015-05-20 19:26:18,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  starting jobs: 2
2015-05-20 19:26:18,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  allocating threads: 2
2015-05-20 19:26:18,289 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (2/2)
2015-05-20 19:26:18,408 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1432174936628_0014
2015-05-20 19:26:18,408 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0014/
2015-05-20 19:26:33,162 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0014_01_000003 is : 143
2015-05-20 19:26:33,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0014_01_000006 is : 143
2015-05-20 19:26:33,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0014_01_000004 is : 143
2015-05-20 19:26:33,288 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0014_01_000002 is : 143
2015-05-20 19:26:33,310 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0014_01_000005 is : 143
2015-05-20 19:26:38,318 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0014_01_000007 is : 143
2015-05-20 19:26:39,476 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (1/2) ...splatform/joingroupbyjoin
2015-05-20 19:26:39,576 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1432174936628_0015
2015-05-20 19:26:39,576 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0015/
2015-05-20 19:26:48,522 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0015_01_000002 is : 143
2015-05-20 19:26:49,719 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin/_temporary
2015-05-20 19:26:49,743 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin
2015-05-20 19:26:49,758 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:26:49,759 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:26:49,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-05-20 19:26:49,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs.txt"]
2015-05-20 19:26:49,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs.txt"]
2015-05-20 19:26:49,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross"]
2015-05-20 19:26:49,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-05-20 19:26:49,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 1
2015-05-20 19:26:49,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 1
2015-05-20 19:26:49,770 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...ieldedpipesplatform/cross
2015-05-20 19:26:49,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1432174936628_0016
2015-05-20 19:26:49,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0016/
2015-05-20 19:27:03,331 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0016_01_000005 is : 143
2015-05-20 19:27:03,424 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0016_01_000002 is : 143
2015-05-20 19:27:03,524 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0016_01_000004 is : 143
2015-05-20 19:27:03,621 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0016_01_000003 is : 143
2015-05-20 19:27:04,818 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross/_temporary
2015-05-20 19:27:04,857 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/cross
2015-05-20 19:27:04,882 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:27:04,883 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:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join"]
2015-05-20 19:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:27:04,895 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:27:04,896 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...fieldedpipesplatform/join
2015-05-20 19:27:04,994 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0017
2015-05-20 19:27:04,994 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0017/
2015-05-20 19:27:20,203 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0017_01_000005 is : 143
2015-05-20 19:27:20,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0017_01_000006 is : 143
2015-05-20 19:27:20,232 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0017_01_000004 is : 143
2015-05-20 19:27:20,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0017_01_000003 is : 143
2015-05-20 19:27:20,407 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0017_01_000002 is : 143
2015-05-20 19:27:21,592 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join/_temporary
2015-05-20 19:27:21,629 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/join
2015-05-20 19:27:21,653 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:27:21,653 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:27:21,669 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting
2015-05-20 19:27:21,669 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs.txt"]
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs.txt"]
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby"]
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  parallel execution is enabled: true
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  starting jobs: 1
2015-05-20 19:27:21,670 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  allocating threads: 1
2015-05-20 19:27:21,671 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] starting step: (1/1) ...platform/joinsintogroupby
2015-05-20 19:27:21,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] submitted hadoop job: job_1432174936628_0018
2015-05-20 19:27:21,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0018/
2015-05-20 19:27:38,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000006 is : 143
2015-05-20 19:27:38,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000007 is : 143
2015-05-20 19:27:38,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000004 is : 143
2015-05-20 19:27:38,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000002 is : 143
2015-05-20 19:27:38,780 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000005 is : 143
2015-05-20 19:27:38,817 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000003 is : 143
2015-05-20 19:27:43,331 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0018_01_000008 is : 143
2015-05-20 19:27:44,533 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby/_temporary
2015-05-20 19:27:44,567 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby
2015-05-20 19:27:44,587 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:27:44,587 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:27:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:27:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:27:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:27:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown"]
2015-05-20 19:27:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:27:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:27:44,599 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:27:44,600 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ldedpipesplatform/unknown
2015-05-20 19:27:44,697 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0019
2015-05-20 19:27:44,697 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0019/
2015-05-20 19:28:00,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0019_01_000003 is : 143
2015-05-20 19:28:00,183 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0019_01_000005 is : 143
2015-05-20 19:28:00,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0019_01_000002 is : 143
2015-05-20 19:28:00,274 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0019_01_000006 is : 143
2015-05-20 19:28:00,364 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0019_01_000004 is : 143
2015-05-20 19:28:01,590 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown/_temporary
2015-05-20 19:28:01,627 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/unknown
2015-05-20 19:28:01,647 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:28:01,647 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:28:01,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost"]
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  parallel execution is enabled: true
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  starting jobs: 1
2015-05-20 19:28:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  allocating threads: 1
2015-05-20 19:28:01,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/1) ...m/joinaroundjoinrightmost
2015-05-20 19:28:01,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1432174936628_0020
2015-05-20 19:28:01,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0020/
2015-05-20 19:28:16,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0020_01_000002 is : 143
2015-05-20 19:28:16,620 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0020_01_000004 is : 143
2015-05-20 19:28:16,647 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0020_01_000006 is : 143
2015-05-20 19:28:16,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0020_01_000003 is : 143
2015-05-20 19:28:16,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0020_01_000005 is : 143
2015-05-20 19:28:17,977 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost/_temporary
2015-05-20 19:28:18,013 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost
2015-05-20 19:28:18,036 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:28:18,036 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:28:18,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:28:18,046 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:28:18,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:28:18,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone"]
2015-05-20 19:28:18,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:28:18,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:28:18,047 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:28:18,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dedpipesplatform/joinnone
2015-05-20 19:28:18,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0021
2015-05-20 19:28:18,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0021/
2015-05-20 19:28:33,322 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0021_01_000005 is : 143
2015-05-20 19:28:33,384 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0021_01_000006 is : 143
2015-05-20 19:28:33,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0021_01_000004 is : 143
2015-05-20 19:28:33,631 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0021_01_000003 is : 143
2015-05-20 19:28:33,787 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0021_01_000002 is : 143
2015-05-20 19:28:34,985 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone/_temporary
2015-05-20 19:28:35,022 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinnone
2015-05-20 19:28:35,042 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:28:35,043 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:28:35,066 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:28:35,066 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:28:35,066 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:28:35,066 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself"]
2015-05-20 19:28:35,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:28:35,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-05-20 19:28:35,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-05-20 19:28:35,068 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-05-20 19:28:35,159 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0022
2015-05-20 19:28:35,160 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0022/
2015-05-20 19:28:36,233 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:28:50,134 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0022_01_000004 is : 143
2015-05-20 19:28:50,250 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0022_01_000003 is : 143
2015-05-20 19:28:50,365 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0022_01_000002 is : 143
2015-05-20 19:28:50,445 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0022_01_000006 is : 143
2015-05-20 19:28:50,587 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0022_01_000005 is : 143
2015-05-20 19:28:51,772 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...dedpipesplatform/joinself
2015-05-20 19:28:51,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0023
2015-05-20 19:28:51,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0023/
2015-05-20 19:29:07,695 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0023_01_000003 is : 143
2015-05-20 19:29:07,776 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0023_01_000002 is : 143
2015-05-20 19:29:08,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0023_01_000005 is : 143
2015-05-20 19:29:08,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0023_01_000006 is : 143
2015-05-20 19:29:08,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0023_01_000004 is : 143
2015-05-20 19:29:09,335 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself/_temporary
2015-05-20 19:29:09,374 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinself
2015-05-20 19:29:09,395 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:29:09,396 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:29:09,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting
2015-05-20 19:29:09,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:29:09,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:29:09,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:29:09,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped"]
2015-05-20 19:29:09,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  parallel execution is enabled: true
2015-05-20 19:29:09,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  starting jobs: 2
2015-05-20 19:29:09,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  allocating threads: 2
2015-05-20 19:29:09,418 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (2/2)
2015-05-20 19:29:09,516 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1432174936628_0024
2015-05-20 19:29:09,516 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0024/
2015-05-20 19:29:26,330 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0024_01_000003 is : 143
2015-05-20 19:29:26,527 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0024_01_000002 is : 143
2015-05-20 19:29:26,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0024_01_000005 is : 143
2015-05-20 19:29:26,720 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0024_01_000006 is : 143
2015-05-20 19:29:26,796 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0024_01_000004 is : 143
2015-05-20 19:29:28,004 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (1/2) ...orm/joinaroundjoinswapped
2015-05-20 19:29:28,172 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1432174936628_0025
2015-05-20 19:29:28,173 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0025/
2015-05-20 19:29:54,365 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0025_01_000006 is : 143
2015-05-20 19:29:54,618 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0025_01_000005 is : 143
2015-05-20 19:29:54,802 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0025_01_000004 is : 143
2015-05-20 19:29:54,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0025_01_000002 is : 143
2015-05-20 19:29:55,025 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0025_01_000003 is : 143
2015-05-20 19:29:56,307 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped/_temporary
2015-05-20 19:29:56,400 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped
2015-05-20 19:29:56,438 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:29:56,439 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:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch"]
2015-05-20 19:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-05-20 19:29:56,478 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-05-20 19:29:56,480 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-05-20 19:29:56,684 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0026
2015-05-20 19:29:56,684 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0026/
2015-05-20 19:30:21,639 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0026_01_000006 is : 143
2015-05-20 19:30:21,908 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0026_01_000005 is : 143
2015-05-20 19:30:21,950 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0026_01_000002 is : 143
2015-05-20 19:30:22,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0026_01_000004 is : 143
2015-05-20 19:30:22,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0026_01_000003 is : 143
2015-05-20 19:30:31,454 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0026_01_000007 is : 143
2015-05-20 19:30:32,758 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...atform/joinfilteredbranch
2015-05-20 19:30:32,960 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0027
2015-05-20 19:30:32,961 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0027/
2015-05-20 19:30:57,764 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0027_01_000003 is : 143
2015-05-20 19:30:58,126 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0027_01_000002 is : 143
2015-05-20 19:30:58,334 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0027_01_000006 is : 143
2015-05-20 19:30:58,519 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0027_01_000004 is : 143
2015-05-20 19:30:58,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0027_01_000005 is : 143
2015-05-20 19:30:59,872 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch/_temporary
2015-05-20 19:30:59,998 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch
2015-05-20 19:31:00,070 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:31:00,070 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:31:00,131 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-05-20 19:31:00,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:31:00,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:31:00,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:31:00,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin"]
2015-05-20 19:31:00,133 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  parallel execution is enabled: true
2015-05-20 19:31:00,133 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  starting jobs: 3
2015-05-20 19:31:00,133 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  allocating threads: 3
2015-05-20 19:31:00,134 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (3/3)
2015-05-20 19:31:00,244 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1432174936628_0028
2015-05-20 19:31:00,244 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0028/
2015-05-20 19:31:20,125 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0028_01_000006 is : 143
2015-05-20 19:31:20,332 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0028_01_000005 is : 143
2015-05-20 19:31:20,409 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0028_01_000002 is : 143
2015-05-20 19:31:20,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0028_01_000003 is : 143
2015-05-20 19:31:20,559 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0028_01_000004 is : 143
2015-05-20 19:31:21,993 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (2/3)
2015-05-20 19:31:22,306 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1432174936628_0029
2015-05-20 19:31:22,306 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0029/
2015-05-20 19:31:44,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0029_01_000006 is : 143
2015-05-20 19:31:44,607 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0029_01_000004 is : 143
2015-05-20 19:31:44,686 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0029_01_000003 is : 143
2015-05-20 19:31:44,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0029_01_000005 is : 143
2015-05-20 19:31:44,877 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0029_01_000002 is : 143
2015-05-20 19:31:46,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/3) ...rm/joinsamesourceintojoin
2015-05-20 19:31:46,265 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1432174936628_0030
2015-05-20 19:31:46,265 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0030/
2015-05-20 19:32:08,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0030_01_000003 is : 143
2015-05-20 19:32:08,302 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0030_01_000006 is : 143
2015-05-20 19:32:08,303 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0030_01_000002 is : 143
2015-05-20 19:32:08,363 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0030_01_000004 is : 143
2015-05-20 19:32:08,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0030_01_000005 is : 143
2015-05-20 19:32:09,654 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin/_temporary
2015-05-20 19:32:09,776 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin
2015-05-20 19:32:09,860 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:32:09,861 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:32:09,896 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-05-20 19:32:09,896 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs.txt"]
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs.txt"]
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup"]
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 1
2015-05-20 19:32:09,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 1
2015-05-20 19:32:09,899 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...platform/joinsintocogroup
2015-05-20 19:32:10,011 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1432174936628_0031
2015-05-20 19:32:10,012 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0031/
2015-05-20 19:32:28,803 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000005 is : 143
2015-05-20 19:32:28,847 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000002 is : 143
2015-05-20 19:32:28,873 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000004 is : 143
2015-05-20 19:32:28,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000003 is : 143
2015-05-20 19:32:29,057 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000007 is : 143
2015-05-20 19:32:29,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000006 is : 143
2015-05-20 19:32:33,973 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0031_01_000008 is : 143
2015-05-20 19:32:35,134 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup/_temporary
2015-05-20 19:32:35,157 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup
2015-05-20 19:32:35,195 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:32:35,196 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:32:35,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:32:35,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs-sparse.txt"]
2015-05-20 19:32:35,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs-sparse.txt"]
2015-05-20 19:32:35,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner"]
2015-05-20 19:32:35,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:32:35,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:32:35,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:32:35,219 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...edpipesplatform/joininner
2015-05-20 19:32:35,321 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0032
2015-05-20 19:32:35,321 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0032/
2015-05-20 19:32:51,432 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0032_01_000002 is : 143
2015-05-20 19:32:51,639 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0032_01_000003 is : 143
2015-05-20 19:32:51,711 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0032_01_000006 is : 143
2015-05-20 19:32:51,802 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0032_01_000005 is : 143
2015-05-20 19:32:51,839 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0032_01_000004 is : 143
2015-05-20 19:32:53,004 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner/_temporary
2015-05-20 19:32:53,041 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininner
2015-05-20 19:32:53,062 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:32:53,062 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:32:53,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-05-20 19:32:53,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:32:53,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby"]
2015-05-20 19:32:53,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-05-20 19:32:53,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 2
2015-05-20 19:32:53,079 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 2
2015-05-20 19:32:53,081 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (2/2)
2015-05-20 19:32:53,174 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1432174936628_0033
2015-05-20 19:32:53,175 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0033/
2015-05-20 19:33:09,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0033_01_000003 is : 143
2015-05-20 19:33:09,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0033_01_000004 is : 143
2015-05-20 19:33:09,151 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0033_01_000002 is : 143
2015-05-20 19:33:09,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0033_01_000006 is : 143
2015-05-20 19:33:09,256 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0033_01_000005 is : 143
2015-05-20 19:33:14,396 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0033_01_000007 is : 143
2015-05-20 19:33:15,542 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/2) ...orm/samepipearoundgroupby
2015-05-20 19:33:15,642 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1432174936628_0034
2015-05-20 19:33:15,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0034/
2015-05-20 19:33:31,677 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0034_01_000002 is : 143
2015-05-20 19:33:31,790 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0034_01_000003 is : 143
2015-05-20 19:33:31,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0034_01_000006 is : 143
2015-05-20 19:33:32,072 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0034_01_000005 is : 143
2015-05-20 19:33:32,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0034_01_000004 is : 143
2015-05-20 19:33:33,291 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby/_temporary
2015-05-20 19:33:33,332 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby
2015-05-20 19:33:33,394 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:33:33,394 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:33:33,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-05-20 19:33:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextLine[['id2']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/nums.20.txt"]
2015-05-20 19:33:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextLine[['id']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/nums.10.txt"]
2015-05-20 19:33:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  sink: Hfs["TextDelimited[['id2', 'count']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin"]
2015-05-20 19:33:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  parallel execution is enabled: true
2015-05-20 19:33:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  starting jobs: 2
2015-05-20 19:33:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  allocating threads: 2
2015-05-20 19:33:33,423 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2)
2015-05-20 19:33:33,542 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432174936628_0035
2015-05-20 19:33:33,542 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0035/
2015-05-20 19:33:47,658 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0035_01_000004 is : 143
2015-05-20 19:33:47,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0035_01_000002 is : 143
2015-05-20 19:33:47,784 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0035_01_000003 is : 143
2015-05-20 19:33:47,890 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0035_01_000005 is : 143
2015-05-20 19:33:49,106 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...JoinMergeGroupBy/hashjoin
2015-05-20 19:33:49,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432174936628_0036
2015-05-20 19:33:49,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0036/
2015-05-20 19:34:08,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000002 is : 143
2015-05-20 19:34:08,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000005 is : 143
2015-05-20 19:34:08,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000006 is : 143
2015-05-20 19:34:08,750 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000007 is : 143
2015-05-20 19:34:08,796 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000004 is : 143
2015-05-20 19:34:08,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000008 is : 143
2015-05-20 19:34:08,876 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000003 is : 143
2015-05-20 19:34:13,795 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0036_01_000009 is : 143
2015-05-20 19:34:14,947 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin/_temporary
2015-05-20 19:34:14,970 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin
2015-05-20 19:34:14,984 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:34:14,985 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:34:14,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-05-20 19:34:14,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:34:14,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2"]
2015-05-20 19:34:14,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-05-20 19:34:14,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-05-20 19:34:14,992 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-05-20 19:34:14,993 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...edpipesplatform/samepipe2
2015-05-20 19:34:15,089 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1432174936628_0037
2015-05-20 19:34:15,090 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0037/
2015-05-20 19:34:30,891 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0037_01_000002 is : 143
2015-05-20 19:34:30,972 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0037_01_000003 is : 143
2015-05-20 19:34:31,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0037_01_000005 is : 143
2015-05-20 19:34:31,194 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0037_01_000006 is : 143
2015-05-20 19:34:31,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0037_01_000004 is : 143
2015-05-20 19:34:32,457 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2/_temporary
2015-05-20 19:34:32,491 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe2
2015-05-20 19:34:32,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:34:32,510 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:34:32,518 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting
2015-05-20 19:34:32,518 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:34:32,518 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3"]
2015-05-20 19:34:32,518 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  parallel execution is enabled: true
2015-05-20 19:34:32,518 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  starting jobs: 1
2015-05-20 19:34:32,519 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  allocating threads: 1
2015-05-20 19:34:32,519 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] starting step: (1/1) ...edpipesplatform/samepipe3
2015-05-20 19:34:32,618 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] submitted hadoop job: job_1432174936628_0038
2015-05-20 19:34:32,618 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0038/
2015-05-20 19:34:47,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0038_01_000003 is : 143
2015-05-20 19:34:48,057 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0038_01_000002 is : 143
2015-05-20 19:34:48,241 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0038_01_000006 is : 143
2015-05-20 19:34:48,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0038_01_000005 is : 143
2015-05-20 19:34:48,421 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0038_01_000004 is : 143
2015-05-20 19:34:49,607 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3/_temporary
2015-05-20 19:34:49,639 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe3
2015-05-20 19:34:49,660 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:34:49,661 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:34:49,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:34:49,671 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:34:49,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:34:49,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby"]
2015-05-20 19:34:49,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:34:49,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:34:49,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:34:49,673 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...pipesplatform/joingroupby
2015-05-20 19:34:49,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0039
2015-05-20 19:34:49,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0039/
2015-05-20 19:35:05,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0039_01_000002 is : 143
2015-05-20 19:35:05,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0039_01_000005 is : 143
2015-05-20 19:35:05,786 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0039_01_000003 is : 143
2015-05-20 19:35:05,814 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0039_01_000006 is : 143
2015-05-20 19:35:05,855 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0039_01_000004 is : 143
2015-05-20 19:35:11,184 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0039_01_000007 is : 143
2015-05-20 19:35:12,356 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby/_temporary
2015-05-20 19:35:12,384 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupby
2015-05-20 19:35:12,399 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:35:12,400 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:35:12,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-05-20 19:35:12,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:35:12,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe"]
2015-05-20 19:35:12,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-05-20 19:35:12,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-05-20 19:35:12,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-05-20 19:35:12,410 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...dedpipesplatform/samepipe
2015-05-20 19:35:12,516 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1432174936628_0040
2015-05-20 19:35:12,516 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0040/
2015-05-20 19:35:28,228 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0040_01_000003 is : 143
2015-05-20 19:35:28,322 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0040_01_000006 is : 143
2015-05-20 19:35:28,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0040_01_000002 is : 143
2015-05-20 19:35:28,673 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0040_01_000005 is : 143
2015-05-20 19:35:28,705 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0040_01_000004 is : 143
2015-05-20 19:35:29,879 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe/_temporary
2015-05-20 19:35:29,921 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe
2015-05-20 19:35:29,942 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:35:29,943 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:35:29,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:35:29,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/rhs-sparse.txt"]
2015-05-20 19:35:29,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lhs-sparse.txt"]
2015-05-20 19:35:29,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter"]
2015-05-20 19:35:29,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:35:29,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:35:29,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:35:29,958 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/joininnerouter
2015-05-20 19:35:30,051 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0041
2015-05-20 19:35:30,051 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0041/
2015-05-20 19:35:45,281 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0041_01_000006 is : 143
2015-05-20 19:35:45,732 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0041_01_000002 is : 143
2015-05-20 19:35:45,755 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0041_01_000004 is : 143
2015-05-20 19:35:45,786 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0041_01_000003 is : 143
2015-05-20 19:35:45,891 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0041_01_000005 is : 143
2015-05-20 19:35:47,069 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter/_temporary
2015-05-20 19:35:47,107 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnerouter
2015-05-20 19:35:47,127 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:35:47,127 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:35:47,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 19:35:47,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/upper.txt"]
2015-05-20 19:35:47,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/lower.txt"]
2015-05-20 19:35:47,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields"]
2015-05-20 19:35:47,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-05-20 19:35:47,137 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-05-20 19:35:47,138 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-05-20 19:35:47,138 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/difffields
2015-05-20 19:35:47,237 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432174936628_0042
2015-05-20 19:35:47,237 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:52953/proxy/application_1432174936628_0042/
2015-05-20 19:36:02,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0042_01_000006 is : 143
2015-05-20 19:36:02,909 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0042_01_000004 is : 143
2015-05-20 19:36:02,932 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0042_01_000003 is : 143
2015-05-20 19:36:03,117 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0042_01_000005 is : 143
2015-05-20 19:36:03,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432174936628_0042_01_000002 is : 143
2015-05-20 19:36:04,363 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields/_temporary
2015-05-20 19:36:04,404 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/difffields

Standard error

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