Class cascading.FieldedPipesPlatformTest

29

tests

0

failures

0

ignored

15m27.56s

duration

100%

successful

Tests

Test Duration Result
testChainEndingWithEach 28.434s passed
testChainedTaps 1m10.17s passed
testConcatenation 26.992s passed
testCopy 16.855s passed
testFilter 18.210s passed
testFilterAll 41.157s passed
testFilterComplex 47.042s passed
testGeneratorAggregator 24.515s passed
testGroupByInsensitive 28.231s passed
testGroupGroup 43.845s passed
testLogicFilter 19.288s passed
testNoGroup 17.481s passed
testNone 23.287s passed
testReplace 18.207s passed
testSameSourceMergeThreeChainGroup 57.353s passed
testSimpleChain 21.851s passed
testSimpleGroup 21.337s passed
testSimpleMerge 27.135s passed
testSimpleMergeThree 35.427s passed
testSplit 34.571s passed
testSplitComplex 42.253s passed
testSplitNonSafe 50.205s passed
testSplitOut 45.956s passed
testSplitSameSourceMerged 41.301s passed
testSplitSameSourceMergedSameName 41.686s passed
testSwap 22.900s passed
testUnGroup 20.918s passed
testUnGroupAnon 22.186s passed
testUnGroupBySize 18.774s passed

Standard output

