2015-05-20 15:33:35,342 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 15:33:35,377 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 15:33:35,377 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.ParallelCascadePlatformTest
2015-05-20 15:33:35,392 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 15:33:36,000 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-05-20 15:33:36,536 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 15:33:39,811 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 15:33:40,081 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:33:40,314 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:33:40,524 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:33:40,747 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-05-20 15:33:57,926 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:33:57,927 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:33:57,932 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 34C679BB9E834B72BF8950BCF06D73CE
2015-05-20 15:33:58,022 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopping all flows
2015-05-20 15:33:58,022 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 15:33:58,023 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopped all flows
2015-05-20 15:33:58,024 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] starting
2015-05-20 15:33:58,039 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:33:58,040 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:33:58,053 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting
2015-05-20 15:33:58,054 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] parallel execution is enabled: true
2015-05-20 15:33:58,055 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flows: 1
2015-05-20 15:33:58,055 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] allocating threads: 1
2015-05-20 15:33:58,055 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2015-05-20 15:33:58,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] at least one sink is marked for delete
2015-05-20 15:33:58,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:33:58,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting
2015-05-20 15:33:58,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:33:58,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-50/first-nondeterministic"]
2015-05-20 15:33:58,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] parallel execution is enabled: true
2015-05-20 15:33:58,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting jobs: 1
2015-05-20 15:33:58,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] allocating threads: 1
2015-05-20 15:33:58,079 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] starting step: (1/1) ...50/first-nondeterministic
2015-05-20 15:33:58,105 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping all flows
2015-05-20 15:33:58,107 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2015-05-20 15:33:58,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopping all jobs
2015-05-20 15:33:58,109 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2015-05-20 15:33:58,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopped all jobs
2015-05-20 15:33:58,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutting down job executor
2015-05-20 15:33:58,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] submitted hadoop job: job_1432161232321_0001
2015-05-20 15:33:58,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0001/
2015-05-20 15:33:58,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutdown complete
2015-05-20 15:33:58,888 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopped all flows
2015-05-20 15:33:58,888 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutting down flow executor
2015-05-20 15:33:58,888 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2015-05-20 15:33:58,889 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutdown complete
2015-05-20 15:33:58,906 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:33:58,907 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:33:58,927 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting
2015-05-20 15:33:58,928 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] parallel execution is enabled: true
2015-05-20 15:33:58,928 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flows: 1
2015-05-20 15:33:58,928 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] allocating threads: 1
2015-05-20 15:33:58,929 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2015-05-20 15:33:58,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] at least one sink is marked for delete
2015-05-20 15:33:58,930 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:33:58,934 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting
2015-05-20 15:33:58,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:33:58,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-100/first-nondeterministic"]
2015-05-20 15:33:58,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] parallel execution is enabled: true
2015-05-20 15:33:58,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting jobs: 1
2015-05-20 15:33:58,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] allocating threads: 1
2015-05-20 15:33:58,936 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-05-20 15:33:59,030 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping all flows
2015-05-20 15:33:59,030 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2015-05-20 15:33:59,031 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopping all jobs
2015-05-20 15:33:59,032 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-05-20 15:33:59,032 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopped all jobs
2015-05-20 15:33:59,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutting down job executor
2015-05-20 15:33:59,156 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] submitted hadoop job: job_1432161232321_0002
2015-05-20 15:33:59,156 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0002/
2015-05-20 15:33:59,170 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutdown complete
2015-05-20 15:33:59,170 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopped all flows
2015-05-20 15:33:59,171 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2015-05-20 15:33:59,171 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutting down flow executor
2015-05-20 15:33:59,171 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutdown complete
2015-05-20 15:33:59,199 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:33:59,199 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:33:59,233 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting
2015-05-20 15:33:59,235 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] parallel execution is enabled: true
2015-05-20 15:33:59,236 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flows: 1
2015-05-20 15:33:59,236 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] allocating threads: 1
2015-05-20 15:33:59,237 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2015-05-20 15:33:59,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] at least one sink is marked for delete
2015-05-20 15:33:59,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:33:59,246 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting
2015-05-20 15:33:59,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:33:59,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-150/first-nondeterministic"]
2015-05-20 15:33:59,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] parallel execution is enabled: true
2015-05-20 15:33:59,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting jobs: 1
2015-05-20 15:33:59,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] allocating threads: 1
2015-05-20 15:33:59,249 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-05-20 15:33:59,383 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping all flows
2015-05-20 15:33:59,384 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2015-05-20 15:33:59,386 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopping all jobs
2015-05-20 15:33:59,390 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-05-20 15:33:59,391 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopped all jobs
2015-05-20 15:33:59,392 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutting down job executor
2015-05-20 15:33:59,603 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] submitted hadoop job: job_1432161232321_0003
2015-05-20 15:33:59,603 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0003/
2015-05-20 15:33:59,622 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutdown complete
2015-05-20 15:33:59,622 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopped all flows
2015-05-20 15:33:59,623 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutting down flow executor
2015-05-20 15:33:59,622 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2015-05-20 15:33:59,623 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutdown complete
2015-05-20 15:33:59,657 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:33:59,658 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:33:59,729 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting
2015-05-20 15:33:59,731 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] parallel execution is enabled: true
2015-05-20 15:33:59,732 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flows: 1
2015-05-20 15:33:59,732 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] allocating threads: 1
2015-05-20 15:33:59,732 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2015-05-20 15:33:59,734 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] at least one sink is marked for delete
2015-05-20 15:33:59,735 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:33:59,743 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting
2015-05-20 15:33:59,744 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:33:59,744 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-200/first-nondeterministic"]
2015-05-20 15:33:59,744 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] parallel execution is enabled: true
2015-05-20 15:33:59,745 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting jobs: 1
2015-05-20 15:33:59,745 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] allocating threads: 1
2015-05-20 15:33:59,747 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-05-20 15:33:59,930 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping all flows
2015-05-20 15:33:59,935 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2015-05-20 15:33:59,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopping all jobs
2015-05-20 15:33:59,938 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-05-20 15:33:59,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopped all jobs
2015-05-20 15:33:59,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutting down job executor
2015-05-20 15:34:00,225 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] submitted hadoop job: job_1432161232321_0004
2015-05-20 15:34:00,225 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0004/
2015-05-20 15:34:00,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutdown complete
2015-05-20 15:34:00,234 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopped all flows
2015-05-20 15:34:00,234 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2015-05-20 15:34:00,267 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:00,268 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:00,321 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting
2015-05-20 15:34:00,322 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:00,322 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flows: 1
2015-05-20 15:34:00,323 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] allocating threads: 1
2015-05-20 15:34:00,323 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2015-05-20 15:34:00,324 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] at least one sink is marked for delete
2015-05-20 15:34:00,324 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:00,340 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting
2015-05-20 15:34:00,340 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:00,340 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-250/first-nondeterministic"]
2015-05-20 15:34:00,341 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:00,341 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting jobs: 1
2015-05-20 15:34:00,341 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] allocating threads: 1
2015-05-20 15:34:00,349 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-05-20 15:34:00,602 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping all flows
2015-05-20 15:34:00,614 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2015-05-20 15:34:00,614 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopping all jobs
2015-05-20 15:34:00,616 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-05-20 15:34:00,618 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopped all jobs
2015-05-20 15:34:00,619 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutting down job executor
2015-05-20 15:34:00,878 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] submitted hadoop job: job_1432161232321_0005
2015-05-20 15:34:00,878 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0005/
2015-05-20 15:34:00,885 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutdown complete
2015-05-20 15:34:00,885 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopped all flows
2015-05-20 15:34:00,885 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2015-05-20 15:34:00,886 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutting down flow executor
2015-05-20 15:34:00,886 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutdown complete
2015-05-20 15:34:00,908 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:00,909 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:00,935 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting
2015-05-20 15:34:00,938 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:00,939 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flows: 1
2015-05-20 15:34:00,939 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] allocating threads: 1
2015-05-20 15:34:00,940 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2015-05-20 15:34:00,940 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] at least one sink is marked for delete
2015-05-20 15:34:00,940 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:00,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting
2015-05-20 15:34:00,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:00,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-300/first-nondeterministic"]
2015-05-20 15:34:00,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:00,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting jobs: 1
2015-05-20 15:34:00,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] allocating threads: 1
2015-05-20 15:34:00,950 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-05-20 15:34:01,236 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping all flows
2015-05-20 15:34:01,245 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2015-05-20 15:34:01,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopping all jobs
2015-05-20 15:34:01,246 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-05-20 15:34:01,246 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopped all jobs
2015-05-20 15:34:01,247 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutting down job executor
2015-05-20 15:34:01,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] submitted hadoop job: job_1432161232321_0006
2015-05-20 15:34:01,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0006/
2015-05-20 15:34:01,403 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutdown complete
2015-05-20 15:34:01,404 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopped all flows
2015-05-20 15:34:01,404 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2015-05-20 15:34:01,424 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:01,424 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:01,439 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting
2015-05-20 15:34:01,441 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:01,441 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flows: 1
2015-05-20 15:34:01,442 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] allocating threads: 1
2015-05-20 15:34:01,443 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2015-05-20 15:34:01,443 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] at least one sink is marked for delete
2015-05-20 15:34:01,443 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:01,451 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting
2015-05-20 15:34:01,452 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:01,452 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-350/first-nondeterministic"]
2015-05-20 15:34:01,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:01,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting jobs: 1
2015-05-20 15:34:01,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] allocating threads: 1
2015-05-20 15:34:01,455 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-05-20 15:34:01,717 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] submitted hadoop job: job_1432161232321_0007
2015-05-20 15:34:01,717 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0007/
2015-05-20 15:34:01,791 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping all flows
2015-05-20 15:34:01,793 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2015-05-20 15:34:01,793 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopping all jobs
2015-05-20 15:34:01,794 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-05-20 15:34:02,013 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopped all jobs
2015-05-20 15:34:02,013 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] shutting down job executor
2015-05-20 15:34:02,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] shutdown complete
2015-05-20 15:34:02,019 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopped all flows
2015-05-20 15:34:02,019 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2015-05-20 15:34:02,020 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutting down flow executor
2015-05-20 15:34:02,020 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutdown complete
2015-05-20 15:34:02,040 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:02,041 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:02,054 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting
2015-05-20 15:34:02,056 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:02,056 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flows: 1
2015-05-20 15:34:02,056 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] allocating threads: 1
2015-05-20 15:34:02,056 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2015-05-20 15:34:02,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] at least one sink is marked for delete
2015-05-20 15:34:02,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:02,066 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting
2015-05-20 15:34:02,066 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:02,067 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-400/first-nondeterministic"]
2015-05-20 15:34:02,067 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:02,067 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting jobs: 1
2015-05-20 15:34:02,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] allocating threads: 1
2015-05-20 15:34:02,070 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-05-20 15:34:02,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] submitted hadoop job: job_1432161232321_0008
2015-05-20 15:34:02,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0008/
2015-05-20 15:34:02,455 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping all flows
2015-05-20 15:34:02,456 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2015-05-20 15:34:02,457 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopping all jobs
2015-05-20 15:34:02,458 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-05-20 15:34:02,666 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopped all jobs
2015-05-20 15:34:02,666 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutting down job executor
2015-05-20 15:34:02,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutdown complete
2015-05-20 15:34:02,671 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopped all flows
2015-05-20 15:34:02,671 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2015-05-20 15:34:02,671 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutting down flow executor
2015-05-20 15:34:02,672 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutdown complete
2015-05-20 15:34:02,693 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:02,693 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:02,706 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting
2015-05-20 15:34:02,707 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:02,707 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flows: 1
2015-05-20 15:34:02,707 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] allocating threads: 1
2015-05-20 15:34:02,708 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2015-05-20 15:34:02,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] at least one sink is marked for delete
2015-05-20 15:34:02,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:02,715 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting
2015-05-20 15:34:02,716 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:02,716 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-450/first-nondeterministic"]
2015-05-20 15:34:02,716 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:02,716 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting jobs: 1
2015-05-20 15:34:02,716 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] allocating threads: 1
2015-05-20 15:34:02,719 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-05-20 15:34:02,944 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] submitted hadoop job: job_1432161232321_0009
2015-05-20 15:34:02,945 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0009/
2015-05-20 15:34:03,160 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping all flows
2015-05-20 15:34:03,161 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2015-05-20 15:34:03,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopping all jobs
2015-05-20 15:34:03,162 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-05-20 15:34:03,370 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopped all jobs
2015-05-20 15:34:03,370 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutting down job executor
2015-05-20 15:34:03,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutdown complete
2015-05-20 15:34:03,376 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopped all flows
2015-05-20 15:34:03,377 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutting down flow executor
2015-05-20 15:34:03,376 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2015-05-20 15:34:03,377 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutdown complete
2015-05-20 15:34:03,400 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:03,400 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:03,413 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting
2015-05-20 15:34:03,414 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:03,414 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flows: 1
2015-05-20 15:34:03,414 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] allocating threads: 1
2015-05-20 15:34:03,414 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2015-05-20 15:34:03,415 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] at least one sink is marked for delete
2015-05-20 15:34:03,415 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:03,419 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting
2015-05-20 15:34:03,419 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:03,420 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-500/first-nondeterministic"]
2015-05-20 15:34:03,420 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] parallel execution is enabled: true
2015-05-20 15:34:03,420 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting jobs: 1
2015-05-20 15:34:03,420 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] allocating threads: 1
2015-05-20 15:34:03,421 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-05-20 15:34:03,620 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] submitted hadoop job: job_1432161232321_0010
2015-05-20 15:34:03,621 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0010/
2015-05-20 15:34:03,921 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping all flows
2015-05-20 15:34:03,922 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2015-05-20 15:34:03,922 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopping all jobs
2015-05-20 15:34:03,923 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-05-20 15:34:04,133 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopped all jobs
2015-05-20 15:34:04,133 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutting down job executor
2015-05-20 15:34:04,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutdown complete
2015-05-20 15:34:04,137 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopped all flows
2015-05-20 15:34:04,137 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2015-05-20 15:34:04,137 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutting down flow executor
2015-05-20 15:34:04,138 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutdown complete
2015-05-20 15:34:04,138 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-300/first-nondeterministic
2015-05-20 15:34:04,139 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-0/first-nondeterministic
2015-05-20 15:34:04,140 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-150/first-nondeterministic
2015-05-20 15:34:04,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-350/first-nondeterministic
2015-05-20 15:34:04,142 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-250/first-nondeterministic
2015-05-20 15:34:04,143 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-450/first-nondeterministic
2015-05-20 15:34:04,144 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-200/first-nondeterministic
2015-05-20 15:34:04,145 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-500/first-nondeterministic
2015-05-20 15:34:04,147 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-50/first-nondeterministic
2015-05-20 15:34:04,148 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-100/first-nondeterministic
2015-05-20 15:34:04,149 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-400/first-nondeterministic
2015-05-20 15:34:04,172 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:04,173 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:04,207 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:04,208 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:04,247 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:04,248 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:04,323 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:04,329 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:04,399 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:34:04,402 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:34:04,485 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting
2015-05-20 15:34:04,486 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] parallel execution is enabled: true
2015-05-20 15:34:04,486 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flows: 5
2015-05-20 15:34:04,486 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] allocating threads: 5
2015-05-20 15:34:04,487 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first2
2015-05-20 15:34:04,487 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first1
2015-05-20 15:34:04,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] at least one sink is marked for delete
2015-05-20 15:34:04,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] at least one sink is marked for delete
2015-05-20 15:34:04,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:04,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:34:04,492 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting
2015-05-20 15:34:04,492 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting
2015-05-20 15:34:04,492 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/ips.20.txt"]
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/first1"]
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/first2"]
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] parallel execution is enabled: true
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting jobs: 1
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] allocating threads: 1
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] parallel execution is enabled: true
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting jobs: 1
2015-05-20 15:34:04,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] allocating threads: 1
2015-05-20 15:34:04,495 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] starting step: (1/1) ...lelcascadeplatform/first2
2015-05-20 15:34:04,496 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] starting step: (1/1) ...lelcascadeplatform/first1
2015-05-20 15:34:04,718 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] submitted hadoop job: job_1432161232321_0012
2015-05-20 15:34:04,718 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0012/
2015-05-20 15:34:04,719 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] submitted hadoop job: job_1432161232321_0011
2015-05-20 15:34:04,720 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0011/
2015-05-20 15:34:31,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0001_01_000002 is : 143
2015-05-20 15:34:32,335 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0001_01_000003 is : 143
2015-05-20 15:34:32,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0002_01_000002 is : 143
2015-05-20 15:34:32,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0003_01_000003 is : 143
2015-05-20 15:34:33,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0004_01_000002 is : 143
2015-05-20 15:34:33,476 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0003_01_000007 is : 143
2015-05-20 15:34:34,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0002_01_000003 is : 143
2015-05-20 15:34:35,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0004_01_000006 is : 143
2015-05-20 15:34:48,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0001_01_000071 is : 143
2015-05-20 15:34:49,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0002_01_000004 is : 143
2015-05-20 15:34:49,595 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0001_01_000072 is : 143
2015-05-20 15:34:50,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0003_01_000008 is : 143
2015-05-20 15:34:50,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0003_01_000009 is : 143
2015-05-20 15:34:50,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0004_01_000007 is : 143
2015-05-20 15:34:50,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0002_01_000007 is : 143
2015-05-20 15:34:50,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0004_01_000012 is : 143
2015-05-20 15:35:28,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0005_01_000004 is : 143
2015-05-20 15:35:28,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0005_01_000002 is : 143
2015-05-20 15:35:28,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0005_01_000003 is : 143
2015-05-20 15:35:28,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0006_01_000002 is : 143
2015-05-20 15:35:29,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0012_01_000002 is : 143
2015-05-20 15:35:29,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0006_01_000003 is : 143
2015-05-20 15:35:29,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0012_01_000006 is : 143
2015-05-20 15:35:29,977 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0011_01_000003 is : 143
2015-05-20 15:35:46,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0006_01_000005 is : 143
2015-05-20 15:35:46,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0011_01_000077 is : 143
2015-05-20 15:35:46,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0005_01_000006 is : 143
2015-05-20 15:35:46,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0006_01_000004 is : 143
2015-05-20 15:35:46,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0012_01_000010 is : 143
2015-05-20 15:35:46,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0012_01_000009 is : 143
2015-05-20 15:35:47,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0011_01_000078 is : 143
2015-05-20 15:35:47,444 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0011_01_000080 is : 143
2015-05-20 15:35:48,070 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/first1/_temporary
2015-05-20 15:35:48,071 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first1
2015-05-20 15:35:48,071 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second1
2015-05-20 15:35:48,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] at least one sink is marked for delete
2015-05-20 15:35:48,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:35:48,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting
2015-05-20 15:35:48,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/first1"]
2015-05-20 15:35:48,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/second1"]
2015-05-20 15:35:48,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] parallel execution is enabled: true
2015-05-20 15:35:48,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting jobs: 1
2015-05-20 15:35:48,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] allocating threads: 1
2015-05-20 15:35:48,076 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] starting step: (1/1) ...elcascadeplatform/second1
2015-05-20 15:35:48,202 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] submitted hadoop job: job_1432161232321_0013
2015-05-20 15:35:48,202 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0013/
2015-05-20 15:35:48,614 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/first2/_temporary
2015-05-20 15:35:48,616 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first2
2015-05-20 15:35:48,616 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second2
2015-05-20 15:35:48,616 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] at least one sink is marked for delete
2015-05-20 15:35:48,616 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:35:48,619 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting
2015-05-20 15:35:48,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/first2"]
2015-05-20 15:35:48,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/second2"]
2015-05-20 15:35:48,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] parallel execution is enabled: true
2015-05-20 15:35:48,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting jobs: 1
2015-05-20 15:35:48,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] allocating threads: 1
2015-05-20 15:35:48,621 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] starting step: (1/1) ...elcascadeplatform/second2
2015-05-20 15:35:48,734 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] submitted hadoop job: job_1432161232321_0014
2015-05-20 15:35:48,734 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0014/
2015-05-20 15:35:53,790 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432161232321_0005_01_000001
2015-05-20 15:36:04,826 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432161232321_0013_01_000008
2015-05-20 15:36:05,484 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432161232321_0014_01_000009
2015-05-20 15:36:20,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0013_01_000003 is : 143
2015-05-20 15:36:21,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0013_01_000004 is : 143
2015-05-20 15:36:21,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0013_01_000002 is : 143
2015-05-20 15:36:22,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0014_01_000002 is : 143
2015-05-20 15:36:22,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0013_01_000005 is : 143
2015-05-20 15:36:22,458 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0014_01_000004 is : 143
2015-05-20 15:36:22,555 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0013_01_000006 is : 143
2015-05-20 15:36:22,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0014_01_000005 is : 143
2015-05-20 15:36:22,852 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0014_01_000007 is : 143
2015-05-20 15:36:22,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0014_01_000003 is : 143
2015-05-20 15:36:23,813 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/second1/_temporary
2015-05-20 15:36:23,814 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second1
2015-05-20 15:36:24,213 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/second2/_temporary
2015-05-20 15:36:24,214 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second2
2015-05-20 15:36:24,214 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: lhs*rhs
2015-05-20 15:36:24,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] at least one sink is marked for delete
2015-05-20 15:36:24,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:36:24,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-05-20 15:36:24,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/second2"]
2015-05-20 15:36:24,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/second1"]
2015-05-20 15:36:24,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/third"]
2015-05-20 15:36:24,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-05-20 15:36:24,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 1
2015-05-20 15:36:24,218 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 1
2015-05-20 15:36:24,219 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...llelcascadeplatform/third
2015-05-20 15:36:24,331 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1432161232321_0015
2015-05-20 15:36:24,331 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Edinburgh.local:63585/proxy/application_1432161232321_0015/
2015-05-20 15:36:33,868 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432161232321_0015_01_000014
2015-05-20 15:36:34,010 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432161232321_0015_01_000015
2015-05-20 15:36:34,873 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432161232321_0015_01_000018
2015-05-20 15:36:49,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000002 is : 143
2015-05-20 15:36:49,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000003 is : 143
2015-05-20 15:36:50,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000011 is : 143
2015-05-20 15:36:50,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000010 is : 143
2015-05-20 15:36:50,308 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000006 is : 143
2015-05-20 15:36:50,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000005 is : 143
2015-05-20 15:36:50,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000009 is : 143
2015-05-20 15:36:50,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000007 is : 143
2015-05-20 15:36:50,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000004 is : 143
2015-05-20 15:36:50,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000013 is : 143
2015-05-20 15:36:55,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432161232321_0015_01_000019 is : 143
2015-05-20 15:36:56,514 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/parallelcascadeplatform/third/_temporary
2015-05-20 15:36:56,515 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: lhs*rhs
2015-05-20 15:36:56,542 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/third
2015-05-20 15:36:56,547 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/first1
2015-05-20 15:36:56,564 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/first2
2015-05-20 15:36:56,580 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/second2
2015-05-20 15:36:56,592 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/parallelcascadeplatform/second1