Class cascading.cascade.ParallelCascadePlatformTest

2

tests

0

failures

0

ignored

3m45.11s

duration

100%

successful

Tests

Test Duration Result
testCascade 3m15.90s passed
testCascadeRaceCondition 29.212s passed

Standard output

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

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
Jul 21, 2015 12:12:08 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jul 21, 2015 12:12:08 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 12:12:08 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 12:12:08 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 12:12:08 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:08 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Jul 21, 2015 12:12:09 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 12:12:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 12:12:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jul 21, 2015 12:12:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 12:12:09 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 12:12:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:10 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 12:12:10 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:11 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 12:12:11 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:11 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:12 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 12:12:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 12:12:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 12:12:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 12:12:12 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 12:12:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:12 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:13 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 12:12:13 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.