2015-07-17 15:02:59,911 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:02:59,934 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:02:59,934 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.CascadePlatformTest
2015-07-17 15:02:59,957 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 15:03:00,891 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-07-17 15:03:01,454 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 15:03:05,772 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-07-17 15:03:06,030 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-07-17 15:03:06,273 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-07-17 15:03:06,513 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-07-17 15:03:23,654 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-07-17 15:03:23,751 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:23,752 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:23,759 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 6F8FFC94E6774333BA512E14B332169C
2015-07-17 15:03:23,875 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:23,876 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:23,909 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:23,910 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:23,947 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:23,948 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:23,982 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:03:23,982 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-07-17 15:03:23,989 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] parallel execution is enabled: true
2015-07-17 15:03:23,989 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flows: 4
2015-07-17 15:03:23,989 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] allocating threads: 4
2015-07-17 15:03:23,990 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-07-17 15:03:23,991 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: first
2015-07-17 15:03:23,992 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: second
2015-07-17 15:03:23,992 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: second
2015-07-17 15:03:23,992 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: third
2015-07-17 15:03:23,993 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: third
2015-07-17 15:03:23,993 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: fourth
2015-07-17 15:03:23,994 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: fourth
2015-07-17 15:03:24,000 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/skipped/second
2015-07-17 15:03:24,001 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/skipped/third
2015-07-17 15:03:24,002 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/skipped/fourth
2015-07-17 15:03:24,005 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/skipped/first
2015-07-17 15:03:24,029 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:24,030 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:24,069 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:24,070 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:24,097 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:03:24,098 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:03:24,115 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting
2015-07-17 15:03:24,117 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] parallel execution is enabled: true
2015-07-17 15:03:24,117 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flows: 3
2015-07-17 15:03:24,117 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] allocating threads: 3
2015-07-17 15:03:24,118 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: second
2015-07-17 15:03:24,118 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: first
2015-07-17 15:03:24,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-07-17 15:03:24,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-07-17 15:03:24,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:03:24,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:03:24,140 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:03:24,140 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"]
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-07-17 15:03:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:03:24,142 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-07-17 15:03:24,142 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:03:24,143 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...deplatform/multitap/first
2015-07-17 15:03:24,143 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...eplatform/multitap/second
2015-07-17 15:03:25,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1437170598144_0001
2015-07-17 15:03:25,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0001/
2015-07-17 15:03:25,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437170598144_0002
2015-07-17 15:03:25,223 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0002/
2015-07-17 15:03:53,229 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0002_01_000003 is : 143
2015-07-17 15:03:53,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0002_01_000002 is : 143
2015-07-17 15:03:53,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0002_01_000004 is : 143
2015-07-17 15:03:54,240 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0002_01_000005 is : 143
2015-07-17 15:03:55,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0001_01_000002 is : 143
2015-07-17 15:03:55,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0001_01_000003 is : 143
2015-07-17 15:03:55,563 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0001_01_000005 is : 143
2015-07-17 15:03:55,747 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0001_01_000004 is : 143
2015-07-17 15:03:55,840 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first/_temporary
2015-07-17 15:03:55,845 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: first
2015-07-17 15:03:57,036 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second/_temporary
2015-07-17 15:03:57,040 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: second
2015-07-17 15:03:57,040 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: multitap
2015-07-17 15:03:57,045 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] at least one sink is marked for delete
2015-07-17 15:03:57,045 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:03:57,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting
2015-07-17 15:03:57,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"], Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]]]
2015-07-17 15:03:57,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap"]
2015-07-17 15:03:57,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] parallel execution is enabled: true
2015-07-17 15:03:57,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting jobs: 1
2015-07-17 15:03:57,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] allocating threads: 1
2015-07-17 15:03:57,051 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] starting step: (1/1) ...latform/multitap/multitap
2015-07-17 15:03:57,264 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] submitted hadoop job: job_1437170598144_0003
2015-07-17 15:03:57,264 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0003/
2015-07-17 15:04:26,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000006 is : 143
2015-07-17 15:04:26,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000003 is : 143
2015-07-17 15:04:27,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000004 is : 143
2015-07-17 15:04:27,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000007 is : 143
2015-07-17 15:04:27,409 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000005 is : 143
2015-07-17 15:04:27,549 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000008 is : 143
2015-07-17 15:04:27,642 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000002 is : 143
2015-07-17 15:04:27,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0003_01_000009 is : 143
2015-07-17 15:04:28,956 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap/_temporary
2015-07-17 15:04:28,957 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: multitap
2015-07-17 15:04:29,006 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/multitap/multitap
2015-07-17 15:04:29,050 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/multitap/first
2015-07-17 15:04:29,075 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/multitap/second
2015-07-17 15:04:29,117 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:04:29,119 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:04:29,149 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:04:29,150 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:04:29,183 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:04:29,184 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:04:29,189 INFO planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-07-17 15:04:29,215 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:04:29,215 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:04:29,230 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting
2015-07-17 15:04:29,232 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] parallel execution is enabled: true
2015-07-17 15:04:29,233 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flows: 4
2015-07-17 15:04:29,233 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] allocating threads: 4
2015-07-17 15:04:29,233 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: first
2015-07-17 15:04:29,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-07-17 15:04:29,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:04:29,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:04:29,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 15:04:29,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-07-17 15:04:29,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:04:29,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:04:29,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:04:29,241 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...platform/checkpoint/first
2015-07-17 15:04:29,391 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437170598144_0004
2015-07-17 15:04:29,391 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0004/
2015-07-17 15:04:46,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0004_01_000003 is : 143
2015-07-17 15:04:47,137 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0004_01_000002 is : 143
2015-07-17 15:04:47,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0004_01_000005 is : 143
2015-07-17 15:04:47,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0004_01_000004 is : 143
2015-07-17 15:04:48,629 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first/_temporary
2015-07-17 15:04:48,634 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: first
2015-07-17 15:04:48,634 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: second
2015-07-17 15:04:48,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-07-17 15:04:48,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:04:48,641 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-07-17 15:04:48,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-07-17 15:04:48,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-07-17 15:04:48,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-07-17 15:04:48,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-07-17 15:04:48,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-07-17 15:04:48,643 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...latform/checkpoint/second
2015-07-17 15:04:48,821 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1437170598144_0005
2015-07-17 15:04:48,821 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0005/
2015-07-17 15:05:08,270 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0005_01_000005 is : 143
2015-07-17 15:05:08,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0005_01_000004 is : 143
2015-07-17 15:05:08,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0005_01_000003 is : 143
2015-07-17 15:05:08,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0005_01_000002 is : 143
2015-07-17 15:05:08,704 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0005_01_000006 is : 143
2015-07-17 15:05:09,900 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second/_temporary
2015-07-17 15:05:09,902 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: second
2015-07-17 15:05:09,902 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: null
2015-07-17 15:05:09,903 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] at least one sink is marked for delete
2015-07-17 15:05:09,903 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:05:09,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-07-17 15:05:09,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-07-17 15:05:09,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath"]
2015-07-17 15:05:09,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-07-17 15:05:09,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-07-17 15:05:09,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-07-17 15:05:09,911 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...platform/checkpoint/third
2015-07-17 15:05:10,064 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1437170598144_0006
2015-07-17 15:05:10,064 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0006/
2015-07-17 15:05:30,261 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0006_01_000007 is : 143
2015-07-17 15:05:30,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0006_01_000006 is : 143
2015-07-17 15:05:31,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0006_01_000002 is : 143
2015-07-17 15:05:31,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0006_01_000005 is : 143
2015-07-17 15:05:31,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0006_01_000004 is : 143
2015-07-17 15:05:31,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0006_01_000003 is : 143
2015-07-17 15:05:32,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...ascadeplatform/unusedpath
2015-07-17 15:05:32,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1437170598144_0007
2015-07-17 15:05:32,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0007/
2015-07-17 15:05:57,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000002 is : 143
2015-07-17 15:05:58,064 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000007 is : 143
2015-07-17 15:05:58,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000003 is : 143
2015-07-17 15:05:58,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000005 is : 143
2015-07-17 15:05:58,199 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000008 is : 143
2015-07-17 15:05:58,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000006 is : 143
2015-07-17 15:05:58,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0007_01_000004 is : 143
2015-07-17 15:05:59,586 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third/_temporary
2015-07-17 15:05:59,588 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath/_temporary
2015-07-17 15:05:59,589 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: null
2015-07-17 15:05:59,589 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: fourth
2015-07-17 15:05:59,589 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-07-17 15:05:59,589 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:05:59,592 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-07-17 15:05:59,593 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-07-17 15:05:59,593 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth"]
2015-07-17 15:05:59,593 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-07-17 15:05:59,593 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-07-17 15:05:59,593 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-07-17 15:05:59,594 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...latform/checkpoint/fourth
2015-07-17 15:05:59,707 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1437170598144_0008
2015-07-17 15:05:59,707 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0008/
2015-07-17 15:06:23,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000007 is : 143
2015-07-17 15:06:23,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000005 is : 143
2015-07-17 15:06:23,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000006 is : 143
2015-07-17 15:06:24,154 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000004 is : 143
2015-07-17 15:06:24,199 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000008 is : 143
2015-07-17 15:06:24,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000002 is : 143
2015-07-17 15:06:24,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0008_01_000003 is : 143
2015-07-17 15:06:25,647 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth/_temporary
2015-07-17 15:06:25,648 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: fourth
2015-07-17 15:06:25,683 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/first
2015-07-17 15:06:25,709 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/third
2015-07-17 15:06:25,744 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/second
2015-07-17 15:06:25,771 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/fourth
2015-07-17 15:06:25,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/unusedpath
2015-07-17 15:06:25,861 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:06:25,862 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:06:25,897 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:06:25,897 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:06:25,919 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:06:25,920 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:06:25,951 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:06:25,952 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:06:25,965 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-07-17 15:06:25,968 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] parallel execution is enabled: true
2015-07-17 15:06:25,968 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flows: 4
2015-07-17 15:06:25,968 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] allocating threads: 4
2015-07-17 15:06:25,970 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-07-17 15:06:25,971 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-07-17 15:06:25,971 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:06:25,974 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:06:25,974 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 15:06:25,975 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail"]
2015-07-17 15:06:25,975 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:06:25,975 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:06:25,975 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:06:25,977 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...irsttestSimpleCascadeFail
2015-07-17 15:06:26,150 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437170598144_0009
2015-07-17 15:06:26,150 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0009/
2015-07-17 15:06:43,559 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000005 is : 143
2015-07-17 15:06:43,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000003 is : 143
2015-07-17 15:06:43,830 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000002 is : 143
2015-07-17 15:06:43,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000004 is : 143
2015-07-17 15:06:46,953 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000010
2015-07-17 15:06:47,231 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000011
2015-07-17 15:06:47,393 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000012
2015-07-17 15:06:48,877 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000013
2015-07-17 15:06:52,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000006 is : 143
2015-07-17 15:06:52,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000008 is : 143
2015-07-17 15:06:53,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000007 is : 143
2015-07-17 15:06:53,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000009 is : 143
2015-07-17 15:06:56,408 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000018
2015-07-17 15:06:56,696 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000019
2015-07-17 15:06:56,997 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000020
2015-07-17 15:06:57,310 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000021
2015-07-17 15:07:01,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000014 is : 143
2015-07-17 15:07:01,711 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000015 is : 143
2015-07-17 15:07:02,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000017 is : 143
2015-07-17 15:07:02,605 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000016 is : 143
2015-07-17 15:07:05,595 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000026
2015-07-17 15:07:05,716 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000027
2015-07-17 15:07:06,433 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000028
2015-07-17 15:07:06,451 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0009_01_000029
2015-07-17 15:07:13,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000022 is : 143
2015-07-17 15:07:13,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000023 is : 143
2015-07-17 15:07:13,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000025 is : 143
2015-07-17 15:07:13,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0009_01_000024 is : 143
2015-07-17 15:07:14,307 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] hadoop job job_1437170598144_0009 state at FAILED
2015-07-17 15:07:14,308 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] failure info: Task failed task_1437170598144_0009_m_000003
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-07-17 15:07:14,335 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events identify failed tasks
2015-07-17 15:07:14,335 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events count: 10
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000003_0, Status : FAILED
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000001_0, Status : FAILED
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000000_0, Status : FAILED
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000002_0, Status : FAILED
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000003_1, Status : FAILED
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000000_1, Status : FAILED
2015-07-17 15:07:14,337 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000001_1, Status : FAILED
2015-07-17 15:07:14,338 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000002_1, Status : FAILED
2015-07-17 15:07:14,338 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000003_2, Status : FAILED
2015-07-17 15:07:14,338 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1437170598144_0009_m_000000_2, Status : FAILED
2015-07-17 15:07:14,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-07-17 15:07:14,373 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-07-17 15:07:14,374 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-07-17 15:07:14,379 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail/_temporary
2015-07-17 15:07:14,383 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_1437170598144_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-07-17 15:07:14,390 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping all flows
2015-07-17 15:07:14,396 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: fourth
2015-07-17 15:07:14,396 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-07-17 15:07:14,397 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...urthtestSimpleCascadeFail
2015-07-17 15:07:14,397 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-07-17 15:07:14,398 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: third
2015-07-17 15:07:14,398 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-07-17 15:07:14,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...hirdtestSimpleCascadeFail
2015-07-17 15:07:14,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-07-17 15:07:14,399 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: second
2015-07-17 15:07:14,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-07-17 15:07:14,399 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...condtestSimpleCascadeFail
2015-07-17 15:07:14,400 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-07-17 15:07:14,400 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: first
2015-07-17 15:07:14,400 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-07-17 15:07:14,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-07-17 15:07:14,403 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-07-17 15:07:14,403 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopped all flows
2015-07-17 15:07:14,404 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascadeFail
2015-07-17 15:07:14,405 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascadeFail
2015-07-17 15:07:14,405 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascadeFail
2015-07-17 15:07:14,406 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail
2015-07-17 15:07:14,431 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:14,431 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:14,466 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:14,466 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:14,499 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:14,500 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:14,521 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:14,521 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.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-07-17 15:07:14,538 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-07-17 15:07:14,540 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] parallel execution is enabled: true
2015-07-17 15:07:14,540 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flows: 4
2015-07-17 15:07:14,540 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] allocating threads: 4
2015-07-17 15:07:14,541 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-07-17 15:07:14,542 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-07-17 15:07:14,542 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
testing if running
2015-07-17 15:07:14,546 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:07:14,546 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 15:07:14,546 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic"]
2015-07-17 15:07:14,546 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:07:14,547 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:07:14,547 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:07:14,548 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2015-07-17 15:07:14,699 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437170598144_0010
2015-07-17 15:07:14,699 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_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
testing if running
testing if running
2015-07-17 15:07:31,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0010_01_000004 is : 143
2015-07-17 15:07:31,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0010_01_000005 is : 143
2015-07-17 15:07:32,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0010_01_000003 is : 143
2015-07-17 15:07:32,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0010_01_000002 is : 143
calling stop
2015-07-17 15:07:32,617 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping all flows
2015-07-17 15:07:32,617 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: fourth
2015-07-17 15:07:32,618 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-07-17 15:07:32,618 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2015-07-17 15:07:32,619 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-07-17 15:07:32,619 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: third
2015-07-17 15:07:32,619 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-07-17 15:07:32,619 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2015-07-17 15:07:32,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-07-17 15:07:32,620 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: second
2015-07-17 15:07:32,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-07-17 15:07:32,620 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...d/second-nondeterministic
2015-07-17 15:07:32,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-07-17 15:07:32,621 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: first
2015-07-17 15:07:32,621 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-07-17 15:07:32,622 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2015-07-17 15:07:33,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-07-17 15:07:33,645 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutting down job executor
2015-07-17 15:07:33,679 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutdown complete
2015-07-17 15:07:33,679 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopped all flows
2015-07-17 15:07:33,680 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutting down flow executor
2015-07-17 15:07:33,680 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] completed flow: first
2015-07-17 15:07:33,681 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutdown complete
2015-07-17 15:07:33,682 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/stopped/fourth-nondeterministic
2015-07-17 15:07:33,684 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/stopped/third-nondeterministic
2015-07-17 15:07:33,685 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic
2015-07-17 15:07:33,708 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/stopped/second-nondeterministic
2015-07-17 15:07:33,722 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:33,723 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:33,747 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:33,748 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:33,766 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:33,767 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:33,791 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:07:33,791 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:07:33,800 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-07-17 15:07:33,801 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] parallel execution is enabled: true
2015-07-17 15:07:33,801 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flows: 4
2015-07-17 15:07:33,801 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] allocating threads: 4
2015-07-17 15:07:33,802 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-07-17 15:07:33,802 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-07-17 15:07:33,803 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:07:33,805 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:07:33,805 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-17 15:07:33,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-07-17 15:07:33,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:07:33,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:07:33,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:07:33,807 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...le/firsttestSimpleCascade
2015-07-17 15:07:33,921 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437170598144_0011
2015-07-17 15:07:33,921 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0011/
2015-07-17 15:07:49,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0011_01_000002 is : 143
2015-07-17 15:07:49,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0011_01_000005 is : 143
2015-07-17 15:07:49,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0011_01_000003 is : 143
2015-07-17 15:07:49,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0011_01_000004 is : 143
2015-07-17 15:07:50,695 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade/_temporary
2015-07-17 15:07:50,696 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: first
2015-07-17 15:07:50,696 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: second
2015-07-17 15:07:50,697 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-07-17 15:07:50,697 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:07:50,699 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-07-17 15:07:50,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-07-17 15:07:50,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-07-17 15:07:50,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-07-17 15:07:50,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-07-17 15:07:50,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-07-17 15:07:50,701 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...e/secondtestSimpleCascade
2015-07-17 15:07:50,835 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1437170598144_0012
2015-07-17 15:07:50,835 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0012/
2015-07-17 15:08:12,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0012_01_000002 is : 143
2015-07-17 15:08:12,797 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0012_01_000003 is : 143
2015-07-17 15:08:12,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0012_01_000006 is : 143
2015-07-17 15:08:12,961 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0012_01_000004 is : 143
2015-07-17 15:08:13,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0012_01_000005 is : 143
2015-07-17 15:08:14,371 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade/_temporary
2015-07-17 15:08:14,372 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: second
2015-07-17 15:08:14,372 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: third
2015-07-17 15:08:14,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-07-17 15:08:14,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:08:14,375 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-07-17 15:08:14,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-07-17 15:08:14,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-07-17 15:08:14,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-07-17 15:08:14,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-07-17 15:08:14,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-07-17 15:08:14,380 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...le/thirdtestSimpleCascade
2015-07-17 15:08:14,508 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1437170598144_0013
2015-07-17 15:08:14,508 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0013/
2015-07-17 15:08:33,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0013_01_000006 is : 143
2015-07-17 15:08:33,711 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0013_01_000007 is : 143
2015-07-17 15:08:33,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0013_01_000004 is : 143
2015-07-17 15:08:34,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0013_01_000002 is : 143
2015-07-17 15:08:34,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0013_01_000003 is : 143
2015-07-17 15:08:34,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0013_01_000005 is : 143
2015-07-17 15:08:35,468 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade/_temporary
2015-07-17 15:08:35,469 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: third
2015-07-17 15:08:35,470 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: fourth
2015-07-17 15:08:35,470 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-07-17 15:08:35,470 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:08:35,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-07-17 15:08:35,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-07-17 15:08:35,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade"]
2015-07-17 15:08:35,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-07-17 15:08:35,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-07-17 15:08:35,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-07-17 15:08:35,479 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...e/fourthtestSimpleCascade
2015-07-17 15:08:35,605 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1437170598144_0014
2015-07-17 15:08:35,605 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Marks-MacBook.local:55379/proxy/application_1437170598144_0014/
2015-07-17 15:08:40,574 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437170598144_0013_01_000001
2015-07-17 15:09:01,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000006 is : 143
2015-07-17 15:09:01,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000008 is : 143
2015-07-17 15:09:01,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000007 is : 143
2015-07-17 15:09:01,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000005 is : 143
2015-07-17 15:09:01,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000003 is : 143
2015-07-17 15:09:02,137 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000002 is : 143
2015-07-17 15:09:02,174 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437170598144_0014_01_000004 is : 143
2015-07-17 15:09:03,394 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade/_temporary
2015-07-17 15:09:03,395 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: fourth
2015-07-17 15:09:03,420 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade
2015-07-17 15:09:03,446 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade
2015-07-17 15:09:03,478 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade
2015-07-17 15:09:03,507 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade
2015-07-17 15:09:03,550 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:09:03,550 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:09:03,574 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:09:03,574 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:09:03,603 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:09:03,603 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:09:03,623 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:09:03,624 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:09:03,636 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/idtest/fourth
2015-07-17 15:09:03,638 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/idtest/first
2015-07-17 15:09:03,639 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/idtest/third
2015-07-17 15:09:03,640 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadeplatform/idtest/second
2015-07-17 15:09:03,653 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:09:03,653 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:09:03,692 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:09:03,693 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar