2015-05-20 20:11:18,476 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 20:11:18,500 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 20:11:18,501 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.flow.hadoop.MapReduceFlowPlatformTest
2015-05-20 20:11:18,515 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 20:11:19,077 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 20:11:19,540 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 20:11:23,627 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 20:11:24,777 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 20:11:25,914 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 20:11:27,048 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 20:11:29,646 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: A86E92BCF9C7442E8644913309E3C362
2015-05-20 20:11:29,785 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 20:11:29,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [mrflow] starting
2015-05-20 20:11:29,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [mrflow] source: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:11:29,788 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [mrflow] sink: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flowTest"]
2015-05-20 20:11:29,788 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [mrflow] parallel execution is enabled: true
2015-05-20 20:11:29,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [mrflow] starting jobs: 1
2015-05-20 20:11:29,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [mrflow] allocating threads: 1
2015-05-20 20:11:29,790 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [mrflow] starting step: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flowTest"]
2015-05-20 20:11:29,896 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(149)) - Hadoop command-line option parsing not performed. Implement the Tool interface and execute your application with ToolRunner to remedy this.
2015-05-20 20:11:29,900 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(258)) - No job jar file set. User classes may not be found. See Job or Job#setJar(String).
2015-05-20 20:11:31,213 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [mrflow] submitted hadoop job: job_1432177881751_0001
2015-05-20 20:11:31,213 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [mrflow] tracking url: http://Edinburgh.local:51848/proxy/application_1432177881751_0001/
2015-05-20 20:11:43,150 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0001_01_000004 is : 143
2015-05-20 20:11:43,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0001_01_000002 is : 143
2015-05-20 20:11:43,258 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0001_01_000005 is : 143
2015-05-20 20:11:43,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0001_01_000003 is : 143
2015-05-20 20:11:48,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0001_01_000006 is : 143
2015-05-20 20:11:49,983 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flowTest/_temporary
2015-05-20 20:11:50,003 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mapreduceflowplatform/flowTest
2015-05-20 20:11:50,053 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:11:50,054 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 20:11:50,121 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:11:50,122 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 20:11:50,283 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting
2015-05-20 20:11:50,286 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] parallel execution is enabled: true
2015-05-20 20:11:50,286 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting flows: 5
2015-05-20 20:11:50,286 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] allocating threads: 5
2015-05-20 20:11:50,287 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting flow: first-flow
2015-05-20 20:11:50,288 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] at least one sink is marked for delete
2015-05-20 20:11:50,288 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:11:50,292 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] starting
2015-05-20 20:11:50,292 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:11:50,292 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow4"]
2015-05-20 20:11:50,292 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] parallel execution is enabled: true
2015-05-20 20:11:50,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] starting jobs: 1
2015-05-20 20:11:50,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-flow] allocating threads: 1
2015-05-20 20:11:50,294 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first-flow] starting step: (1/1) ...preduceflowplatform/flow4
2015-05-20 20:11:50,487 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first-flow] submitted hadoop job: job_1432177881751_0002
2015-05-20 20:11:50,487 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first-flow] tracking url: http://Edinburgh.local:51848/proxy/application_1432177881751_0002/
2015-05-20 20:12:03,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0002_01_000005 is : 143
2015-05-20 20:12:03,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0002_01_000003 is : 143
2015-05-20 20:12:03,939 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0002_01_000004 is : 143
2015-05-20 20:12:04,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0002_01_000002 is : 143
2015-05-20 20:12:05,242 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow4/_temporary
2015-05-20 20:12:05,243 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] completed flow: first-flow
2015-05-20 20:12:05,244 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting flow: second-flow
2015-05-20 20:12:05,244 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] at least one sink is marked for delete
2015-05-20 20:12:05,244 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:12:05,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] starting
2015-05-20 20:12:05,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow4"]
2015-05-20 20:12:05,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow5"]
2015-05-20 20:12:05,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] parallel execution is enabled: true
2015-05-20 20:12:05,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] starting jobs: 1
2015-05-20 20:12:05,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-flow] allocating threads: 1
2015-05-20 20:12:05,248 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second-flow] starting step: (1/1) ...preduceflowplatform/flow5
2015-05-20 20:12:05,403 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second-flow] submitted hadoop job: job_1432177881751_0003
2015-05-20 20:12:05,403 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second-flow] tracking url: http://Edinburgh.local:51848/proxy/application_1432177881751_0003/
2015-05-20 20:12:20,154 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0003_01_000003 is : 143
2015-05-20 20:12:20,240 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0003_01_000002 is : 143
2015-05-20 20:12:20,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0003_01_000004 is : 143
2015-05-20 20:12:20,395 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0003_01_000005 is : 143
2015-05-20 20:12:20,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0003_01_000006 is : 143
2015-05-20 20:12:21,669 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow5/_temporary
2015-05-20 20:12:21,670 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] completed flow: second-flow
2015-05-20 20:12:21,671 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting flow: first-mr
2015-05-20 20:12:21,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] at least one sink is marked for delete
2015-05-20 20:12:21,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:12:21,673 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] starting
2015-05-20 20:12:21,674 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] source: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow5"]
2015-05-20 20:12:21,674 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] sink: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow1"]
2015-05-20 20:12:21,674 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] parallel execution is enabled: true
2015-05-20 20:12:21,674 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] starting jobs: 1
2015-05-20 20:12:21,674 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first-mr] allocating threads: 1
2015-05-20 20:12:21,675 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first-mr] starting step: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow1"]
2015-05-20 20:12:21,700 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(149)) - Hadoop command-line option parsing not performed. Implement the Tool interface and execute your application with ToolRunner to remedy this.
2015-05-20 20:12:21,704 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(258)) - No job jar file set. User classes may not be found. See Job or Job#setJar(String).
2015-05-20 20:12:21,836 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first-mr] submitted hadoop job: job_1432177881751_0004
2015-05-20 20:12:21,836 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first-mr] tracking url: http://Edinburgh.local:51848/proxy/application_1432177881751_0004/
2015-05-20 20:12:38,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000007 is : 143
2015-05-20 20:12:38,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000006 is : 143
2015-05-20 20:12:38,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000002 is : 143
2015-05-20 20:12:38,228 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000003 is : 143
2015-05-20 20:12:38,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000005 is : 143
2015-05-20 20:12:38,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000004 is : 143
2015-05-20 20:12:43,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0004_01_000008 is : 143
2015-05-20 20:12:44,455 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow1/_temporary
2015-05-20 20:12:44,456 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] completed flow: first-mr
2015-05-20 20:12:44,456 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting flow: second-mr
2015-05-20 20:12:44,456 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] at least one sink is marked for delete
2015-05-20 20:12:44,456 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:12:44,458 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] starting
2015-05-20 20:12:44,459 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] source: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow1"]
2015-05-20 20:12:44,459 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] sink: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow2"]
2015-05-20 20:12:44,459 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] parallel execution is enabled: true
2015-05-20 20:12:44,459 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] starting jobs: 1
2015-05-20 20:12:44,459 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second-mr] allocating threads: 1
2015-05-20 20:12:44,460 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second-mr] starting step: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow2"]
2015-05-20 20:12:44,489 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(149)) - Hadoop command-line option parsing not performed. Implement the Tool interface and execute your application with ToolRunner to remedy this.
2015-05-20 20:12:44,491 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(258)) - No job jar file set. User classes may not be found. See Job or Job#setJar(String).
2015-05-20 20:12:44,581 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second-mr] submitted hadoop job: job_1432177881751_0005
2015-05-20 20:12:44,581 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second-mr] tracking url: http://Edinburgh.local:51848/proxy/application_1432177881751_0005/
2015-05-20 20:12:57,739 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0005_01_000003 is : 143
2015-05-20 20:12:57,767 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0005_01_000005 is : 143
2015-05-20 20:12:57,837 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0005_01_000002 is : 143
2015-05-20 20:12:57,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0005_01_000004 is : 143
2015-05-20 20:13:03,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0005_01_000006 is : 143
2015-05-20 20:13:04,348 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow2/_temporary
2015-05-20 20:13:04,349 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] completed flow: second-mr
2015-05-20 20:13:04,349 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] starting flow: third-mr
2015-05-20 20:13:04,349 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] at least one sink is marked for delete
2015-05-20 20:13:04,349 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:13:04,351 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] starting
2015-05-20 20:13:04,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] source: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow2"]
2015-05-20 20:13:04,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] sink: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow3"]
2015-05-20 20:13:04,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] parallel execution is enabled: true
2015-05-20 20:13:04,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] starting jobs: 1
2015-05-20 20:13:04,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third-mr] allocating threads: 1
2015-05-20 20:13:04,353 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third-mr] starting step: Hfs["NullScheme"]["hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow3"]
2015-05-20 20:13:04,374 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(149)) - Hadoop command-line option parsing not performed. Implement the Tool interface and execute your application with ToolRunner to remedy this.
2015-05-20 20:13:04,378 WARN mapreduce.JobSubmitter (JobSubmitter.java:copyAndConfigureFiles(258)) - No job jar file set. User classes may not be found. See Job or Job#setJar(String).
2015-05-20 20:13:04,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third-mr] submitted hadoop job: job_1432177881751_0006
2015-05-20 20:13:04,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third-mr] tracking url: http://Edinburgh.local:51848/proxy/application_1432177881751_0006/
2015-05-20 20:13:12,924 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0006_01_000002 is : 143
2015-05-20 20:13:17,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432177881751_0006_01_000003 is : 143
2015-05-20 20:13:19,076 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:51817/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/mapreduceflowplatform/flow3/_temporary
2015-05-20 20:13:19,077 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first-flow+second-flow...] completed flow: third-mr
2015-05-20 20:13:19,092 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mapreduceflowplatform/flow1
2015-05-20 20:13:19,097 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mapreduceflowplatform/flow4
2015-05-20 20:13:19,110 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mapreduceflowplatform/flow5
2015-05-20 20:13:19,126 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mapreduceflowplatform/flow2
2015-05-20 20:13:19,132 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/mapreduceflowplatform/flow3