2015-07-17 15:12:59,713 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:12:59,732 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:12:59,733 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.hadoop.RiffleCascadePlatformTest
2015-07-17 15:12:59,752 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 15:13:00,604 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:13:01,154 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 15:13:05,167 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:13:05,410 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:13:05,621 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:13:05,849 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:13:22,957 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-07-17 15:13:23,034 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 250954052FF44BAF9B816101209D0AD1
2015-07-17 15:13:23,076 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/rifflecascadeplatform/children/first
2015-07-17 15:13:23,096 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/rifflecascadeplatform/stopException/first
2015-07-17 15:13:23,127 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:13:23,129 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:13:23,227 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:13:23,227 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:13:23,267 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:13:23,268 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:13:23,303 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:13:23,303 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:13:23,379 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:13:23,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:13:23,381 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:13:23,381 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/rifflecascadeplatform/perpetual/first"]
2015-07-17 15:13:23,382 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:13:23,382 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:13:23,382 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:13:23,384 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...eplatform/perpetual/first
2015-07-17 15:13:24,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437171197445_0001
2015-07-17 15:13:24,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0001/
2015-07-17 15:13:38,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0001_01_000003 is : 143
2015-07-17 15:13:38,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0001_01_000002 is : 143
2015-07-17 15:13:39,134 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0001_01_000005 is : 143
2015-07-17 15:13:39,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0001_01_000004 is : 143
2015-07-17 15:13:40,554 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/rifflecascadeplatform/perpetual/first/_temporary
2015-07-17 15:13:40,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-07-17 15:13:40,559 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/rifflecascadeplatform/perpetual/first"]
2015-07-17 15:13:40,559 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/rifflecascadeplatform/perpetual/second"]
2015-07-17 15:13:40,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-07-17 15:13:40,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-07-17 15:13:40,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-07-17 15:13:40,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...platform/perpetual/second
2015-07-17 15:13:40,741 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1437171197445_0002
2015-07-17 15:13:40,741 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0002/
2015-07-17 15:13:56,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0002_01_000002 is : 143
2015-07-17 15:13:56,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0002_01_000004 is : 143
2015-07-17 15:13:56,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0002_01_000006 is : 143
2015-07-17 15:13:56,916 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0002_01_000003 is : 143
2015-07-17 15:13:57,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0002_01_000005 is : 143
2015-07-17 15:13:58,334 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/rifflecascadeplatform/perpetual/second/_temporary
2015-07-17 15:13:58,341 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-07-17 15:13:58,342 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/rifflecascadeplatform/perpetual/second"]
2015-07-17 15:13:58,342 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/rifflecascadeplatform/perpetual/third"]
2015-07-17 15:13:58,342 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-07-17 15:13:58,342 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-07-17 15:13:58,342 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-07-17 15:13:58,343 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...eplatform/perpetual/third
2015-07-17 15:13:58,496 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1437171197445_0003
2015-07-17 15:13:58,496 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0003/
2015-07-17 15:14:16,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0003_01_000007 is : 143
2015-07-17 15:14:16,724 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0003_01_000003 is : 143
2015-07-17 15:14:16,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0003_01_000002 is : 143
2015-07-17 15:14:16,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0003_01_000004 is : 143
2015-07-17 15:14:17,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0003_01_000006 is : 143
2015-07-17 15:14:17,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0003_01_000005 is : 143
2015-07-17 15:14:18,284 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/rifflecascadeplatform/perpetual/third/_temporary
2015-07-17 15:14:18,290 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-07-17 15:14:18,290 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/rifflecascadeplatform/perpetual/third"]
2015-07-17 15:14:18,290 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/rifflecascadeplatform/perpetual/fourth"]
2015-07-17 15:14:18,290 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-07-17 15:14:18,291 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-07-17 15:14:18,291 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-07-17 15:14:18,292 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...platform/perpetual/fourth
2015-07-17 15:14:18,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1437171197445_0004
2015-07-17 15:14:18,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0004/
2015-07-17 15:14:38,107 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000002 is : 143
2015-07-17 15:14:38,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000003 is : 143
2015-07-17 15:14:38,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000007 is : 143
2015-07-17 15:14:38,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000005 is : 143
2015-07-17 15:14:38,585 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000008 is : 143
2015-07-17 15:14:38,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000006 is : 143
2015-07-17 15:14:38,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0004_01_000004 is : 143
2015-07-17 15:14:40,013 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/rifflecascadeplatform/perpetual/fourth/_temporary
2015-07-17 15:14:40,049 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/rifflecascadeplatform/perpetual/third
2015-07-17 15:14:40,076 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/rifflecascadeplatform/perpetual/fourth
2015-07-17 15:14:40,104 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/rifflecascadeplatform/perpetual/first
2015-07-17 15:14:40,123 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/rifflecascadeplatform/perpetual/second
2015-07-17 15:14:40,167 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:14:40,168 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:14:40,195 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:14:40,196 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:14:40,221 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:14:40,221 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:14:40,253 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:14:40,253 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:14:40,324 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting
2015-07-17 15:14:40,325 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] parallel execution is enabled: false
2015-07-17 15:14:40,325 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flows: 4
2015-07-17 15:14:40,325 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] allocating threads: 1
2015-07-17 15:14:40,326 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: first
2015-07-17 15:14:40,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-07-17 15:14:40,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:14:40,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-07-17 15:14:40,334 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:14:40,334 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/rifflecascadeplatform/perpetualcascade/first"]
2015-07-17 15:14:40,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-07-17 15:14:40,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-07-17 15:14:40,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-07-17 15:14:40,335 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...rm/perpetualcascade/first
2015-07-17 15:14:40,476 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1437171197445_0005
2015-07-17 15:14:40,476 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0005/
2015-07-17 15:14:54,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0005_01_000003 is : 143
2015-07-17 15:14:54,278 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0005_01_000002 is : 143
2015-07-17 15:14:54,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0005_01_000004 is : 143
2015-07-17 15:14:54,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0005_01_000005 is : 143
2015-07-17 15:14:55,815 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/rifflecascadeplatform/perpetualcascade/first/_temporary
2015-07-17 15:14:55,816 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: first
2015-07-17 15:14:55,816 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: second
2015-07-17 15:14:55,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-07-17 15:14:55,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:14:55,820 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-07-17 15:14:55,821 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/rifflecascadeplatform/perpetualcascade/first"]
2015-07-17 15:14:55,821 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/rifflecascadeplatform/perpetualcascade/second"]
2015-07-17 15:14:55,821 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-07-17 15:14:55,821 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-07-17 15:14:55,821 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-07-17 15:14:55,822 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...m/perpetualcascade/second
2015-07-17 15:14:55,963 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1437171197445_0006
2015-07-17 15:14:55,964 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0006/
2015-07-17 15:15:12,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0006_01_000002 is : 143
2015-07-17 15:15:12,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0006_01_000003 is : 143
2015-07-17 15:15:12,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0006_01_000005 is : 143
2015-07-17 15:15:12,555 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0006_01_000006 is : 143
2015-07-17 15:15:12,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0006_01_000004 is : 143
2015-07-17 15:15:13,830 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/rifflecascadeplatform/perpetualcascade/second/_temporary
2015-07-17 15:15:13,831 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: second
2015-07-17 15:15:13,832 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: third
2015-07-17 15:15:13,832 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-07-17 15:15:13,832 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:15:13,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-07-17 15:15:13,837 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/rifflecascadeplatform/perpetualcascade/second"]
2015-07-17 15:15:13,837 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/rifflecascadeplatform/perpetualcascade/third"]
2015-07-17 15:15:13,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-07-17 15:15:13,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-07-17 15:15:13,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-07-17 15:15:13,839 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...rm/perpetualcascade/third
2015-07-17 15:15:13,955 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1437171197445_0007
2015-07-17 15:15:13,955 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0007/
2015-07-17 15:15:32,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0007_01_000004 is : 143
2015-07-17 15:15:32,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0007_01_000002 is : 143
2015-07-17 15:15:32,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0007_01_000007 is : 143
2015-07-17 15:15:32,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0007_01_000005 is : 143
2015-07-17 15:15:32,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0007_01_000006 is : 143
2015-07-17 15:15:32,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0007_01_000003 is : 143
2015-07-17 15:15:33,977 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/rifflecascadeplatform/perpetualcascade/third/_temporary
2015-07-17 15:15:33,978 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: third
2015-07-17 15:15:33,979 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: fourth
2015-07-17 15:15:33,979 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-07-17 15:15:33,979 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:15:33,983 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-07-17 15:15:33,984 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/rifflecascadeplatform/perpetualcascade/third"]
2015-07-17 15:15:33,984 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/rifflecascadeplatform/perpetualcascade/fourth"]
2015-07-17 15:15:33,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-07-17 15:15:33,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-07-17 15:15:33,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-07-17 15:15:33,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...m/perpetualcascade/fourth
2015-07-17 15:15:34,105 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1437171197445_0008
2015-07-17 15:15:34,105 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Marks-MacBook.local:58023/proxy/application_1437171197445_0008/
2015-07-17 15:15:54,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000008 is : 143
2015-07-17 15:15:54,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000002 is : 143
2015-07-17 15:15:54,247 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000003 is : 143
2015-07-17 15:15:54,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000005 is : 143
2015-07-17 15:15:54,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000007 is : 143
2015-07-17 15:15:54,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000006 is : 143
2015-07-17 15:15:54,544 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171197445_0008_01_000004 is : 143
2015-07-17 15:15:55,735 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/rifflecascadeplatform/perpetualcascade/fourth/_temporary
2015-07-17 15:15:55,736 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: fourth
2015-07-17 15:15:55,762 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/rifflecascadeplatform/perpetualcascade/second
2015-07-17 15:15:55,784 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/rifflecascadeplatform/perpetualcascade/first
2015-07-17 15:15:55,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/rifflecascadeplatform/perpetualcascade/third
2015-07-17 15:15:55,828 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/rifflecascadeplatform/perpetualcascade/fourth
2015-07-17 15:15:55,870 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/rifflecascadeplatform/counter/first
2015-07-17 15:15:55,884 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/rifflecascadeplatform/completeException/first
2015-07-17 15:15:55,905 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/rifflecascadeplatform/startException/first