Class cascading.cascade.ParallelCascadePlatformTest

2

tests

0

failures

0

ignored

3m21.22s

duration

100%

successful

Tests

Test Duration Result
testCascade 2m52.46s passed
testCascadeRaceCondition 28.760s passed

Standard output

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

Standard error

May 20, 2015 3:33:52 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
May 20, 2015 3:33:52 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
May 20, 2015 3:33:52 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:33:52 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 3:33:52 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"
May 20, 2015 3:33:52 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 3:33:53 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"
May 20, 2015 3:33:53 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.
May 20, 2015 3:33:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 3:33:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
May 20, 2015 3:33:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:33:53 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 3:33:53 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"
May 20, 2015 3:33:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 3:33:54 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"
May 20, 2015 3:33:54 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.
May 20, 2015 3:33:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 20, 2015 3:33:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:33:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 3:33:54 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 3:33:54 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"
May 20, 2015 3:33:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 3:33:55 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"
May 20, 2015 3:33:55 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.
May 20, 2015 3:33:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 20, 2015 3:33:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:33:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 3:33:55 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 3:33:55 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"
May 20, 2015 3:33:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 3:33:56 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"
May 20, 2015 3:33:56 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.
May 20, 2015 3:33:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 20, 2015 3:33:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 20, 2015 3:33:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 20, 2015 3:33:56 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 20, 2015 3:33:56 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"
May 20, 2015 3:33:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 20, 2015 3:33:57 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"
May 20, 2015 3:33:57 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.