2015-07-21 12:11:50,842 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 12:11:50,860 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-mr1
2015-07-21 12:11:50,881 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-07-21 12:11:51,716 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-21 12:11:52,181 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-21 12:11:55,958 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-21 12:11:56,203 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-21 12:11:56,404 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-21 12:11:56,611 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-21 12:12:13,770 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-07-21 12:12:13,857 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:13,858 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:13,906 INFO property.AppProps (AppProps.java:getAppID(174)) - using app.id: 97EA846193D8401AA9EA68A93BA42DFF
2015-07-21 12:12:13,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2015-07-21 12:12:13,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:13,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:14,073 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2015-07-21 12:12:14,073 INFO util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 12:12:14,073 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2015-07-21 12:12:14,074 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2015-07-21 12:12:14,091 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:14,092 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:14,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-07-21 12:12:14,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:14,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:14,141 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2015-07-21 12:12:14,143 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] parallel execution of flows is enabled: false
2015-07-21 12:12:14,143 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] executing total flows: 1
2015-07-21 12:12:14,143 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] allocating management threads: 1
2015-07-21 12:12:14,144 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2015-07-21 12:12:14,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] at least one sink is marked for delete
2015-07-21 12:12:14,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:14,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] starting
2015-07-21 12:12:14,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:14,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic"]
2015-07-21 12:12:14,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] parallel execution of steps is enabled: true
2015-07-21 12:12:14,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] executing total steps: 1
2015-07-21 12:12:14,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] allocating management threads: 1
2015-07-21 12:12:14,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] starting step: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:14,205 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2015-07-21 12:12:14,206 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2015-07-21 12:12:14,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopping all jobs
2015-07-21 12:12:14,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:14,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopped all jobs
2015-07-21 12:12:14,209 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] shutting down job executor
2015-07-21 12:12:14,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] submitted hadoop job: job_1437505928251_0001
2015-07-21 12:12:14,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0001/
2015-07-21 12:12:14,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] shutdown complete
2015-07-21 12:12:14,998 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2015-07-21 12:12:14,998 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2015-07-21 12:12:15,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] completed in: 00:00.042
2015-07-21 12:12:15,014 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2015-07-21 12:12:15,014 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2015-07-21 12:12:15,038 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:15,039 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:15,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-07-21 12:12:15,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:15,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:15,101 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2015-07-21 12:12:15,104 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:15,104 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] executing total flows: 1
2015-07-21 12:12:15,104 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] allocating management threads: 1
2015-07-21 12:12:15,105 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2015-07-21 12:12:15,105 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:15,106 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:15,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] starting
2015-07-21 12:12:15,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:15,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2015-07-21 12:12:15,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:15,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] executing total steps: 1
2015-07-21 12:12:15,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] allocating management threads: 1
2015-07-21 12:12:15,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:15,211 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2015-07-21 12:12:15,212 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2015-07-21 12:12:15,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopping all jobs
2015-07-21 12:12:15,213 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:15,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopped all jobs
2015-07-21 12:12:15,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] shutting down job executor
2015-07-21 12:12:15,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] submitted hadoop job: job_1437505928251_0002
2015-07-21 12:12:15,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0002/
2015-07-21 12:12:15,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] shutdown complete
2015-07-21 12:12:15,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] completed in: 00:00.098
2015-07-21 12:12:15,466 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2015-07-21 12:12:15,467 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2015-07-21 12:12:15,466 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2015-07-21 12:12:15,467 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2015-07-21 12:12:15,490 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:15,491 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:15,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-07-21 12:12:15,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:15,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:15,554 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2015-07-21 12:12:15,555 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:15,555 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] executing total flows: 1
2015-07-21 12:12:15,555 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] allocating management threads: 1
2015-07-21 12:12:15,556 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2015-07-21 12:12:15,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:15,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:15,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] starting
2015-07-21 12:12:15,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:15,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2015-07-21 12:12:15,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:15,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] executing total steps: 1
2015-07-21 12:12:15,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] allocating management threads: 1
2015-07-21 12:12:15,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:15,708 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2015-07-21 12:12:15,709 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2015-07-21 12:12:15,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopping all jobs
2015-07-21 12:12:15,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:15,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopped all jobs
2015-07-21 12:12:15,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] shutting down job executor
2015-07-21 12:12:15,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] submitted hadoop job: job_1437505928251_0003
2015-07-21 12:12:15,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0003/
2015-07-21 12:12:15,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] shutdown complete
2015-07-21 12:12:15,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] completed in: 00:00.147
2015-07-21 12:12:15,823 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2015-07-21 12:12:15,823 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2015-07-21 12:12:15,845 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:15,845 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:15,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-07-21 12:12:15,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:15,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:15,891 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2015-07-21 12:12:15,892 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:15,892 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] executing total flows: 1
2015-07-21 12:12:15,892 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] allocating management threads: 1
2015-07-21 12:12:15,893 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2015-07-21 12:12:15,893 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:15,893 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:15,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] starting
2015-07-21 12:12:15,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:15,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2015-07-21 12:12:15,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:15,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] executing total steps: 1
2015-07-21 12:12:15,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] allocating management threads: 1
2015-07-21 12:12:15,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:16,094 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2015-07-21 12:12:16,096 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2015-07-21 12:12:16,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopping all jobs
2015-07-21 12:12:16,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:16,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopped all jobs
2015-07-21 12:12:16,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] shutting down job executor
2015-07-21 12:12:16,152 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] submitted hadoop job: job_1437505928251_0004
2015-07-21 12:12:16,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0004/
2015-07-21 12:12:16,213 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] completed in: 00:00.197
2015-07-21 12:12:16,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] shutdown complete
2015-07-21 12:12:16,215 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2015-07-21 12:12:16,215 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2015-07-21 12:12:16,216 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2015-07-21 12:12:16,217 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2015-07-21 12:12:16,244 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:16,245 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:16,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-07-21 12:12:16,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:16,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:16,306 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2015-07-21 12:12:16,307 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:16,307 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] executing total flows: 1
2015-07-21 12:12:16,308 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] allocating management threads: 1
2015-07-21 12:12:16,308 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2015-07-21 12:12:16,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:16,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:16,317 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] starting
2015-07-21 12:12:16,317 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:16,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2015-07-21 12:12:16,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:16,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] executing total steps: 1
2015-07-21 12:12:16,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] allocating management threads: 1
2015-07-21 12:12:16,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:16,556 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2015-07-21 12:12:16,557 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2015-07-21 12:12:16,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopping all jobs
2015-07-21 12:12:16,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:16,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopped all jobs
2015-07-21 12:12:16,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] shutting down job executor
2015-07-21 12:12:16,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] submitted hadoop job: job_1437505928251_0005
2015-07-21 12:12:16,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0005/
2015-07-21 12:12:16,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] completed in: 00:00.241
2015-07-21 12:12:16,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] shutdown complete
2015-07-21 12:12:16,591 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2015-07-21 12:12:16,591 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2015-07-21 12:12:16,621 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:16,621 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:16,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-07-21 12:12:16,656 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:16,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:16,670 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2015-07-21 12:12:16,671 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:16,672 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] executing total flows: 1
2015-07-21 12:12:16,672 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] allocating management threads: 1
2015-07-21 12:12:16,672 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2015-07-21 12:12:16,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:16,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:16,678 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] starting
2015-07-21 12:12:16,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:16,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2015-07-21 12:12:16,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:16,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] executing total steps: 1
2015-07-21 12:12:16,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] allocating management threads: 1
2015-07-21 12:12:16,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:16,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] submitted hadoop job: job_1437505928251_0006
2015-07-21 12:12:16,885 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0006/
2015-07-21 12:12:16,971 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2015-07-21 12:12:16,972 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2015-07-21 12:12:16,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopping all jobs
2015-07-21 12:12:16,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:16,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] completed in: 00:00.294
2015-07-21 12:12:17,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopped all jobs
2015-07-21 12:12:17,194 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2015-07-21 12:12:17,195 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2015-07-21 12:12:17,194 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2015-07-21 12:12:17,195 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2015-07-21 12:12:17,217 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:17,218 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:17,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-07-21 12:12:17,252 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:17,252 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:17,263 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2015-07-21 12:12:17,264 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:17,264 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] executing total flows: 1
2015-07-21 12:12:17,264 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] allocating management threads: 1
2015-07-21 12:12:17,265 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2015-07-21 12:12:17,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:17,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:17,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] starting
2015-07-21 12:12:17,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:17,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2015-07-21 12:12:17,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:17,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] executing total steps: 1
2015-07-21 12:12:17,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] allocating management threads: 1
2015-07-21 12:12:17,273 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:17,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] submitted hadoop job: job_1437505928251_0007
2015-07-21 12:12:17,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0007/
2015-07-21 12:12:17,618 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2015-07-21 12:12:17,619 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2015-07-21 12:12:17,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopping all jobs
2015-07-21 12:12:17,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:17,831 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopped all jobs
2015-07-21 12:12:17,831 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] shutting down job executor
2015-07-21 12:12:17,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] shutdown complete
2015-07-21 12:12:17,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] completed in: 00:00.349
2015-07-21 12:12:17,834 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2015-07-21 12:12:17,835 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2015-07-21 12:12:17,835 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2015-07-21 12:12:17,836 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2015-07-21 12:12:17,861 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:17,861 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:17,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-07-21 12:12:17,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:17,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:17,907 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2015-07-21 12:12:17,908 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:17,908 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] executing total flows: 1
2015-07-21 12:12:17,908 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] allocating management threads: 1
2015-07-21 12:12:17,909 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2015-07-21 12:12:17,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:17,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:17,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] starting
2015-07-21 12:12:17,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:17,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2015-07-21 12:12:17,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:17,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] executing total steps: 1
2015-07-21 12:12:17,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] allocating management threads: 1
2015-07-21 12:12:17,916 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:18,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] submitted hadoop job: job_1437505928251_0008
2015-07-21 12:12:18,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0008/
2015-07-21 12:12:18,307 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2015-07-21 12:12:18,309 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2015-07-21 12:12:18,310 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopping all jobs
2015-07-21 12:12:18,314 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:18,523 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopped all jobs
2015-07-21 12:12:18,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] shutting down job executor
2015-07-21 12:12:18,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] shutdown complete
2015-07-21 12:12:18,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] completed in: 00:00.396
2015-07-21 12:12:18,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2015-07-21 12:12:18,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2015-07-21 12:12:18,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2015-07-21 12:12:18,531 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2015-07-21 12:12:18,555 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:18,555 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:18,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-07-21 12:12:18,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:18,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:18,601 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2015-07-21 12:12:18,602 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:18,602 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] executing total flows: 1
2015-07-21 12:12:18,602 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] allocating management threads: 1
2015-07-21 12:12:18,603 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2015-07-21 12:12:18,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:18,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:18,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] starting
2015-07-21 12:12:18,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:18,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2015-07-21 12:12:18,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:18,610 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] executing total steps: 1
2015-07-21 12:12:18,610 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] allocating management threads: 1
2015-07-21 12:12:18,611 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:18,804 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] submitted hadoop job: job_1437505928251_0009
2015-07-21 12:12:18,805 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0009/
2015-07-21 12:12:19,053 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2015-07-21 12:12:19,054 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2015-07-21 12:12:19,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopping all jobs
2015-07-21 12:12:19,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-07-21 12:12:19,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopped all jobs
2015-07-21 12:12:19,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] shutting down job executor
2015-07-21 12:12:19,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] shutdown complete
2015-07-21 12:12:19,273 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2015-07-21 12:12:19,273 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2015-07-21 12:12:19,273 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] completed in: 00:00.446
2015-07-21 12:12:19,274 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2015-07-21 12:12:19,274 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2015-07-21 12:12:19,301 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:19,302 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:19,344 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-07-21 12:12:19,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:19,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:19,357 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2015-07-21 12:12:19,358 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] parallel execution of flows is enabled: false
2015-07-21 12:12:19,358 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] executing total flows: 1
2015-07-21 12:12:19,358 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] allocating management threads: 1
2015-07-21 12:12:19,359 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2015-07-21 12:12:19,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] at least one sink is marked for delete
2015-07-21 12:12:19,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:19,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] starting
2015-07-21 12:12:19,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:19,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2015-07-21 12:12:19,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] parallel execution of steps is enabled: true
2015-07-21 12:12:19,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] executing total steps: 1
2015-07-21 12:12:19,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] allocating management threads: 1
2015-07-21 12:12:19,372 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:19,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] submitted hadoop job: job_1437505928251_0010
2015-07-21 12:12:19,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0010/
2015-07-21 12:12:19,859 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2015-07-21 12:12:19,863 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2015-07-21 12:12:19,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopping all jobs
2015-07-21 12:12:19,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-07-21 12:12:20,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopped all jobs
2015-07-21 12:12:20,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] shutting down job executor
2015-07-21 12:12:20,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] shutdown complete
2015-07-21 12:12:20,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] completed in: 00:00.497
2015-07-21 12:12:20,075 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2015-07-21 12:12:20,075 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2015-07-21 12:12:20,075 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2015-07-21 12:12:20,076 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2015-07-21 12:12:20,076 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2015-07-21 12:12:20,077 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2015-07-21 12:12:20,079 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2015-07-21 12:12:20,080 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2015-07-21 12:12:20,081 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2015-07-21 12:12:20,082 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2015-07-21 12:12:20,083 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2015-07-21 12:12:20,085 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2015-07-21 12:12:20,086 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2015-07-21 12:12:20,087 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2015-07-21 12:12:20,088 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2015-07-21 12:12:20,123 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:20,124 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:20,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-07-21 12:12:20,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:20,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:20,222 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:20,222 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:20,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 12:12:20,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:20,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:20,298 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:20,299 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:20,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 12:12:20,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:20,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:20,364 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:20,365 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:20,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 12:12:20,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:12:20,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:20,451 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:12:20,452 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:12:20,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-07-21 12:12:20,500 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 12:12:20,501 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:12:20,532 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2015-07-21 12:12:20,534 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] parallel execution of flows is enabled: true
2015-07-21 12:12:20,535 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] executing total flows: 5
2015-07-21 12:12:20,535 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] allocating management threads: 5
2015-07-21 12:12:20,535 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2015-07-21 12:12:20,536 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2015-07-21 12:12:20,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] at least one sink is marked for delete
2015-07-21 12:12:20,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:20,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] at least one sink is marked for delete
2015-07-21 12:12:20,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:12:20,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] starting
2015-07-21 12:12:20,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:20,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] starting
2015-07-21 12:12:20,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/ips.20.txt"]
2015-07-21 12:12:20,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] parallel execution of steps is enabled: true
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] executing total steps: 1
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] allocating management threads: 1
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] parallel execution of steps is enabled: true
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] executing total steps: 1
2015-07-21 12:12:20,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] allocating management threads: 1
2015-07-21 12:12:20,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2015-07-21 12:12:20,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2015-07-21 12:12:20,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] submitted hadoop job: job_1437505928251_0011
2015-07-21 12:12:20,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0011/
2015-07-21 12:12:20,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] submitted hadoop job: job_1437505928251_0012
2015-07-21 12:12:20,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0012/
2015-07-21 12:12:46,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0001_01_000005 is : 143
2015-07-21 12:12:46,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0001_01_000003 is : 143
2015-07-21 12:12:46,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0001_01_000004 is : 143
2015-07-21 12:12:46,643 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0001_01_000002 is : 143
2015-07-21 12:12:47,190 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0002_01_000004 is : 143
2015-07-21 12:12:47,419 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0002_01_000005 is : 143
2015-07-21 12:12:47,485 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0002_01_000003 is : 143
2015-07-21 12:12:47,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0002_01_000002 is : 143
2015-07-21 12:13:20,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0003_01_000002 is : 143
2015-07-21 12:13:20,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0003_01_000004 is : 143
2015-07-21 12:13:20,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0003_01_000005 is : 143
2015-07-21 12:13:21,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0003_01_000003 is : 143
2015-07-21 12:13:21,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0004_01_000004 is : 143
2015-07-21 12:13:21,779 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0004_01_000002 is : 143
2015-07-21 12:13:21,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0004_01_000005 is : 143
2015-07-21 12:13:22,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0004_01_000003 is : 143
2015-07-21 12:13:55,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0005_01_000005 is : 143
2015-07-21 12:13:55,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0005_01_000003 is : 143
2015-07-21 12:13:55,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0005_01_000004 is : 143
2015-07-21 12:13:55,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0005_01_000002 is : 143
2015-07-21 12:13:56,851 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0011_01_000002 is : 143
2015-07-21 12:13:57,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0011_01_000003 is : 143
2015-07-21 12:13:57,389 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0011_01_000005 is : 143
2015-07-21 12:13:57,501 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0011_01_000004 is : 143
2015-07-21 12:13:58,735 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1/_temporary
2015-07-21 12:13:58,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] completed in: 01:38.188
2015-07-21 12:13:58,740 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2015-07-21 12:13:58,740 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2015-07-21 12:13:58,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] at least one sink is marked for delete
2015-07-21 12:13:58,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:13:58,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] starting
2015-07-21 12:13:58,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2015-07-21 12:13:58,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2015-07-21 12:13:58,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] parallel execution of steps is enabled: true
2015-07-21 12:13:58,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] executing total steps: 1
2015-07-21 12:13:58,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] allocating management threads: 1
2015-07-21 12:13:58,744 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2015-07-21 12:13:58,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] submitted hadoop job: job_1437505928251_0013
2015-07-21 12:13:58,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0013/
2015-07-21 12:14:31,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0012_01_000002 is : 143
2015-07-21 12:14:31,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0012_01_000003 is : 143
2015-07-21 12:14:31,886 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0012_01_000005 is : 143
2015-07-21 12:14:32,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0012_01_000004 is : 143
2015-07-21 12:14:33,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0013_01_000005 is : 143
2015-07-21 12:14:33,210 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0013_01_000004 is : 143
2015-07-21 12:14:33,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0013_01_000003 is : 143
2015-07-21 12:14:33,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0013_01_000006 is : 143
2015-07-21 12:14:33,429 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2/_temporary
2015-07-21 12:14:33,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] completed in: 02:12.885
2015-07-21 12:14:33,433 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2015-07-21 12:14:33,433 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2015-07-21 12:14:33,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] at least one sink is marked for delete
2015-07-21 12:14:33,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:14:33,437 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] starting
2015-07-21 12:14:33,437 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2015-07-21 12:14:33,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2015-07-21 12:14:33,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] parallel execution of steps is enabled: true
2015-07-21 12:14:33,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] executing total steps: 1
2015-07-21 12:14:33,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] allocating management threads: 1
2015-07-21 12:14:33,439 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2015-07-21 12:14:33,571 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0013_01_000002 is : 143
2015-07-21 12:14:33,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] submitted hadoop job: job_1437505928251_0014
2015-07-21 12:14:33,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0014/
2015-07-21 12:14:34,797 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1/_temporary
2015-07-21 12:14:34,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] completed in: 00:36.053
2015-07-21 12:14:34,798 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2015-07-21 12:14:57,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0014_01_000004 is : 143
2015-07-21 12:14:57,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0014_01_000003 is : 143
2015-07-21 12:14:57,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0014_01_000006 is : 143
2015-07-21 12:14:57,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0014_01_000005 is : 143
2015-07-21 12:14:57,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0014_01_000002 is : 143
2015-07-21 12:14:58,635 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2/_temporary
2015-07-21 12:14:58,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] completed in: 00:25.197
2015-07-21 12:14:58,636 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2015-07-21 12:14:58,637 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2015-07-21 12:14:58,637 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] at least one sink is marked for delete
2015-07-21 12:14:58,637 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:14:58,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-07-21 12:14:58,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2015-07-21 12:14:58,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2015-07-21 12:14:58,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third"]
2015-07-21 12:14:58,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2015-07-21 12:14:58,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2015-07-21 12:14:58,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2015-07-21 12:14:58,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2015-07-21 12:14:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1437505928251_0015
2015-07-21 12:14:58,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:61376/proxy/application_1437505928251_0015/
2015-07-21 12:15:27,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000004 is : 143
2015-07-21 12:15:28,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000011 is : 143
2015-07-21 12:15:28,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000009 is : 143
2015-07-21 12:15:28,491 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000007 is : 143
2015-07-21 12:15:28,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000002 is : 143
2015-07-21 12:15:28,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000006 is : 143
2015-07-21 12:15:28,685 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000005 is : 143
2015-07-21 12:15:28,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000003 is : 143
2015-07-21 12:15:28,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000010 is : 143
2015-07-21 12:15:28,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000008 is : 143
2015-07-21 12:15:34,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437505928251_0015_01_000012 is : 143
2015-07-21 12:15:35,835 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third/_temporary
2015-07-21 12:15:35,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:37.194
2015-07-21 12:15:35,838 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2015-07-21 12:15:35,867 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/third
2015-07-21 12:15:35,877 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first1
2015-07-21 12:15:35,900 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first2
2015-07-21 12:15:35,926 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second2
2015-07-21 12:15:35,953 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second1