Class cascading.cascade.CascadePlatformTest

8

tests

0

failures

0

ignored

4m49.36s

duration

100%

successful

Tests

Test Duration Result
testCascadeID 0.081s passed
testCheckpointTapCascade 1m30.82s passed
testMultiTapCascade 53.304s passed
testPlannerFailureDuplicateSinks 0.048s passed
testSimpleCascade 1m11.08s passed
testSimpleCascadeFail 38.029s passed
testSimpleCascadeStop 24.638s passed
testSkippedCascade 11.352s passed

Standard output

2015-05-20 19:55:32,401 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 19:55:32,438 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 19:55:32,438 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.CascadePlatformTest
2015-05-20 19:55:32,454 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 19:55:33,019 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-05-20 19:55:33,499 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 19:55:37,555 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 19:55:38,704 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 19:55:39,844 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 19:55:40,976 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 19:55:43,598 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,599 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,605 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: BDC7FF276F5045E295AB8269BD062FEC
2015-05-20 19:55:43,713 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,714 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,742 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,743 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,767 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,767 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,791 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 19:55:43,791 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-05-20 19:55:43,794 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  parallel execution is enabled: true
2015-05-20 19:55:43,794 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  starting flows: 4
2015-05-20 19:55:43,794 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  allocating threads: 4
2015-05-20 19:55:43,795 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-05-20 19:55:43,795 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: first
2015-05-20 19:55:43,796 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: second
2015-05-20 19:55:43,796 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: second
2015-05-20 19:55:43,796 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: third
2015-05-20 19:55:43,796 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: third
2015-05-20 19:55:43,797 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: fourth
2015-05-20 19:55:43,797 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: fourth
2015-05-20 19:55:43,801 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/skipped/third
2015-05-20 19:55:43,801 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/skipped/fourth
2015-05-20 19:55:43,802 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/skipped/second
2015-05-20 19:55:43,803 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/skipped/first
2015-05-20 19:55:43,820 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,820 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,845 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,845 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,884 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:55:43,885 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:55:43,912 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting
2015-05-20 19:55:43,914 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second]  parallel execution is enabled: true
2015-05-20 19:55:43,915 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second]  starting flows: 3
2015-05-20 19:55:43,915 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second]  allocating threads: 3
2015-05-20 19:55:43,915 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: second
2015-05-20 19:55:43,916 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: first
2015-05-20 19:55:43,917 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 19:55:43,917 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:55:43,917 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 19:55:43,918 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:55:43,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 19:55:43,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/ips.20.txt"]
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/ips.20.txt"]
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"]
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-05-20 19:55:43,937 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]
2015-05-20 19:55:43,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: true
2015-05-20 19:55:43,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 1
2015-05-20 19:55:43,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-05-20 19:55:43,939 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...deplatform/multitap/first
2015-05-20 19:55:43,939 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...eplatform/multitap/second
2015-05-20 19:55:45,550 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432176935720_0001
2015-05-20 19:55:45,550 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432176935720_0002
2015-05-20 19:55:45,551 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0002/
2015-05-20 19:55:45,551 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0001/
2015-05-20 19:56:07,704 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0001_01_000005 is : 143
2015-05-20 19:56:07,886 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0001_01_000002 is : 143
2015-05-20 19:56:07,961 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0001_01_000003 is : 143
2015-05-20 19:56:07,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0001_01_000004 is : 143
2015-05-20 19:56:08,334 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0002_01_000004 is : 143
2015-05-20 19:56:08,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0002_01_000003 is : 143
2015-05-20 19:56:08,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0002_01_000005 is : 143
2015-05-20 19:56:08,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0002_01_000002 is : 143
2015-05-20 19:56:09,286 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second/_temporary
2015-05-20 19:56:09,287 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: second
2015-05-20 19:56:09,759 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first/_temporary
2015-05-20 19:56:09,760 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: first
2015-05-20 19:56:09,760 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: multitap
2015-05-20 19:56:09,761 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] at least one sink is marked for delete
2015-05-20 19:56:09,761 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:56:09,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting
2015-05-20 19:56:09,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"], Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]]]
2015-05-20 19:56:09,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap"]
2015-05-20 19:56:09,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  parallel execution is enabled: true
2015-05-20 19:56:09,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  starting jobs: 1
2015-05-20 19:56:09,764 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap]  allocating threads: 1
2015-05-20 19:56:09,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] starting step: (1/1) ...latform/multitap/multitap
2015-05-20 19:56:09,903 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] submitted hadoop job: job_1432176935720_0003
2015-05-20 19:56:09,903 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0003/
2015-05-20 19:56:35,043 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000008 is : 143
2015-05-20 19:56:35,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000009 is : 143
2015-05-20 19:56:35,352 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000004 is : 143
2015-05-20 19:56:35,426 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000005 is : 143
2015-05-20 19:56:35,553 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000007 is : 143
2015-05-20 19:56:35,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000002 is : 143
2015-05-20 19:56:35,710 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000006 is : 143
2015-05-20 19:56:35,813 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0003_01_000003 is : 143
2015-05-20 19:56:37,028 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap/_temporary
2015-05-20 19:56:37,028 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: multitap
2015-05-20 19:56:37,064 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/multitap/multitap
2015-05-20 19:56:37,086 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/multitap/second
2015-05-20 19:56:37,098 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/multitap/first
2015-05-20 19:56:37,123 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:56:37,124 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:56:37,143 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:56:37,143 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:56:37,162 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:56:37,162 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:56:37,165 INFO  planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-05-20 19:56:37,183 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:56:37,184 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:56:37,193 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting
2015-05-20 19:56:37,194 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first]  parallel execution is enabled: true
2015-05-20 19:56:37,194 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first]  starting flows: 4
2015-05-20 19:56:37,195 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first]  allocating threads: 4
2015-05-20 19:56:37,195 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: first
2015-05-20 19:56:37,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 19:56:37,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:56:37,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 19:56:37,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/ips.20.txt"]
2015-05-20 19:56:37,198 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-05-20 19:56:37,199 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-05-20 19:56:37,199 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-05-20 19:56:37,199 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-05-20 19:56:37,200 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...platform/checkpoint/first
2015-05-20 19:56:37,319 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432176935720_0004
2015-05-20 19:56:37,319 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0004/
2015-05-20 19:56:51,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0004_01_000002 is : 143
2015-05-20 19:56:51,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0004_01_000004 is : 143
2015-05-20 19:56:51,395 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0004_01_000005 is : 143
2015-05-20 19:56:51,414 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0004_01_000003 is : 143
2015-05-20 19:56:52,612 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first/_temporary
2015-05-20 19:56:52,613 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: first
2015-05-20 19:56:52,613 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: second
2015-05-20 19:56:52,614 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 19:56:52,614 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:56:52,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 19:56:52,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-05-20 19:56:52,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-05-20 19:56:52,617 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: true
2015-05-20 19:56:52,617 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 1
2015-05-20 19:56:52,617 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-05-20 19:56:52,618 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...latform/checkpoint/second
2015-05-20 19:56:52,733 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432176935720_0005
2015-05-20 19:56:52,733 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0005/
2015-05-20 19:57:07,674 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0005_01_000006 is : 143
2015-05-20 19:57:07,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0005_01_000002 is : 143
2015-05-20 19:57:07,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0005_01_000005 is : 143
2015-05-20 19:57:08,024 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0005_01_000003 is : 143
2015-05-20 19:57:08,078 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0005_01_000004 is : 143
2015-05-20 19:57:09,282 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second/_temporary
2015-05-20 19:57:09,283 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: second
2015-05-20 19:57:09,283 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: null
2015-05-20 19:57:09,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] at least one sink is marked for delete
2015-05-20 19:57:09,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:57:09,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-05-20 19:57:09,287 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-05-20 19:57:09,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath"]
2015-05-20 19:57:09,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  parallel execution is enabled: true
2015-05-20 19:57:09,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  starting jobs: 2
2015-05-20 19:57:09,288 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  allocating threads: 2
2015-05-20 19:57:09,289 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...platform/checkpoint/third
2015-05-20 19:57:09,409 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432176935720_0006
2015-05-20 19:57:09,410 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0006/
2015-05-20 19:57:25,805 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0006_01_000006 is : 143
2015-05-20 19:57:26,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0006_01_000007 is : 143
2015-05-20 19:57:26,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0006_01_000004 is : 143
2015-05-20 19:57:26,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0006_01_000003 is : 143
2015-05-20 19:57:26,386 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0006_01_000005 is : 143
2015-05-20 19:57:26,481 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0006_01_000002 is : 143
2015-05-20 19:57:27,695 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...ascadeplatform/unusedpath
2015-05-20 19:57:27,800 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432176935720_0007
2015-05-20 19:57:27,800 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0007/
2015-05-20 19:57:45,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000006 is : 143
2015-05-20 19:57:46,020 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000007 is : 143
2015-05-20 19:57:46,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000004 is : 143
2015-05-20 19:57:46,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000005 is : 143
2015-05-20 19:57:46,276 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000003 is : 143
2015-05-20 19:57:46,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000008 is : 143
2015-05-20 19:57:46,364 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0007_01_000002 is : 143
2015-05-20 19:57:47,560 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third/_temporary
2015-05-20 19:57:47,561 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath/_temporary
2015-05-20 19:57:47,562 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: null
2015-05-20 19:57:47,562 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: fourth
2015-05-20 19:57:47,563 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-05-20 19:57:47,563 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:57:47,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-05-20 19:57:47,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-05-20 19:57:47,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth"]
2015-05-20 19:57:47,568 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  parallel execution is enabled: true
2015-05-20 19:57:47,568 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  starting jobs: 1
2015-05-20 19:57:47,568 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  allocating threads: 1
2015-05-20 19:57:47,568 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...latform/checkpoint/fourth
2015-05-20 19:57:47,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1432176935720_0008
2015-05-20 19:57:47,666 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0008/
2015-05-20 19:58:06,248 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000003 is : 143
2015-05-20 19:58:06,322 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000002 is : 143
2015-05-20 19:58:06,475 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000007 is : 143
2015-05-20 19:58:06,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000004 is : 143
2015-05-20 19:58:06,533 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000006 is : 143
2015-05-20 19:58:06,593 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000008 is : 143
2015-05-20 19:58:06,655 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0008_01_000005 is : 143
2015-05-20 19:58:07,851 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth/_temporary
2015-05-20 19:58:07,851 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: fourth
2015-05-20 19:58:07,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/unusedpath
2015-05-20 19:58:07,886 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/first
2015-05-20 19:58:07,897 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/fourth
2015-05-20 19:58:07,910 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/second
2015-05-20 19:58:07,922 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/third
2015-05-20 19:58:07,947 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:07,947 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:58:07,974 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:07,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 19:58:07,989 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:07,989 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:58:08,004 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:08,004 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:58:08,014 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-05-20 19:58:08,015 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  parallel execution is enabled: true
2015-05-20 19:58:08,015 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  starting flows: 4
2015-05-20 19:58:08,015 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  allocating threads: 4
2015-05-20 19:58:08,016 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-05-20 19:58:08,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 19:58:08,016 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:58:08,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 19:58:08,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/ips.20.txt"]
2015-05-20 19:58:08,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail"]
2015-05-20 19:58:08,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-05-20 19:58:08,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-05-20 19:58:08,019 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-05-20 19:58:08,020 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...irsttestSimpleCascadeFail
2015-05-20 19:58:08,118 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432176935720_0009
2015-05-20 19:58:08,118 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0009/
2015-05-20 19:58:21,530 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000004 is : 143
2015-05-20 19:58:21,556 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000003 is : 143
2015-05-20 19:58:21,580 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000002 is : 143
2015-05-20 19:58:21,604 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000005 is : 143
2015-05-20 19:58:29,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000009 is : 143
2015-05-20 19:58:29,652 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000007 is : 143
2015-05-20 19:58:29,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000006 is : 143
2015-05-20 19:58:29,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000008 is : 143
2015-05-20 19:58:33,609 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000014
2015-05-20 19:58:33,829 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000015
2015-05-20 19:58:33,901 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000016
2015-05-20 19:58:34,610 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000017
2015-05-20 19:58:36,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000010 is : 143
2015-05-20 19:58:38,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000011 is : 143
2015-05-20 19:58:38,409 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000012 is : 143
2015-05-20 19:58:38,450 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000013 is : 143
2015-05-20 19:58:41,632 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000022
2015-05-20 19:58:42,393 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000023
2015-05-20 19:58:42,415 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000024
2015-05-20 19:58:42,450 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1432176935720_0009_01_000025
2015-05-20 19:58:44,728 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000018 is : 143
2015-05-20 19:58:44,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000019 is : 143
2015-05-20 19:58:44,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000021 is : 143
2015-05-20 19:58:44,770 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0009_01_000020 is : 143
2015-05-20 19:58:45,871 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] hadoop job job_1432176935720_0009 state at FAILED
2015-05-20 19:58:45,872 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] failure info: Task failed task_1432176935720_0009_m_000003
Job failed as tasks failed. failedMaps:1 failedReduces:0

