2015-05-20 17:28:15,051 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 17:28:15,087 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 17:28:15,088 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.CascadePlatformTest
2015-05-20 17:28:15,104 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 17:28:15,940 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 17:28:16,517 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 17:28:20,335 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 17:28:20,567 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 17:28:20,781 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 17:28:20,978 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 17:28:38,181 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,182 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 17:28:38,187 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: EADC09FBB3F9435E839995E44DAA5260
2015-05-20 17:28:38,292 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,293 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 17:28:38,327 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,330 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 17:28:38,369 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,370 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 17:28:38,402 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 17:28:38,402 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-05-20 17:28:38,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] parallel execution is enabled: true
2015-05-20 17:28:38,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flows: 4
2015-05-20 17:28:38,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] allocating threads: 4
2015-05-20 17:28:38,408 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-05-20 17:28:38,409 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: first
2015-05-20 17:28:38,410 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: second
2015-05-20 17:28:38,410 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: second
2015-05-20 17:28:38,410 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: third
2015-05-20 17:28:38,411 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: third
2015-05-20 17:28:38,411 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: fourth
2015-05-20 17:28:38,412 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: fourth
2015-05-20 17:28:38,421 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/skipped/second
2015-05-20 17:28:38,423 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/skipped/first
2015-05-20 17:28:38,427 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/skipped/third
2015-05-20 17:28:38,429 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/skipped/fourth
2015-05-20 17:28:38,458 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,459 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 17:28:38,494 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,495 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 17:28:38,535 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:28:38,536 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 17:28:38,558 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting
2015-05-20 17:28:38,561 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] parallel execution is enabled: true
2015-05-20 17:28:38,561 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flows: 3
2015-05-20 17:28:38,561 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] allocating threads: 3
2015-05-20 17:28:38,562 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: second
2015-05-20 17:28:38,562 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: first
2015-05-20 17:28:38,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 17:28:38,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 17:28:38,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:28:38,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:28:38,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:28:38,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 17:28:38,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:28:38,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:28:38,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]
2015-05-20 17:28:38,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"]
2015-05-20 17:28:38,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 17:28:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:28:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 17:28:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:28:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:28:38,583 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 17:28:38,585 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...deplatform/multitap/first
2015-05-20 17:28:38,585 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...eplatform/multitap/second
2015-05-20 17:28:39,680 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168112571_0002
2015-05-20 17:28:39,684 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0002/
2015-05-20 17:28:39,687 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432168112571_0001
2015-05-20 17:28:39,726 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0001/
2015-05-20 17:29:08,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0002_01_000004 is : 143
2015-05-20 17:29:08,645 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0002_01_000005 is : 143
2015-05-20 17:29:08,812 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0002_01_000003 is : 143
2015-05-20 17:29:08,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0001_01_000002 is : 143
2015-05-20 17:29:09,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0002_01_000002 is : 143
2015-05-20 17:29:09,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0001_01_000003 is : 143
2015-05-20 17:29:09,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0001_01_000004 is : 143
2015-05-20 17:29:09,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0001_01_000005 is : 143
2015-05-20 17:29:10,428 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first/_temporary
2015-05-20 17:29:10,431 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: first
2015-05-20 17:29:10,863 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second/_temporary
2015-05-20 17:29:10,864 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: second
2015-05-20 17:29:10,864 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: multitap
2015-05-20 17:29:10,865 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] at least one sink is marked for delete
2015-05-20 17:29:10,865 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:29:10,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting
2015-05-20 17:29:10,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"], Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]]]
2015-05-20 17:29:10,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap"]
2015-05-20 17:29:10,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] parallel execution is enabled: true
2015-05-20 17:29:10,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting jobs: 1
2015-05-20 17:29:10,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] allocating threads: 1
2015-05-20 17:29:10,870 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] starting step: (1/1) ...latform/multitap/multitap
2015-05-20 17:29:11,021 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] submitted hadoop job: job_1432168112571_0003
2015-05-20 17:29:11,022 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0003/
2015-05-20 17:29:42,300 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000005 is : 143
2015-05-20 17:29:42,751 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000002 is : 143
2015-05-20 17:29:42,940 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000008 is : 143
2015-05-20 17:29:43,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000003 is : 143
2015-05-20 17:29:43,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000009 is : 143
2015-05-20 17:29:43,121 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000004 is : 143
2015-05-20 17:29:43,275 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000006 is : 143
2015-05-20 17:29:43,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0003_01_000007 is : 143
2015-05-20 17:29:44,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap/_temporary
2015-05-20 17:29:44,583 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: multitap
2015-05-20 17:29:44,632 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/multitap/second
2015-05-20 17:29:44,646 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/multitap/first
2015-05-20 17:29:44,660 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/multitap/multitap
2015-05-20 17:29:44,698 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:29:44,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 17:29:44,718 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:29:44,718 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 17:29:44,746 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:29:44,746 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 17:29:44,749 INFO planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-05-20 17:29:44,770 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:29:44,771 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 17:29:44,781 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting
2015-05-20 17:29:44,782 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] parallel execution is enabled: true
2015-05-20 17:29:44,782 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flows: 4
2015-05-20 17:29:44,782 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] allocating threads: 4
2015-05-20 17:29:44,783 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: first
2015-05-20 17:29:44,783 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 17:29:44,784 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:29:44,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:29:44,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:29:44,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-05-20 17:29:44,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:29:44,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:29:44,787 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:29:44,788 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...platform/checkpoint/first
2015-05-20 17:29:44,851 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-05-20 17:29:44,851 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-05-20 17:29:44,852 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-05-20 17:29:44,908 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168112571_0004
2015-05-20 17:29:44,908 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0004/
2015-05-20 17:30:00,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0004_01_000003 is : 143
2015-05-20 17:30:01,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0004_01_000005 is : 143
2015-05-20 17:30:01,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0004_01_000002 is : 143
2015-05-20 17:30:01,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0004_01_000004 is : 143
2015-05-20 17:30:02,624 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first/_temporary
2015-05-20 17:30:02,625 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: first
2015-05-20 17:30:02,625 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: second
2015-05-20 17:30:02,626 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 17:30:02,626 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:30:02,629 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 17:30:02,629 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-05-20 17:30:02,629 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-05-20 17:30:02,630 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 17:30:02,630 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 17:30:02,630 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 17:30:02,631 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...latform/checkpoint/second
2015-05-20 17:30:02,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432168112571_0005
2015-05-20 17:30:02,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0005/
2015-05-20 17:30:21,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0005_01_000006 is : 143
2015-05-20 17:30:21,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0005_01_000005 is : 143
2015-05-20 17:30:22,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0005_01_000003 is : 143
2015-05-20 17:30:22,132 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0005_01_000002 is : 143
2015-05-20 17:30:22,304 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0005_01_000004 is : 143
2015-05-20 17:30:23,512 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second/_temporary
2015-05-20 17:30:23,513 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: second
2015-05-20 17:30:23,513 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: null
2015-05-20 17:30:23,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] at least one sink is marked for delete
2015-05-20 17:30:23,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:30:23,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-05-20 17:30:23,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-05-20 17:30:23,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath"]
2015-05-20 17:30:23,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-05-20 17:30:23,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-05-20 17:30:23,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-05-20 17:30:23,521 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...platform/checkpoint/third
2015-05-20 17:30:23,771 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432168112571_0006
2015-05-20 17:30:23,771 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0006/
2015-05-20 17:30:44,103 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0006_01_000002 is : 143
2015-05-20 17:30:44,280 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0006_01_000003 is : 143
2015-05-20 17:30:44,365 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0006_01_000006 is : 143
2015-05-20 17:30:44,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0006_01_000005 is : 143
2015-05-20 17:30:44,520 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0006_01_000007 is : 143
2015-05-20 17:30:44,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0006_01_000004 is : 143
2015-05-20 17:30:45,781 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...ascadeplatform/unusedpath
2015-05-20 17:30:46,040 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432168112571_0007
2015-05-20 17:30:46,040 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0007/
2015-05-20 17:31:09,740 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000007 is : 143
2015-05-20 17:31:09,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000003 is : 143
2015-05-20 17:31:10,327 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000006 is : 143
2015-05-20 17:31:10,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000002 is : 143
2015-05-20 17:31:10,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000004 is : 143
2015-05-20 17:31:10,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000005 is : 143
2015-05-20 17:31:10,486 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0007_01_000008 is : 143
2015-05-20 17:31:11,703 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third/_temporary
2015-05-20 17:31:11,706 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath/_temporary
2015-05-20 17:31:11,706 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: null
2015-05-20 17:31:11,707 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: fourth
2015-05-20 17:31:11,707 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-05-20 17:31:11,707 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:31:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-05-20 17:31:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-05-20 17:31:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth"]
2015-05-20 17:31:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-05-20 17:31:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-05-20 17:31:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-05-20 17:31:11,712 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...latform/checkpoint/fourth
2015-05-20 17:31:11,827 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1432168112571_0008
2015-05-20 17:31:11,827 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0008/
2015-05-20 17:31:32,269 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000003 is : 143
2015-05-20 17:31:32,389 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000004 is : 143
2015-05-20 17:31:32,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000005 is : 143
2015-05-20 17:31:32,493 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000007 is : 143
2015-05-20 17:31:32,553 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000006 is : 143
2015-05-20 17:31:32,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000002 is : 143
2015-05-20 17:31:32,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0008_01_000008 is : 143
2015-05-20 17:31:33,851 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth/_temporary
2015-05-20 17:31:33,852 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: fourth
2015-05-20 17:31:33,876 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/fourth
2015-05-20 17:31:33,896 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/first
2015-05-20 17:31:33,908 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/unusedpath
2015-05-20 17:31:33,928 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/second
2015-05-20 17:31:33,941 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/third
2015-05-20 17:31:33,969 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:31:33,969 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 17:31:33,993 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:31:33,993 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 17:31:34,014 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:31:34,014 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 17:31:34,052 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:31:34,052 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 17:31:34,065 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-05-20 17:31:34,066 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] parallel execution is enabled: true
2015-05-20 17:31:34,067 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flows: 4
2015-05-20 17:31:34,067 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] allocating threads: 4
2015-05-20 17:31:34,068 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-05-20 17:31:34,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 17:31:34,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:31:34,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:31:34,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:31:34,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail"]
2015-05-20 17:31:34,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:31:34,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:31:34,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:31:34,076 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...irsttestSimpleCascadeFail
2015-05-20 17:31:34,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168112571_0009
2015-05-20 17:31:34,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0009/
2015-05-20 17:31:49,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000002 is : 143
2015-05-20 17:31:49,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000003 is : 143
2015-05-20 17:31:49,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000005 is : 143
2015-05-20 17:31:49,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000004 is : 143
2015-05-20 17:31:53,573 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168112571_0009_01_000010
2015-05-20 17:31:53,644 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168112571_0009_01_000011
2015-05-20 17:31:53,680 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168112571_0009_01_000012
2015-05-20 17:31:53,920 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168112571_0009_01_000013
2015-05-20 17:31:57,419 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000006 is : 143
2015-05-20 17:31:59,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000008 is : 143
2015-05-20 17:31:59,546 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000007 is : 143
2015-05-20 17:31:59,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000009 is : 143
2015-05-20 17:32:04,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000014 is : 143
2015-05-20 17:32:07,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000017 is : 143
2015-05-20 17:32:08,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000016 is : 143
2015-05-20 17:32:08,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000015 is : 143
2015-05-20 17:32:10,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000018 is : 143
2015-05-20 17:32:10,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000021 is : 143
2015-05-20 17:32:10,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000020 is : 143
2015-05-20 17:32:10,299 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0009_01_000019 is : 143
2015-05-20 17:32:11,417 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] hadoop job job_1432168112571_0009 state at FAILED
2015-05-20 17:32:11,419 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] failure info: Task failed task_1432168112571_0009_m_000000
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-05-20 17:32:11,447 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events identify failed tasks
2015-05-20 17:32:11,447 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events count: 10
2015-05-20 17:32:11,448 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000000_0, Status : FAILED
2015-05-20 17:32:11,448 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000001_0, Status : FAILED
2015-05-20 17:32:11,448 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000003_0, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000002_0, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000000_1, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000003_1, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000001_1, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000002_1, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000000_2, Status : FAILED
2015-05-20 17:32:11,449 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1432168112571_0009_m_000002_2, Status : FAILED
2015-05-20 17:32:11,487 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-05-20 17:32:11,488 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-05-20 17:32:11,490 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-05-20 17:32:11,492 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail/_temporary
2015-05-20 17:32:11,497 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_1432168112571_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 17:32:11,501 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping all flows
2015-05-20 17:32:11,502 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: fourth
2015-05-20 17:32:11,503 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-05-20 17:32:11,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...urthtestSimpleCascadeFail
2015-05-20 17:32:11,503 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-05-20 17:32:11,503 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: third
2015-05-20 17:32:11,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-05-20 17:32:11,504 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...hirdtestSimpleCascadeFail
2015-05-20 17:32:11,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-05-20 17:32:11,505 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: second
2015-05-20 17:32:11,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-05-20 17:32:11,506 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...condtestSimpleCascadeFail
2015-05-20 17:32:11,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-05-20 17:32:11,506 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: first
2015-05-20 17:32:11,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-05-20 17:32:11,507 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-05-20 17:32:11,508 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-05-20 17:32:11,508 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopped all flows
2015-05-20 17:32:11,508 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascadeFail
2015-05-20 17:32:11,510 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail
2015-05-20 17:32:11,513 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascadeFail
2015-05-20 17:32:11,513 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascadeFail
2015-05-20 17:32:11,535 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:11,535 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 17:32:11,572 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:11,573 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 17:32:11,604 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:11,604 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 17:32:11,633 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:11,634 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 17:32:11,665 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-05-20 17:32:11,666 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] parallel execution is enabled: true
2015-05-20 17:32:11,666 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flows: 4
2015-05-20 17:32:11,666 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] allocating threads: 4
2015-05-20 17:32:11,667 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-05-20 17:32:11,668 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 17:32:11,668 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:32:11,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:32:11,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:32:11,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic"]
testing if running
2015-05-20 17:32:11,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:32:11,673 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:32:11,673 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:32:11,674 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2015-05-20 17:32:11,843 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168112571_0010
2015-05-20 17:32:11,843 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_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
testing if running
testing if running
2015-05-20 17:32:26,884 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0010_01_000004 is : 143
2015-05-20 17:32:26,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0010_01_000002 is : 143
2015-05-20 17:32:27,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0010_01_000003 is : 143
2015-05-20 17:32:27,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0010_01_000005 is : 143
calling stop
2015-05-20 17:32:27,736 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping all flows
2015-05-20 17:32:27,736 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: fourth
2015-05-20 17:32:27,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-05-20 17:32:27,737 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2015-05-20 17:32:27,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-05-20 17:32:27,738 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: third
2015-05-20 17:32:27,738 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-05-20 17:32:27,738 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2015-05-20 17:32:27,739 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-05-20 17:32:27,739 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: second
2015-05-20 17:32:27,739 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-05-20 17:32:27,739 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...d/second-nondeterministic
2015-05-20 17:32:27,740 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-05-20 17:32:27,740 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: first
2015-05-20 17:32:27,740 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-05-20 17:32:27,741 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2015-05-20 17:32:28,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-05-20 17:32:28,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutting down job executor
2015-05-20 17:32:28,789 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutdown complete
2015-05-20 17:32:28,789 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopped all flows
2015-05-20 17:32:28,789 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] completed flow: first
2015-05-20 17:32:28,790 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutting down flow executor
2015-05-20 17:32:28,790 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutdown complete
2015-05-20 17:32:28,790 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/stopped/third-nondeterministic
2015-05-20 17:32:28,792 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/stopped/second-nondeterministic
2015-05-20 17:32:28,793 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic
2015-05-20 17:32:28,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/stopped/fourth-nondeterministic
2015-05-20 17:32:28,829 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:28,829 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 17:32:28,849 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:28,849 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 17:32:28,873 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:28,873 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 17:32:28,893 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:32:28,894 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 17:32:28,903 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-05-20 17:32:28,904 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] parallel execution is enabled: true
2015-05-20 17:32:28,905 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flows: 4
2015-05-20 17:32:28,905 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] allocating threads: 4
2015-05-20 17:32:28,905 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-05-20 17:32:28,907 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 17:32:28,907 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:32:28,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:32:28,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:32:28,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-05-20 17:32:28,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:32:28,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:32:28,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:32:28,912 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...le/firsttestSimpleCascade
2015-05-20 17:32:29,030 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168112571_0011
2015-05-20 17:32:29,030 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0011/
2015-05-20 17:32:43,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0011_01_000003 is : 143
2015-05-20 17:32:43,479 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0011_01_000004 is : 143
2015-05-20 17:32:43,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0011_01_000005 is : 143
2015-05-20 17:32:43,752 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0011_01_000002 is : 143
2015-05-20 17:32:44,940 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade/_temporary
2015-05-20 17:32:44,941 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: first
2015-05-20 17:32:44,941 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: second
2015-05-20 17:32:44,942 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 17:32:44,942 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:32:44,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 17:32:44,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-05-20 17:32:44,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-05-20 17:32:44,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 17:32:44,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 17:32:44,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 17:32:44,946 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...e/secondtestSimpleCascade
2015-05-20 17:32:45,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432168112571_0012
2015-05-20 17:32:45,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0012/
2015-05-20 17:33:01,825 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0012_01_000003 is : 143
2015-05-20 17:33:01,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0012_01_000002 is : 143
2015-05-20 17:33:01,920 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0012_01_000006 is : 143
2015-05-20 17:33:02,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0012_01_000004 is : 143
2015-05-20 17:33:02,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0012_01_000005 is : 143
2015-05-20 17:33:03,393 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade/_temporary
2015-05-20 17:33:03,394 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: second
2015-05-20 17:33:03,395 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: third
2015-05-20 17:33:03,395 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-05-20 17:33:03,396 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:33:03,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-05-20 17:33:03,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-05-20 17:33:03,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-05-20 17:33:03,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-05-20 17:33:03,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-05-20 17:33:03,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-05-20 17:33:03,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...le/thirdtestSimpleCascade
2015-05-20 17:33:03,511 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432168112571_0013
2015-05-20 17:33:03,511 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0013/
2015-05-20 17:33:21,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0013_01_000002 is : 143
2015-05-20 17:33:21,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0013_01_000003 is : 143
2015-05-20 17:33:21,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0013_01_000007 is : 143
2015-05-20 17:33:21,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0013_01_000006 is : 143
2015-05-20 17:33:22,016 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0013_01_000005 is : 143
2015-05-20 17:33:22,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0013_01_000004 is : 143
2015-05-20 17:33:23,373 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade/_temporary
2015-05-20 17:33:23,375 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: third
2015-05-20 17:33:23,375 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: fourth
2015-05-20 17:33:23,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-05-20 17:33:23,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:33:23,382 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-05-20 17:33:23,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-05-20 17:33:23,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade"]
2015-05-20 17:33:23,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-05-20 17:33:23,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-05-20 17:33:23,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-05-20 17:33:23,384 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...e/fourthtestSimpleCascade
2015-05-20 17:33:23,501 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1432168112571_0014
2015-05-20 17:33:23,501 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Edinburgh.local:62441/proxy/application_1432168112571_0014/
2015-05-20 17:33:43,582 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000003 is : 143
2015-05-20 17:33:43,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000002 is : 143
2015-05-20 17:33:43,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000006 is : 143
2015-05-20 17:33:43,977 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000007 is : 143
2015-05-20 17:33:44,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000008 is : 143
2015-05-20 17:33:44,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000004 is : 143
2015-05-20 17:33:44,150 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168112571_0014_01_000005 is : 143
2015-05-20 17:33:45,351 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade/_temporary
2015-05-20 17:33:45,352 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: fourth
2015-05-20 17:33:45,378 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade
2015-05-20 17:33:45,393 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade
2015-05-20 17:33:45,411 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade
2015-05-20 17:33:45,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade
2015-05-20 17:33:45,455 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:33:45,455 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 17:33:45,479 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:33:45,479 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 17:33:45,498 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:33:45,499 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 17:33:45,519 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:33:45,520 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 17:33:45,531 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/idtest/second
2015-05-20 17:33:45,532 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/idtest/fourth
2015-05-20 17:33:45,533 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/idtest/first
2015-05-20 17:33:45,533 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadeplatform/idtest/third
2015-05-20 17:33:45,545 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:33:45,545 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 17:33:45,580 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:33:45,581 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