2015-05-20 14:32:15,088 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 14:32:15,118 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 14:32:15,118 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.FieldedPipesPlatformTest
2015-05-20 14:32:15,138 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 14:32:15,729 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 14:32:16,258 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 14:32:19,994 WARN  fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 14:32:20,352 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 14:32:20,676 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 14:32:20,891 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 14:32:21,162 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 14:32:38,359 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:32:38,360 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 14:32:38,366 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 53C741F38F654AF7B3CF28CA09662F83
2015-05-20 14:32:38,488 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 14:32:38,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:32:38,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:32:38,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex"]
2015-05-20 14:32:38,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:32:38,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:32:38,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:32:38,492 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/filtercomplex
2015-05-20 14:32:39,222 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0001
2015-05-20 14:32:39,222 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0001/
2015-05-20 14:32:54,888 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000003 is : 143
2015-05-20 14:32:55,095 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000004 is : 143
2015-05-20 14:32:55,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000005 is : 143
2015-05-20 14:32:55,205 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000002 is : 143
2015-05-20 14:33:00,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000006 is : 143
2015-05-20 14:33:02,133 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex/_temporary
2015-05-20 14:33:02,166 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/filtercomplex
2015-05-20 14:33:02,200 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:33:02,201 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 14:33:02,238 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:33:02,238 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:33:02,238 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain"]
2015-05-20 14:33:02,239 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:33:02,239 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:33:02,239 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:33:02,240 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/simplechain
2015-05-20 14:33:02,415 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0002
2015-05-20 14:33:02,415 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0002/
2015-05-20 14:33:17,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000002 is : 143
2015-05-20 14:33:17,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000003 is : 143
2015-05-20 14:33:17,946 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000005 is : 143
2015-05-20 14:33:17,993 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000004 is : 143
2015-05-20 14:33:22,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000006 is : 143
2015-05-20 14:33:24,004 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain/_temporary
2015-05-20 14:33:24,026 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplechain
2015-05-20 14:33:24,048 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:33:24,048 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 14:33:24,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:33:24,068 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:33:24,068 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple"]
2015-05-20 14:33:24,068 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:33:24,068 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:33:24,068 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:33:24,069 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/simple
2015-05-20 14:33:24,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0003
2015-05-20 14:33:24,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0003/
2015-05-20 14:33:38,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000003 is : 143
2015-05-20 14:33:38,793 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000005 is : 143
2015-05-20 14:33:38,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000002 is : 143
2015-05-20 14:33:39,029 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000004 is : 143
2015-05-20 14:33:44,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000006 is : 143
2015-05-20 14:33:45,330 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple/_temporary
2015-05-20 14:33:45,363 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simple
2015-05-20 14:33:45,416 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:33:45,417 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 14:33:45,439 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 14:33:45,439 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 14:33:45,439 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:33:45,439 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge"]
2015-05-20 14:33:45,439 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-05-20 14:33:45,440 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-05-20 14:33:45,440 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-05-20 14:33:45,441 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-05-20 14:33:45,576 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432157552760_0004
2015-05-20 14:33:45,576 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0004/
2015-05-20 14:33:54,871 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0004_01_000008
2015-05-20 14:34:05,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000002 is : 143
2015-05-20 14:34:05,864 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000006 is : 143
2015-05-20 14:34:05,923 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000007 is : 143
2015-05-20 14:34:06,117 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000004 is : 143
2015-05-20 14:34:06,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000005 is : 143
2015-05-20 14:34:06,232 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000003 is : 143
2015-05-20 14:34:11,250 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000009 is : 143
2015-05-20 14:34:12,457 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge/_temporary
2015-05-20 14:34:12,498 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemerge
2015-05-20 14:34:12,592 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:34:12,592 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 14:34:12,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:34:12,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:34:12,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach"]
2015-05-20 14:34:12,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:34:12,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:34:12,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:34:12,612 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/chaineach
2015-05-20 14:34:12,868 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0005
2015-05-20 14:34:12,868 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0005/
2015-05-20 14:34:33,637 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000002 is : 143
2015-05-20 14:34:34,012 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000003 is : 143
2015-05-20 14:34:34,086 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000004 is : 143
2015-05-20 14:34:34,087 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000005 is : 143
2015-05-20 14:34:39,646 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000006 is : 143
2015-05-20 14:34:40,913 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach/_temporary
2015-05-20 14:34:40,934 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chaineach
2015-05-20 14:34:40,960 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:34:40,960 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 14:34:40,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:34:40,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:34:40,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator"]
2015-05-20 14:34:40,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:34:40,977 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:34:40,977 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:34:40,978 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/generatoraggregator
2015-05-20 14:34:41,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0006
2015-05-20 14:34:41,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0006/
2015-05-20 14:34:58,360 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000005 is : 143
2015-05-20 14:34:58,601 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000003 is : 143
2015-05-20 14:34:58,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000004 is : 143
2015-05-20 14:34:58,761 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000002 is : 143
2015-05-20 14:35:04,183 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000006 is : 143
2015-05-20 14:35:05,431 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator/_temporary
2015-05-20 14:35:05,450 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/generatoraggregator
2015-05-20 14:35:05,486 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:35:05,487 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 14:35:05,513 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 14:35:05,513 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 14:35:05,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:35:05,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 14:35:05,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree"]
2015-05-20 14:35:05,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  parallel execution is enabled: true
2015-05-20 14:35:05,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  starting jobs: 1
2015-05-20 14:35:05,514 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merge]  allocating threads: 1
2015-05-20 14:35:05,515 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-05-20 14:35:05,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432157552760_0007
2015-05-20 14:35:05,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0007/
2015-05-20 14:35:15,663 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0007_01_000011
2015-05-20 14:35:16,209 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0007_01_000013
2015-05-20 14:35:16,650 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0007_01_000014
2015-05-20 14:35:33,675 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000004 is : 143
2015-05-20 14:35:34,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000003 is : 143
2015-05-20 14:35:34,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000005 is : 143
2015-05-20 14:35:34,329 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000002 is : 143
2015-05-20 14:35:34,465 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000006 is : 143
2015-05-20 14:35:34,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000009 is : 143
2015-05-20 14:35:34,542 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000008 is : 143
2015-05-20 14:35:34,638 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000007 is : 143
2015-05-20 14:35:34,707 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000010 is : 143
2015-05-20 14:35:39,641 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000015 is : 143
2015-05-20 14:35:40,862 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree/_temporary
2015-05-20 14:35:40,877 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemergethree
2015-05-20 14:35:40,897 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:35:40,897 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 14:35:40,928 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-05-20 14:35:40,928 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:35:40,928 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1"]
2015-05-20 14:35:40,928 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2"]
2015-05-20 14:35:40,929 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-05-20 14:35:40,929 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 3
2015-05-20 14:35:40,929 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 3
2015-05-20 14:35:40,934 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-05-20 14:35:41,060 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0008
2015-05-20 14:35:41,060 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0008/
2015-05-20 14:35:58,061 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000002 is : 143
2015-05-20 14:35:58,439 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000005 is : 143
2015-05-20 14:35:58,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000003 is : 143
2015-05-20 14:35:58,627 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000004 is : 143
2015-05-20 14:35:59,951 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...pesplatform/nonsafesplit2
2015-05-20 14:35:59,952 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...pesplatform/nonsafesplit1
2015-05-20 14:36:00,217 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0010
2015-05-20 14:36:00,217 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0010/
2015-05-20 14:36:00,230 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0009
2015-05-20 14:36:00,230 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0009/
2015-05-20 14:36:02,226 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-05-20 14:36:12,086 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0010_01_000006
2015-05-20 14:36:12,656 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0009_01_000008
2015-05-20 14:36:13,088 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0009_01_000009
2015-05-20 14:36:28,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000003 is : 143
2015-05-20 14:36:28,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000005 is : 143
2015-05-20 14:36:28,835 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000002 is : 143
2015-05-20 14:36:29,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000004 is : 143
2015-05-20 14:36:29,441 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000005 is : 143
2015-05-20 14:36:29,584 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000003 is : 143
2015-05-20 14:36:29,684 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000002 is : 143
2015-05-20 14:36:29,758 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000004 is : 143
2015-05-20 14:36:31,016 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2/_temporary
2015-05-20 14:36:31,018 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1/_temporary
2015-05-20 14:36:31,058 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit2
2015-05-20 14:36:31,069 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit1
2015-05-20 14:36:31,111 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:36:31,112 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 14:36:31,131 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting
2015-05-20 14:36:31,131 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:36:31,131 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2"]
2015-05-20 14:36:31,131 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1"]
2015-05-20 14:36:31,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  parallel execution is enabled: true
2015-05-20 14:36:31,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  starting jobs: 3
2015-05-20 14:36:31,132 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2]  allocating threads: 3
2015-05-20 14:36:31,133 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (1/3)
2015-05-20 14:36:31,248 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1432157552760_0011
2015-05-20 14:36:31,248 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0011/
2015-05-20 14:36:37,194 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1061)) - Event EventType: FINISH_APPLICATION sent to absent application application_1432157552760_0009
2015-05-20 14:36:46,883 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000002 is : 143
2015-05-20 14:36:47,155 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000003 is : 143
2015-05-20 14:36:47,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000005 is : 143
2015-05-20 14:36:47,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000004 is : 143
2015-05-20 14:36:52,752 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000006 is : 143
2015-05-20 14:36:53,940 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (3/3) ...edpipesplatform/splitout2
2015-05-20 14:36:53,940 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (2/3) ...edpipesplatform/splitout1
2015-05-20 14:36:54,085 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1432157552760_0012
2015-05-20 14:36:54,085 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0012/
2015-05-20 14:36:54,105 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1432157552760_0013
2015-05-20 14:36:54,105 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0013/
2015-05-20 14:37:08,057 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0012_01_000002 is : 143
2015-05-20 14:37:08,219 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0013_01_000002 is : 143
2015-05-20 14:37:15,604 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0012_01_000003 is : 143
2015-05-20 14:37:16,863 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1/_temporary
2015-05-20 14:37:16,865 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2/_temporary
2015-05-20 14:37:16,993 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout1
2015-05-20 14:37:17,021 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout2
2015-05-20 14:37:17,098 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:37:17,098 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 14:37:17,118 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-05-20 14:37:17,118 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:37:17,118 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1"]
2015-05-20 14:37:17,118 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2"]
2015-05-20 14:37:17,119 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-05-20 14:37:17,119 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 2
2015-05-20 14:37:17,119 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 2
2015-05-20 14:37:17,121 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/2) ...eldedpipesplatform/split2
2015-05-20 14:37:17,121 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/2) ...eldedpipesplatform/split1
2015-05-20 14:37:17,352 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0014
2015-05-20 14:37:17,352 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0014/
2015-05-20 14:37:17,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0015
2015-05-20 14:37:17,358 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0015/
2015-05-20 14:37:32,271 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0014_01_000006
2015-05-20 14:37:32,361 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0015_01_000006
2015-05-20 14:37:49,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000003 is : 143
2015-05-20 14:37:49,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000005 is : 143
2015-05-20 14:37:49,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000002 is : 143
2015-05-20 14:37:49,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000003 is : 143
2015-05-20 14:37:50,070 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000004 is : 143
2015-05-20 14:37:50,136 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000004 is : 143
2015-05-20 14:37:50,229 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000002 is : 143
2015-05-20 14:37:50,236 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000005 is : 143
2015-05-20 14:37:51,558 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1/_temporary
2015-05-20 14:37:51,560 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2/_temporary
2015-05-20 14:37:51,595 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/split2
2015-05-20 14:37:51,607 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/split1
2015-05-20 14:37:51,631 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:37:51,632 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 14:37:51,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 14:37:51,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:37:51,648 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged"]
2015-05-20 14:37:51,648 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-05-20 14:37:51,648 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 2
2015-05-20 14:37:51,648 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 2
2015-05-20 14:37:51,649 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-05-20 14:37:51,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0016
2015-05-20 14:37:51,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0016/
2015-05-20 14:38:07,472 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000002 is : 143
2015-05-20 14:38:07,502 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000003 is : 143
2015-05-20 14:38:07,713 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000005 is : 143
2015-05-20 14:38:07,832 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000004 is : 143
2015-05-20 14:38:09,026 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...latform/splitsourcemerged
2015-05-20 14:38:09,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0017
2015-05-20 14:38:09,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0017/
2015-05-20 14:38:26,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000005 is : 143
2015-05-20 14:38:26,255 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000004 is : 143
2015-05-20 14:38:26,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000002 is : 143
2015-05-20 14:38:26,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000003 is : 143
2015-05-20 14:38:31,662 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000006 is : 143
2015-05-20 14:38:32,899 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged/_temporary
2015-05-20 14:38:32,914 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemerged
2015-05-20 14:38:32,930 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:38:32,930 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 14:38:32,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:38:32,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:38:32,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy"]
2015-05-20 14:38:32,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:38:32,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:38:32,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:38:32,943 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/copy
2015-05-20 14:38:33,063 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0018
2015-05-20 14:38:33,063 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0018/
2015-05-20 14:38:48,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000002 is : 143
2015-05-20 14:38:48,442 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000003 is : 143
2015-05-20 14:38:48,473 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000004 is : 143
2015-05-20 14:38:48,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000005 is : 143
2015-05-20 14:38:49,735 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy/_temporary
2015-05-20 14:38:49,760 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/copy
2015-05-20 14:38:49,794 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:38:49,795 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 14:38:49,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:38:49,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:38:49,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/none"]
2015-05-20 14:38:49,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:38:49,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:38:49,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:38:49,814 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/none
2015-05-20 14:38:49,954 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0019
2015-05-20 14:38:49,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0019/
2015-05-20 14:39:06,040 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000003 is : 143
2015-05-20 14:39:06,126 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000002 is : 143
2015-05-20 14:39:06,251 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000005 is : 143
2015-05-20 14:39:06,459 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000004 is : 143
2015-05-20 14:39:11,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000006 is : 143
2015-05-20 14:39:13,032 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/none/_temporary
2015-05-20 14:39:13,056 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/none
2015-05-20 14:39:13,076 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:39:13,076 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 14:39:13,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:39:13,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:39:13,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap"]
2015-05-20 14:39:13,089 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:39:13,089 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:39:13,089 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:39:13,092 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/swap
2015-05-20 14:39:13,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0020
2015-05-20 14:39:13,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0020/
2015-05-20 14:39:28,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000002 is : 143
2015-05-20 14:39:28,721 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000003 is : 143
2015-05-20 14:39:28,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000004 is : 143
2015-05-20 14:39:28,929 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000005 is : 143
2015-05-20 14:39:34,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000006 is : 143
2015-05-20 14:39:35,942 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap/_temporary
2015-05-20 14:39:35,957 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/swap
2015-05-20 14:39:35,973 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:39:35,974 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 14:39:35,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:39:35,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:39:35,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter"]
2015-05-20 14:39:35,984 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:39:35,985 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:39:35,985 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:39:35,986 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/logicfilter
2015-05-20 14:39:36,110 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0021
2015-05-20 14:39:36,110 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0021/
2015-05-20 14:39:53,513 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000005 is : 143
2015-05-20 14:39:53,784 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000002 is : 143
2015-05-20 14:39:53,842 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000004 is : 143
2015-05-20 14:39:53,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000003 is : 143
2015-05-20 14:39:55,216 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter/_temporary
2015-05-20 14:39:55,239 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/logicfilter
2015-05-20 14:39:55,288 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:39:55,288 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 14:39:55,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:39:55,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower+upper.txt"]
2015-05-20 14:39:55,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped"]
2015-05-20 14:39:55,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:39:55,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:39:55,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:39:55,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/ungrouped
2015-05-20 14:39:55,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0022
2015-05-20 14:39:55,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0022/
2015-05-20 14:40:14,366 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000002 is : 143
2015-05-20 14:40:14,404 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000006 is : 143
2015-05-20 14:40:14,825 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000003 is : 143
2015-05-20 14:40:14,876 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000005 is : 143
2015-05-20 14:40:14,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000004 is : 143
2015-05-20 14:40:16,128 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped/_temporary
2015-05-20 14:40:16,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped
2015-05-20 14:40:16,192 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:40:16,192 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 14:40:16,235 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second"]
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third"]
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first"]
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  parallel execution is enabled: true
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  starting jobs: 3
2015-05-20 14:40:16,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  allocating threads: 3
2015-05-20 14:40:16,239 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/3) ...latform/chainedtaps/first
2015-05-20 14:40:16,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432157552760_0023
2015-05-20 14:40:16,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0023/
2015-05-20 14:40:32,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000002 is : 143
2015-05-20 14:40:32,557 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000004 is : 143
2015-05-20 14:40:32,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000005 is : 143
2015-05-20 14:40:32,703 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000003 is : 143
2015-05-20 14:40:38,222 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000006 is : 143
2015-05-20 14:40:39,522 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (2/3) ...atform/chainedtaps/second
2015-05-20 14:40:39,672 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432157552760_0024
2015-05-20 14:40:39,672 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0024/
2015-05-20 14:40:55,515 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000004 is : 143
2015-05-20 14:40:55,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000002 is : 143
2015-05-20 14:40:55,735 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000005 is : 143
2015-05-20 14:40:55,789 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000003 is : 143
2015-05-20 14:41:01,245 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000006 is : 143
2015-05-20 14:41:02,466 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (3/3) ...latform/chainedtaps/third
2015-05-20 14:41:02,589 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432157552760_0025
2015-05-20 14:41:02,590 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0025/
2015-05-20 14:41:19,515 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000004 is : 143
2015-05-20 14:41:19,659 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000003 is : 143
2015-05-20 14:41:19,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000005 is : 143
2015-05-20 14:41:19,761 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000002 is : 143
2015-05-20 14:41:25,084 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000006 is : 143
2015-05-20 14:41:26,301 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first/_temporary
2015-05-20 14:41:26,303 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second/_temporary
2015-05-20 14:41:26,304 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third/_temporary
2015-05-20 14:41:26,319 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/third
2015-05-20 14:41:26,323 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/second
2015-05-20 14:41:26,330 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/first
2015-05-20 14:41:26,349 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:41:26,350 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 14:41:26,380 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:41:26,381 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:41:26,381 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall"]
2015-05-20 14:41:26,381 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:41:26,381 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-05-20 14:41:26,381 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 2
2015-05-20 14:41:26,383 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-05-20 14:41:26,500 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0026
2015-05-20 14:41:26,501 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0026/
2015-05-20 14:41:43,786 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000004 is : 143
2015-05-20 14:41:43,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000003 is : 143
2015-05-20 14:41:43,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000005 is : 143
2015-05-20 14:41:43,959 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000002 is : 143
2015-05-20 14:41:48,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000006 is : 143
2015-05-20 14:41:50,179 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...edpipesplatform/filterall
2015-05-20 14:41:50,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0027
2015-05-20 14:41:50,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0027/
2015-05-20 14:42:00,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0027_01_000002 is : 143
2015-05-20 14:42:06,255 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0027_01_000003 is : 143
2015-05-20 14:42:07,476 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall/_temporary
2015-05-20 14:42:07,489 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/filterall
2015-05-20 14:42:07,504 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:42:07,504 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 14:42:07,519 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 14:42:07,519 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:42:07,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename"]
2015-05-20 14:42:07,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  parallel execution is enabled: true
2015-05-20 14:42:07,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  starting jobs: 2
2015-05-20 14:42:07,520 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merged]  allocating threads: 2
2015-05-20 14:42:07,523 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-05-20 14:42:07,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0028
2015-05-20 14:42:07,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0028/
2015-05-20 14:42:23,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000004 is : 143
2015-05-20 14:42:23,786 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000002 is : 143
2015-05-20 14:42:23,808 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000003 is : 143
2015-05-20 14:42:23,840 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000005 is : 143
2015-05-20 14:42:25,040 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...splitsourcemergedsamename
2015-05-20 14:42:25,166 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0029
2015-05-20 14:42:25,166 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0029/
2015-05-20 14:42:41,973 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000002 is : 143
2015-05-20 14:42:42,038 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000005 is : 143
2015-05-20 14:42:42,148 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000004 is : 143
2015-05-20 14:42:42,199 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000003 is : 143
2015-05-20 14:42:47,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000006 is : 143
2015-05-20 14:42:49,158 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename/_temporary
2015-05-20 14:42:49,174 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename
2015-05-20 14:42:49,195 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:42:49,195 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 14:42:49,213 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting
2015-05-20 14:42:49,213 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 14:42:49,213 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:42:49,214 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic"]
2015-05-20 14:42:49,214 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  parallel execution is enabled: true
2015-05-20 14:42:49,214 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  starting jobs: 1
2015-05-20 14:42:49,214 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper]  allocating threads: 1
2015-05-20 14:42:49,215 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] starting step: (1/1) ...grouping-nondeterministic
2015-05-20 14:42:49,346 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] submitted hadoop job: job_1432157552760_0030
2015-05-20 14:42:49,347 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0030/
2015-05-20 14:42:59,072 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0030_01_000008
2015-05-20 14:42:59,181 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0030_01_000009
2015-05-20 14:43:09,477 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000005 is : 143
2015-05-20 14:43:09,840 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000003 is : 143
2015-05-20 14:43:09,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000002 is : 143
2015-05-20 14:43:09,967 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000004 is : 143
2015-05-20 14:43:10,000 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000006 is : 143
2015-05-20 14:43:10,106 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000007 is : 143
2015-05-20 14:43:16,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000010 is : 143
2015-05-20 14:43:17,391 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic/_temporary
2015-05-20 14:43:17,405 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic
2015-05-20 14:43:17,422 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:43:17,422 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 14:43:17,435 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:43:17,435 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower+upper.txt"]
2015-05-20 14:43:17,436 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon"]
2015-05-20 14:43:17,436 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:43:17,436 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:43:17,436 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:43:17,440 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/ungroupedanon
2015-05-20 14:43:17,560 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0031
2015-05-20 14:43:17,560 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0031/
2015-05-20 14:43:29,039 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0031_01_000008
2015-05-20 14:43:37,629 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000002 is : 143
2015-05-20 14:43:38,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000005 is : 143
2015-05-20 14:43:38,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000003 is : 143
2015-05-20 14:43:38,267 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000006 is : 143
2015-05-20 14:43:38,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000004 is : 143
2015-05-20 14:43:39,559 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon/_temporary
2015-05-20 14:43:39,582 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungroupedanon
2015-05-20 14:43:39,606 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:43:39,607 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 14:43:39,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:43:39,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:43:39,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup"]
2015-05-20 14:43:39,623 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:43:39,624 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 2
2015-05-20 14:43:39,624 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 2
2015-05-20 14:43:39,625 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-05-20 14:43:39,744 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0032
2015-05-20 14:43:39,744 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0032/
2015-05-20 14:43:57,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000005 is : 143
2015-05-20 14:43:57,958 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000004 is : 143
2015-05-20 14:43:57,970 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000002 is : 143
2015-05-20 14:43:58,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000003 is : 143
2015-05-20 14:44:04,492 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000006 is : 143
2015-05-20 14:44:05,695 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...dpipesplatform/groupgroup
2015-05-20 14:44:05,805 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0033
2015-05-20 14:44:05,805 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0033/
2015-05-20 14:44:15,707 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0033_01_000002 is : 143
2015-05-20 14:44:22,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0033_01_000003 is : 143
2015-05-20 14:44:23,420 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup/_temporary
2015-05-20 14:44:23,437 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/groupgroup
2015-05-20 14:44:23,453 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:44:23,453 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 14:44:23,472 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting
2015-05-20 14:44:23,473 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:44:23,473 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup"]
2015-05-20 14:44:23,473 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  parallel execution is enabled: true
2015-05-20 14:44:23,473 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  starting jobs: 2
2015-05-20 14:44:23,473 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset]  allocating threads: 2
2015-05-20 14:44:23,475 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (2/2)
2015-05-20 14:44:23,626 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1432157552760_0034
2015-05-20 14:44:23,627 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0034/
2015-05-20 14:44:43,038 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000006 is : 143
2015-05-20 14:44:43,215 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000003 is : 143
2015-05-20 14:44:43,238 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000005 is : 143
2015-05-20 14:44:43,307 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000004 is : 143
2015-05-20 14:44:43,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000002 is : 143
2015-05-20 14:44:49,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000007 is : 143
2015-05-20 14:44:51,005 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (1/2) .../samemergethreechaingroup
2015-05-20 14:44:51,152 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1432157552760_0035
2015-05-20 14:44:51,152 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0035/
2015-05-20 14:45:00,800 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0035_01_000008
2015-05-20 14:45:12,941 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000005 is : 143
2015-05-20 14:45:13,242 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000003 is : 143
2015-05-20 14:45:13,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000007 is : 143
2015-05-20 14:45:13,561 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000002 is : 143
2015-05-20 14:45:13,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000004 is : 143
2015-05-20 14:45:13,739 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000006 is : 143
2015-05-20 14:45:19,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000009 is : 143
2015-05-20 14:45:20,768 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup/_temporary
2015-05-20 14:45:20,790 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup
2015-05-20 14:45:20,808 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:45:20,809 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 14:45:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:45:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:45:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace"]
2015-05-20 14:45:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:45:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:45:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:45:20,820 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/replace
2015-05-20 14:45:20,924 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0036
2015-05-20 14:45:20,924 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0036/
2015-05-20 14:45:37,126 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000005 is : 143
2015-05-20 14:45:37,591 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000003 is : 143
2015-05-20 14:45:37,638 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000004 is : 143
2015-05-20 14:45:37,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000002 is : 143
2015-05-20 14:45:38,956 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace/_temporary
2015-05-20 14:45:38,988 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/replace
2015-05-20 14:45:39,027 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:45:39,027 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 14:45:39,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:45:39,036 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/extra+lower+upper.txt"]
2015-05-20 14:45:39,037 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size"]
2015-05-20 14:45:39,037 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:45:39,037 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:45:39,037 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:45:39,039 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/ungrouped_size
2015-05-20 14:45:39,094 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-05-20 14:45:39,149 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0037
2015-05-20 14:45:39,149 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0037/
2015-05-20 14:45:56,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000004 is : 143
2015-05-20 14:45:56,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000003 is : 143
2015-05-20 14:45:56,540 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000002 is : 143
2015-05-20 14:45:56,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000005 is : 143
2015-05-20 14:45:57,745 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size/_temporary
2015-05-20 14:45:57,766 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped_size
2015-05-20 14:45:57,789 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:45:57,789 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 14:45:57,796 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:45:57,797 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:45:57,797 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter"]
2015-05-20 14:45:57,797 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:45:57,797 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:45:57,797 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:45:57,799 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/filter
2015-05-20 14:45:57,916 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0038
2015-05-20 14:45:57,916 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0038/
2015-05-20 14:46:14,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000002 is : 143
2015-05-20 14:46:14,447 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000004 is : 143
2015-05-20 14:46:14,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000005 is : 143
2015-05-20 14:46:14,761 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000003 is : 143
2015-05-20 14:46:15,954 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter/_temporary
2015-05-20 14:46:15,974 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/filter
2015-05-20 14:46:16,005 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:46:16,005 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 14:46:16,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting
2015-05-20 14:46:16,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]]]
2015-05-20 14:46:16,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat"]
2015-05-20 14:46:16,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  parallel execution is enabled: true
2015-05-20 14:46:16,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  starting jobs: 1
2015-05-20 14:46:16,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [concat]  allocating threads: 1
2015-05-20 14:46:16,018 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] starting step: (1/1) ...pesplatform/complexconcat
2015-05-20 14:46:16,135 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] submitted hadoop job: job_1432157552760_0039
2015-05-20 14:46:16,135 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0039/
2015-05-20 14:46:25,463 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0039_01_000008
2015-05-20 14:46:35,901 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000006 is : 143
2015-05-20 14:46:35,985 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000002 is : 143
2015-05-20 14:46:36,154 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000003 is : 143
2015-05-20 14:46:36,221 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000005 is : 143
2015-05-20 14:46:36,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000007 is : 143
2015-05-20 14:46:36,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000004 is : 143
2015-05-20 14:46:41,738 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000009 is : 143
2015-05-20 14:46:42,960 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat/_temporary
2015-05-20 14:46:42,974 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/complexconcat
2015-05-20 14:46:42,994 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:46:42,994 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 14:46:43,018 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-05-20 14:46:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:46:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1"]
2015-05-20 14:46:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2"]
2015-05-20 14:46:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  parallel execution is enabled: true
2015-05-20 14:46:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  starting jobs: 3
2015-05-20 14:46:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right]  allocating threads: 3
2015-05-20 14:46:43,023 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-05-20 14:46:43,154 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0040
2015-05-20 14:46:43,154 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0040/
2015-05-20 14:47:00,925 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000002 is : 143
2015-05-20 14:47:01,171 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000005 is : 143
2015-05-20 14:47:01,350 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000004 is : 143
2015-05-20 14:47:01,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000003 is : 143
2015-05-20 14:47:06,688 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000006 is : 143
2015-05-20 14:47:07,909 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...dpipesplatform/splitcomp2
2015-05-20 14:47:07,909 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...dpipesplatform/splitcomp1
2015-05-20 14:47:08,176 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0041
2015-05-20 14:47:08,176 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0041/
2015-05-20 14:47:08,240 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0042
2015-05-20 14:47:08,241 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0042/
2015-05-20 14:47:23,397 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0041_01_000002 is : 143
2015-05-20 14:47:23,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0042_01_000002 is : 143
2015-05-20 14:47:25,145 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2/_temporary
2015-05-20 14:47:25,146 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1/_temporary
2015-05-20 14:47:25,211 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp1
2015-05-20 14:47:25,216 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp2
2015-05-20 14:47:25,257 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:47:25,258 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 14:47:25,269 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:47:25,270 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:47:25,270 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup"]
2015-05-20 14:47:25,270 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  parallel execution is enabled: true
2015-05-20 14:47:25,270 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  starting jobs: 1
2015-05-20 14:47:25,270 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [test]  allocating threads: 1
2015-05-20 14:47:25,271 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/nogroup
2015-05-20 14:47:25,395 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0043
2015-05-20 14:47:25,396 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0043/
2015-05-20 14:47:40,810 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000005 is : 143
2015-05-20 14:47:41,176 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000004 is : 143
2015-05-20 14:47:41,334 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000002 is : 143
2015-05-20 14:47:41,459 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000003 is : 143
2015-05-20 14:47:42,652 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup/_temporary
2015-05-20 14:47:42,700 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/nogroup

Standard error

May 20, 2015 2:32:32 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
May 20, 2015 2:32:32 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
May 20, 2015 2:32:32 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 2:32:32 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 2:32:33 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 2:32:33 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 2:32:33 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
May 20, 2015 2:32:33 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 2:32:34 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 2:32:34 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 2:32:34 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 2:32:34 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 2:32:34 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 2:32:34 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 2:32:34 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 2:32:34 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 2:32:35 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 2:32:35 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 2:32:35 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 2:32:35 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 2:32:35 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 2:32:35 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 2:32:35 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 2:32:35 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 2:32:36 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 2:32:36 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 2:32:36 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 2:32:36 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 2:32:36 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 2:32:36 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 2:32:36 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 2:32:36 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 2:32:37 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 2:32:37 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 2:32:37 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 2:32:37 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 2:32:37 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 2:32:37 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 2:32:37 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 2:32:37 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.