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