2015-05-20 19:58:45,901 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events identify failed tasks
2015-05-20 19:58:45,901 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events count: 10
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000002_0, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000001_0, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000000_0, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000003_0, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000003_1, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000001_1, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000002_1, Status : FAILED
2015-05-20 19:58:45,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000000_1, Status : FAILED
2015-05-20 19:58:45,903 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000003_2, Status : FAILED
2015-05-20 19:58:45,903 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432176935720_0009_m_000001_2, Status : FAILED
2015-05-20 19:58:45,944 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-05-20 19:58:45,944 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-05-20 19:58:45,946 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-05-20 19:58:45,947 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail/_temporary
2015-05-20 19:58:45,948 WARN  cascade.Cascade (Cascade.java:logWarn(1006)) - [fourth+second+third+first] flow failed: first
cascading.flow.FlowException: step failed: (1/1) ...irsttestSimpleCascadeFail, with job id: job_1432176935720_0009, please see cluster logs for failure messages
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:261)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:162)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:124)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:43)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-05-20 19:58:45,952 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping all flows
2015-05-20 19:58:45,953 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: fourth
2015-05-20 19:58:45,953 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-05-20 19:58:45,954 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...urthtestSimpleCascadeFail
2015-05-20 19:58:45,954 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-05-20 19:58:45,954 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: third
2015-05-20 19:58:45,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-05-20 19:58:45,955 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...hirdtestSimpleCascadeFail
2015-05-20 19:58:45,955 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-05-20 19:58:45,956 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: second
2015-05-20 19:58:45,956 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-05-20 19:58:45,956 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...condtestSimpleCascadeFail
2015-05-20 19:58:45,957 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-05-20 19:58:45,957 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: first
2015-05-20 19:58:45,957 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-05-20 19:58:45,957 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-05-20 19:58:45,958 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-05-20 19:58:45,959 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopped all flows
2015-05-20 19:58:45,959 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascadeFail
2015-05-20 19:58:45,960 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail
2015-05-20 19:58:45,962 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascadeFail
2015-05-20 19:58:45,963 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascadeFail
2015-05-20 19:58:45,981 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:45,982 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:58:46,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:46,007 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:58:46,024 ERROR security.UserGroupInformation (UserGroupInformation.java:doAs(1494)) - PriviledgedActionException as:soberoi (auth:SIMPLE) cause:java.io.FileNotFoundException: File does not exist: /tmp/hadoop-yarn/staging/soberoi/.staging/job_1432176935720_0009/job.split
2015-05-20 19:58:46,035 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:46,036 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:58:46,059 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:58:46,060 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
calling start
2015-05-20 19:58:46,076 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-05-20 19:58:46,077 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  parallel execution is enabled: true
2015-05-20 19:58:46,077 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  starting flows: 4
2015-05-20 19:58:46,077 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth]  allocating threads: 4
2015-05-20 19:58:46,078 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-05-20 19:58:46,078 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 19:58:46,078 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:58:46,081 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
testing if running
2015-05-20 19:58:46,081 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/ips.20.txt"]
2015-05-20 19:58:46,081 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic"]
2015-05-20 19:58:46,081 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-05-20 19:58:46,081 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-05-20 19:58:46,081 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-05-20 19:58:46,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2015-05-20 19:58:46,175 ERROR security.UserGroupInformation (UserGroupInformation.java:doAs(1494)) - PriviledgedActionException as:soberoi (auth:SIMPLE) cause:java.io.FileNotFoundException: File does not exist: /tmp/hadoop-yarn/staging/soberoi/.staging/job_1432176935720_0009/job.split
2015-05-20 19:58:46,215 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432176935720_0010
2015-05-20 19:58:46,216 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0010/
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
2015-05-20 19:58:59,302 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0010_01_000003 is : 143
2015-05-20 19:58:59,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0010_01_000002 is : 143
2015-05-20 19:58:59,553 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0010_01_000005 is : 143
2015-05-20 19:58:59,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0010_01_000004 is : 143
calling stop
2015-05-20 19:59:00,143 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping all flows
2015-05-20 19:59:00,144 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: fourth
2015-05-20 19:59:00,144 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-05-20 19:59:00,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2015-05-20 19:59:00,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-05-20 19:59:00,145 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: third
2015-05-20 19:59:00,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-05-20 19:59:00,145 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2015-05-20 19:59:00,145 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-05-20 19:59:00,145 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: second
2015-05-20 19:59:00,146 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-05-20 19:59:00,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...d/second-nondeterministic
2015-05-20 19:59:00,146 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-05-20 19:59:00,146 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: first
2015-05-20 19:59:00,146 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-05-20 19:59:00,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2015-05-20 19:59:10,572 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-05-20 19:59:10,573 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutting down job executor
2015-05-20 19:59:10,586 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutdown complete
2015-05-20 19:59:10,587 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopped all flows
2015-05-20 19:59:10,587 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] completed flow: first
2015-05-20 19:59:10,587 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutting down flow executor
2015-05-20 19:59:10,588 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutdown complete
2015-05-20 19:59:10,589 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic
2015-05-20 19:59:10,600 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/stopped/fourth-nondeterministic
2015-05-20 19:59:10,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/stopped/third-nondeterministic
2015-05-20 19:59:10,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/stopped/second-nondeterministic
2015-05-20 19:59:10,613 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:59:10,613 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:59:10,642 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:59:10,642 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:59:10,663 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:59:10,663 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:59:10,702 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 19:59:10,702 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 19:59:10,721 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-05-20 19:59:10,722 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  parallel execution is enabled: true
2015-05-20 19:59:10,722 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  starting flows: 4
2015-05-20 19:59:10,722 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first]  allocating threads: 4
2015-05-20 19:59:10,723 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-05-20 19:59:10,723 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 19:59:10,724 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:59:10,726 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 19:59:10,726 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/ips.20.txt"]
2015-05-20 19:59:10,726 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-05-20 19:59:10,727 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  parallel execution is enabled: true
2015-05-20 19:59:10,727 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  starting jobs: 1
2015-05-20 19:59:10,727 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [first]  allocating threads: 1
2015-05-20 19:59:10,728 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...le/firsttestSimpleCascade
2015-05-20 19:59:10,869 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432176935720_0011
2015-05-20 19:59:10,869 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0011/
2015-05-20 19:59:24,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0011_01_000004 is : 143
2015-05-20 19:59:24,777 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0011_01_000005 is : 143
2015-05-20 19:59:24,835 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0011_01_000003 is : 143
2015-05-20 19:59:24,863 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0011_01_000002 is : 143
2015-05-20 19:59:26,034 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade/_temporary
2015-05-20 19:59:26,035 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: first
2015-05-20 19:59:26,035 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: second
2015-05-20 19:59:26,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 19:59:26,035 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:59:26,037 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 19:59:26,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-05-20 19:59:26,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-05-20 19:59:26,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  parallel execution is enabled: true
2015-05-20 19:59:26,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  starting jobs: 1
2015-05-20 19:59:26,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [second]  allocating threads: 1
2015-05-20 19:59:26,039 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...e/secondtestSimpleCascade
2015-05-20 19:59:26,140 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432176935720_0012
2015-05-20 19:59:26,141 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0012/
2015-05-20 19:59:41,008 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0012_01_000002 is : 143
2015-05-20 19:59:41,072 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0012_01_000003 is : 143
2015-05-20 19:59:41,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0012_01_000006 is : 143
2015-05-20 19:59:41,359 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0012_01_000005 is : 143
2015-05-20 19:59:41,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0012_01_000004 is : 143
2015-05-20 19:59:42,618 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade/_temporary
2015-05-20 19:59:42,619 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: second
2015-05-20 19:59:42,619 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: third
2015-05-20 19:59:42,619 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-05-20 19:59:42,619 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 19:59:42,621 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-05-20 19:59:42,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-05-20 19:59:42,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-05-20 19:59:42,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  parallel execution is enabled: true
2015-05-20 19:59:42,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  starting jobs: 1
2015-05-20 19:59:42,622 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [third]  allocating threads: 1
2015-05-20 19:59:42,623 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...le/thirdtestSimpleCascade
2015-05-20 19:59:42,716 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432176935720_0013
2015-05-20 19:59:42,717 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0013/
2015-05-20 19:59:59,513 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0013_01_000003 is : 143
2015-05-20 19:59:59,675 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0013_01_000002 is : 143
2015-05-20 19:59:59,703 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0013_01_000004 is : 143
2015-05-20 19:59:59,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0013_01_000006 is : 143
2015-05-20 19:59:59,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0013_01_000007 is : 143
2015-05-20 19:59:59,873 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0013_01_000005 is : 143
2015-05-20 20:00:01,066 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade/_temporary
2015-05-20 20:00:01,067 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: third
2015-05-20 20:00:01,067 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: fourth
2015-05-20 20:00:01,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-05-20 20:00:01,067 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:00:01,070 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-05-20 20:00:01,071 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-05-20 20:00:01,071 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade"]
2015-05-20 20:00:01,071 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  parallel execution is enabled: true
2015-05-20 20:00:01,071 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  starting jobs: 1
2015-05-20 20:00:01,071 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth]  allocating threads: 1
2015-05-20 20:00:01,072 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...e/fourthtestSimpleCascade
2015-05-20 20:00:01,162 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1432176935720_0014
2015-05-20 20:00:01,162 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Edinburgh.local:62827/proxy/application_1432176935720_0014/
2015-05-20 20:00:19,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000006 is : 143
2015-05-20 20:00:20,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000007 is : 143
2015-05-20 20:00:20,206 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000004 is : 143
2015-05-20 20:00:20,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000005 is : 143
2015-05-20 20:00:20,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000008 is : 143
2015-05-20 20:00:20,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000002 is : 143
2015-05-20 20:00:20,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432176935720_0014_01_000003 is : 143
2015-05-20 20:00:21,608 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade/_temporary
2015-05-20 20:00:21,608 INFO  cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: fourth
2015-05-20 20:00:21,632 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade
2015-05-20 20:00:21,645 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade
2015-05-20 20:00:21,657 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade
2015-05-20 20:00:21,667 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade
2015-05-20 20:00:21,698 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:00:21,698 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:00:21,713 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:00:21,713 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:00:21,733 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:00:21,733 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:00:21,752 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:00:21,753 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:00:21,760 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/idtest/third
2015-05-20 20:00:21,761 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/idtest/first
2015-05-20 20:00:21,762 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/idtest/second
2015-05-20 20:00:21,762 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/cascadeplatform/idtest/fourth
2015-05-20 20:00:21,772 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:00:21,773 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:00:21,803 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:00:21,804 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

Standard error

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