Class cascading.cascade.ParallelCascadePlatformTest

all > cascading.cascade > ParallelCascadePlatformTest

tests

failures

ignored

4m46.12s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testCascade	4m15.59s	passed
testCascadeRaceCondition	30.526s	passed

Standard output

2016-05-18 08:21:47,001 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 08:21:47,031 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-mr1
2016-05-18 08:21:47,062 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 08:21:48,081 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
2016-05-18 08:21:48,799 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 08:21:53,244 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.
2016-05-18 08:21:53,476 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.
2016-05-18 08:21:53,650 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.
2016-05-18 08:21:53,824 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.
2016-05-18 08:22:10,968 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 08:22:11,065 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:11,066 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:11,133 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 79E2E12A0AF74F40B2CE4E1089BFBD63
2016-05-18 08:22:11,253 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-05-18 08:22:11,257 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:11,257 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:11,392 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2016-05-18 08:22:11,392 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2016-05-18 08:22:11,392 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 08:22:11,393 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2016-05-18 08:22:11,426 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:11,426 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:11,514 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-05-18 08:22:11,519 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:11,520 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:11,587 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2016-05-18 08:22:11,590 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...]  parallel execution of flows is enabled: false
2016-05-18 08:22:11,590 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...]  executing total flows: 1
2016-05-18 08:22:11,590 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...]  allocating management threads: 1
2016-05-18 08:22:11,591 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2016-05-18 08:22:11,592 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] at least one sink is marked for delete
2016-05-18 08:22:11,592 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:11,629 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] starting
2016-05-18 08:22:11,630 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:11,630 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic"]
2016-05-18 08:22:11,630 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...]  parallel execution of steps is enabled: true
2016-05-18 08:22:11,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...]  executing total steps: 1
2016-05-18 08:22:11,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...]  allocating management threads: 1
2016-05-18 08:22:11,632 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:11,637 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2016-05-18 08:22:11,638 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2016-05-18 08:22:11,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping all jobs
2016-05-18 08:22:11,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:11,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopped all jobs
2016-05-18 08:22:12,340 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] submitted hadoop job: job_1463559725466_0001
2016-05-18 08:22:12,341 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0001/
2016-05-18 08:22:12,362 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2016-05-18 08:22:12,362 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2016-05-18 08:22:12,377 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...]  completed in: 00:00.010
2016-05-18 08:22:12,377 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2016-05-18 08:22:12,378 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2016-05-18 08:22:12,401 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:12,402 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:12,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 08:22:12,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:12,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:12,465 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2016-05-18 08:22:12,470 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:12,470 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...]  executing total flows: 1
2016-05-18 08:22:12,471 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:12,472 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2016-05-18 08:22:12,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:12,473 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:12,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting
2016-05-18 08:22:12,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:12,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2016-05-18 08:22:12,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:12,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...]  executing total steps: 1
2016-05-18 08:22:12,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:12,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:12,565 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2016-05-18 08:22:12,567 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2016-05-18 08:22:12,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping all jobs
2016-05-18 08:22:12,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:12,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopped all jobs
2016-05-18 08:22:12,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] submitted hadoop job: job_1463559725466_0002
2016-05-18 08:22:12,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0002/
2016-05-18 08:22:12,910 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2016-05-18 08:22:12,914 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2016-05-18 08:22:12,914 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...]  completed in: 00:00.090
2016-05-18 08:22:12,915 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2016-05-18 08:22:12,916 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2016-05-18 08:22:12,943 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:12,944 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:13,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-18 08:22:13,019 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:13,019 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:13,040 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2016-05-18 08:22:13,042 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:13,042 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...]  executing total flows: 1
2016-05-18 08:22:13,042 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:13,044 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2016-05-18 08:22:13,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:13,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:13,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting
2016-05-18 08:22:13,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:13,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2016-05-18 08:22:13,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:13,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...]  executing total steps: 1
2016-05-18 08:22:13,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:13,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:13,190 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2016-05-18 08:22:13,192 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2016-05-18 08:22:13,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping all jobs
2016-05-18 08:22:13,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:13,194 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopped all jobs
2016-05-18 08:22:13,273 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] submitted hadoop job: job_1463559725466_0003
2016-05-18 08:22:13,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0003/
2016-05-18 08:22:13,279 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2016-05-18 08:22:13,280 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutting down flow executor
2016-05-18 08:22:13,280 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...]  completed in: 00:00.137
2016-05-18 08:22:13,281 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2016-05-18 08:22:13,281 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutdown complete
2016-05-18 08:22:13,302 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:13,302 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:13,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 08:22:13,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:13,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:13,366 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2016-05-18 08:22:13,394 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:13,398 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...]  executing total flows: 1
2016-05-18 08:22:13,398 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:13,398 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2016-05-18 08:22:13,403 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:13,403 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:13,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting
2016-05-18 08:22:13,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:13,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2016-05-18 08:22:13,414 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:13,414 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...]  executing total steps: 1
2016-05-18 08:22:13,414 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:13,419 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:13,566 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2016-05-18 08:22:13,568 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2016-05-18 08:22:13,569 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping all jobs
2016-05-18 08:22:13,569 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:13,569 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopped all jobs
2016-05-18 08:22:13,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] submitted hadoop job: job_1463559725466_0004
2016-05-18 08:22:13,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0004/
2016-05-18 08:22:13,658 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...]  completed in: 00:00.157
2016-05-18 08:22:13,658 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2016-05-18 08:22:13,659 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2016-05-18 08:22:13,658 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2016-05-18 08:22:13,660 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2016-05-18 08:22:13,681 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:13,682 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:13,727 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 08:22:13,728 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:13,729 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:13,742 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2016-05-18 08:22:13,743 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:13,743 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...]  executing total flows: 1
2016-05-18 08:22:13,743 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:13,744 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2016-05-18 08:22:13,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:13,745 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:13,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting
2016-05-18 08:22:13,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:13,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2016-05-18 08:22:13,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:13,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...]  executing total steps: 1
2016-05-18 08:22:13,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:13,752 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:13,992 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2016-05-18 08:22:13,994 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2016-05-18 08:22:13,994 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping all jobs
2016-05-18 08:22:13,995 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:13,995 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopped all jobs
2016-05-18 08:22:13,997 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] submitted hadoop job: job_1463559725466_0005
2016-05-18 08:22:13,998 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0005/
2016-05-18 08:22:14,001 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2016-05-18 08:22:14,001 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutting down flow executor
2016-05-18 08:22:14,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...]  completed in: 00:00.245
2016-05-18 08:22:14,001 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2016-05-18 08:22:14,002 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutdown complete
2016-05-18 08:22:14,016 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:14,017 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:14,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 08:22:14,061 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:14,062 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:14,072 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2016-05-18 08:22:14,073 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:14,073 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...]  executing total flows: 1
2016-05-18 08:22:14,073 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:14,074 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2016-05-18 08:22:14,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:14,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:14,079 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting
2016-05-18 08:22:14,079 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:14,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2016-05-18 08:22:14,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:14,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...]  executing total steps: 1
2016-05-18 08:22:14,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:14,081 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:14,261 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] submitted hadoop job: job_1463559725466_0006
2016-05-18 08:22:14,261 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0006/
2016-05-18 08:22:14,372 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2016-05-18 08:22:14,374 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2016-05-18 08:22:14,374 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping all jobs
2016-05-18 08:22:14,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:14,589 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopped all jobs
2016-05-18 08:22:14,594 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2016-05-18 08:22:14,594 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...]  completed in: 00:00.295
2016-05-18 08:22:14,594 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2016-05-18 08:22:14,594 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2016-05-18 08:22:14,595 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2016-05-18 08:22:14,618 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:14,618 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:14,667 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 08:22:14,668 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:14,668 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:14,691 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2016-05-18 08:22:14,693 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:14,693 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...]  executing total flows: 1
2016-05-18 08:22:14,694 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:14,695 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2016-05-18 08:22:14,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:14,696 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:14,703 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting
2016-05-18 08:22:14,703 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:14,704 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2016-05-18 08:22:14,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:14,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...]  executing total steps: 1
2016-05-18 08:22:14,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:14,707 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:14,914 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] submitted hadoop job: job_1463559725466_0007
2016-05-18 08:22:14,914 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0007/
2016-05-18 08:22:15,041 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2016-05-18 08:22:15,042 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2016-05-18 08:22:15,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping all jobs
2016-05-18 08:22:15,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:15,050 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-05-18 08:22:15,256 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopped all jobs
2016-05-18 08:22:15,259 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2016-05-18 08:22:15,259 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2016-05-18 08:22:15,260 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...]  completed in: 00:00.340
2016-05-18 08:22:15,260 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2016-05-18 08:22:15,261 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2016-05-18 08:22:15,284 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:15,285 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:15,330 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 08:22:15,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:15,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:15,356 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2016-05-18 08:22:15,362 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:15,362 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...]  executing total flows: 1
2016-05-18 08:22:15,362 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:15,363 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2016-05-18 08:22:15,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:15,364 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:15,370 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting
2016-05-18 08:22:15,370 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:15,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2016-05-18 08:22:15,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:15,372 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...]  executing total steps: 1
2016-05-18 08:22:15,372 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:15,373 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:15,610 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] submitted hadoop job: job_1463559725466_0008
2016-05-18 08:22:15,610 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0008/
2016-05-18 08:22:15,756 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2016-05-18 08:22:15,757 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2016-05-18 08:22:15,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping all jobs
2016-05-18 08:22:15,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:15,967 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopped all jobs
2016-05-18 08:22:15,972 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2016-05-18 08:22:15,972 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2016-05-18 08:22:15,973 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...]  completed in: 00:00.387
2016-05-18 08:22:15,973 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2016-05-18 08:22:15,973 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2016-05-18 08:22:16,000 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:16,000 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:16,048 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-18 08:22:16,049 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:16,049 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:16,063 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2016-05-18 08:22:16,064 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:16,064 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...]  executing total flows: 1
2016-05-18 08:22:16,065 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:16,065 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2016-05-18 08:22:16,065 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:16,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:16,070 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting
2016-05-18 08:22:16,070 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:16,071 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2016-05-18 08:22:16,071 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:16,071 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...]  executing total steps: 1
2016-05-18 08:22:16,071 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:16,073 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:16,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] submitted hadoop job: job_1463559725466_0009
2016-05-18 08:22:16,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0009/
2016-05-18 08:22:16,513 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2016-05-18 08:22:16,514 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2016-05-18 08:22:16,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping all jobs
2016-05-18 08:22:16,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 08:22:16,722 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopped all jobs
2016-05-18 08:22:16,726 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2016-05-18 08:22:16,726 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...]  completed in: 00:00.445
2016-05-18 08:22:16,726 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2016-05-18 08:22:16,726 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2016-05-18 08:22:16,727 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2016-05-18 08:22:16,787 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:16,798 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:16,838 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 08:22:16,838 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:16,839 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:16,851 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2016-05-18 08:22:16,852 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...]  parallel execution of flows is enabled: false
2016-05-18 08:22:16,853 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...]  executing total flows: 1
2016-05-18 08:22:16,853 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:16,853 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2016-05-18 08:22:16,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] at least one sink is marked for delete
2016-05-18 08:22:16,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:16,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting
2016-05-18 08:22:16,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:16,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2016-05-18 08:22:16,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...]  parallel execution of steps is enabled: true
2016-05-18 08:22:16,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...]  executing total steps: 1
2016-05-18 08:22:16,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...]  allocating management threads: 1
2016-05-18 08:22:16,861 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:17,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] submitted hadoop job: job_1463559725466_0010
2016-05-18 08:22:17,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0010/
2016-05-18 08:22:17,351 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2016-05-18 08:22:17,352 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2016-05-18 08:22:17,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping all jobs
2016-05-18 08:22:17,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 08:22:17,558 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopped all jobs
2016-05-18 08:22:17,563 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2016-05-18 08:22:17,564 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2016-05-18 08:22:17,564 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...]  completed in: 00:00.493
2016-05-18 08:22:17,564 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2016-05-18 08:22:17,565 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2016-05-18 08:22:17,565 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2016-05-18 08:22:17,572 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2016-05-18 08:22:17,573 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2016-05-18 08:22:17,574 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2016-05-18 08:22:17,575 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2016-05-18 08:22:17,577 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2016-05-18 08:22:17,578 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2016-05-18 08:22:17,580 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2016-05-18 08:22:17,581 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2016-05-18 08:22:17,583 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2016-05-18 08:22:17,584 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2016-05-18 08:22:17,613 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:17,614 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:17,652 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 08:22:17,653 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:17,653 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:17,681 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:17,681 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:17,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 08:22:17,726 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:17,727 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:17,750 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:17,751 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:17,798 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 08:22:17,798 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:17,799 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:17,830 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:17,831 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:17,863 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 08:22:17,864 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:22:17,864 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:17,902 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:22:17,902 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 08:22:17,958 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-05-18 08:22:17,959 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 08:22:17,959 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:22:18,001 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2016-05-18 08:22:18,002 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...]  parallel execution of flows is enabled: true
2016-05-18 08:22:18,003 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...]  executing total flows: 5
2016-05-18 08:22:18,003 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...]  allocating management threads: 5
2016-05-18 08:22:18,003 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2016-05-18 08:22:18,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] at least one sink is marked for delete
2016-05-18 08:22:18,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:18,008 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2016-05-18 08:22:18,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] at least one sink is marked for delete
2016-05-18 08:22:18,010 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:22:18,024 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting
2016-05-18 08:22:18,024 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:18,024 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2016-05-18 08:22:18,024 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2]  parallel execution of steps is enabled: true
2016-05-18 08:22:18,025 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2]  executing total steps: 1
2016-05-18 08:22:18,025 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2]  allocating management threads: 1
2016-05-18 08:22:18,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting
2016-05-18 08:22:18,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-05-18 08:22:18,031 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2016-05-18 08:22:18,031 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1]  parallel execution of steps is enabled: true
2016-05-18 08:22:18,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1]  executing total steps: 1
2016-05-18 08:22:18,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1]  allocating management threads: 1
2016-05-18 08:22:18,037 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2016-05-18 08:22:18,037 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2016-05-18 08:22:18,341 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] submitted hadoop job: job_1463559725466_0011
2016-05-18 08:22:18,342 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0011/
2016-05-18 08:22:18,542 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] submitted hadoop job: job_1463559725466_0012
2016-05-18 08:22:18,542 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0012/
2016-05-18 08:22:31,833 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0001_01_000003 is : 143
2016-05-18 08:22:31,877 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0001_01_000005 is : 143
2016-05-18 08:22:31,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0001_01_000002 is : 143
2016-05-18 08:22:55,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0002_01_000003 is : 143
2016-05-18 08:22:56,184 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0002_01_000005 is : 143
2016-05-18 08:23:20,231 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0003_01_000002 is : 143
2016-05-18 08:23:20,485 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0003_01_000003 is : 143
2016-05-18 08:23:21,396 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0003_01_000004 is : 143
2016-05-18 08:23:27,734 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463559725466_0003_01_000001
2016-05-18 08:23:43,776 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0004_01_000002 is : 143
2016-05-18 08:23:43,989 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0004_01_000003 is : 143
2016-05-18 08:23:44,530 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0004_01_000005 is : 143
2016-05-18 08:23:44,609 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0004_01_000004 is : 143
2016-05-18 08:23:50,974 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463559725466_0004_01_000001
2016-05-18 08:24:07,238 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0005_01_000003 is : 143
2016-05-18 08:24:07,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0005_01_000004 is : 143
2016-05-18 08:24:07,662 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0005_01_000005 is : 143
2016-05-18 08:24:08,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0005_01_000002 is : 143
2016-05-18 08:24:31,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0011_01_000003 is : 143
2016-05-18 08:24:31,493 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0011_01_000002 is : 143
2016-05-18 08:24:32,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0011_01_000005 is : 143
2016-05-18 08:24:32,110 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0011_01_000004 is : 143
2016-05-18 08:24:33,276 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2/_temporary
2016-05-18 08:24:33,278 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first2]  completed in: 02:15.249, using cpu time: 00:04.500
2016-05-18 08:24:33,278 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2016-05-18 08:24:33,278 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2016-05-18 08:24:33,278 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] at least one sink is marked for delete
2016-05-18 08:24:33,278 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:24:33,280 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting
2016-05-18 08:24:33,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2016-05-18 08:24:33,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2016-05-18 08:24:33,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2]  parallel execution of steps is enabled: true
2016-05-18 08:24:33,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2]  executing total steps: 1
2016-05-18 08:24:33,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2]  allocating management threads: 1
2016-05-18 08:24:33,283 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2016-05-18 08:24:33,397 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] submitted hadoop job: job_1463559725466_0013
2016-05-18 08:24:33,397 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0013/
2016-05-18 08:24:54,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0012_01_000002 is : 143
2016-05-18 08:24:54,808 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0012_01_000003 is : 143
2016-05-18 08:24:55,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0012_01_000004 is : 143
2016-05-18 08:24:55,386 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0012_01_000005 is : 143
2016-05-18 08:24:56,570 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1/_temporary
2016-05-18 08:24:56,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first1]  completed in: 02:38.538, using cpu time: 00:04.560
2016-05-18 08:24:56,572 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2016-05-18 08:24:56,572 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2016-05-18 08:24:56,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] at least one sink is marked for delete
2016-05-18 08:24:56,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:24:56,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting
2016-05-18 08:24:56,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2016-05-18 08:24:56,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2016-05-18 08:24:56,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1]  parallel execution of steps is enabled: true
2016-05-18 08:24:56,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1]  executing total steps: 1
2016-05-18 08:24:56,577 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1]  allocating management threads: 1
2016-05-18 08:24:56,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2016-05-18 08:24:56,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] submitted hadoop job: job_1463559725466_0014
2016-05-18 08:24:56,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0014/
2016-05-18 08:25:20,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0013_01_000003 is : 143
2016-05-18 08:25:21,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0013_01_000005 is : 143
2016-05-18 08:25:21,495 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0013_01_000004 is : 143
2016-05-18 08:25:22,012 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0013_01_000002 is : 143
2016-05-18 08:25:23,190 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2/_temporary
2016-05-18 08:25:23,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second2]  completed in: 00:49.908, using cpu time: 00:05.570
2016-05-18 08:25:23,192 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2016-05-18 08:25:48,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0014_01_000003 is : 143
2016-05-18 08:25:48,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0014_01_000005 is : 143
2016-05-18 08:25:48,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0014_01_000004 is : 143
2016-05-18 08:25:48,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0014_01_000002 is : 143
2016-05-18 08:25:49,054 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0014_01_000006 is : 143
2016-05-18 08:25:50,229 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1/_temporary
2016-05-18 08:25:50,230 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second1]  completed in: 00:53.652, using cpu time: 00:05.680
2016-05-18 08:25:50,230 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2016-05-18 08:25:50,231 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2016-05-18 08:25:50,231 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] at least one sink is marked for delete
2016-05-18 08:25:50,231 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 08:25:50,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 08:25:50,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2016-05-18 08:25:50,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2016-05-18 08:25:50,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third"]
2016-05-18 08:25:50,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 08:25:50,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 1
2016-05-18 08:25:50,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 1
2016-05-18 08:25:50,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2016-05-18 08:25:50,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463559725466_0015
2016-05-18 08:25:50,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:38029/proxy/application_1463559725466_0015/
2016-05-18 08:26:23,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000007 is : 143
2016-05-18 08:26:23,485 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000006 is : 143
2016-05-18 08:26:27,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000008 is : 143
2016-05-18 08:26:27,843 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000011 is : 143
2016-05-18 08:26:27,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000002 is : 143
2016-05-18 08:26:28,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000010 is : 143
2016-05-18 08:26:28,235 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000004 is : 143
2016-05-18 08:26:28,324 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000005 is : 143
2016-05-18 08:26:31,905 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463559725466_0015_01_000012 is : 143
2016-05-18 08:26:33,093 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third/_temporary
2016-05-18 08:26:33,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:42.858, using cpu time: 00:12.940
2016-05-18 08:26:33,094 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2016-05-18 08:26:33,121 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second1
2016-05-18 08:26:33,137 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/third
2016-05-18 08:26:33,142 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second2
2016-05-18 08:26:33,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first2
2016-05-18 08:26:33,165 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first1

Standard error

Exception in thread "org.apache.hadoop.util.JvmPauseMonitor$Monitor@62c5d5eb" java.lang.NoSuchMethodError: com.google.common.base.Stopwatch.elapsedMillis()J
	at org.apache.hadoop.util.JvmPauseMonitor$Monitor.run(JvmPauseMonitor.java:186)
	at java.lang.Thread.run(Thread.java:745)
Exception in thread "org.apache.hadoop.util.JvmPauseMonitor$Monitor@5770b13f" java.lang.NoSuchMethodError: com.google.common.base.Stopwatch.elapsedMillis()J
	at org.apache.hadoop.util.JvmPauseMonitor$Monitor.run(JvmPauseMonitor.java:186)
	at java.lang.Thread.run(Thread.java:745)
Exception in thread "org.apache.hadoop.util.JvmPauseMonitor$Monitor@2d631f8b" java.lang.NoSuchMethodError: com.google.common.base.Stopwatch.elapsedMillis()J
	at org.apache.hadoop.util.JvmPauseMonitor$Monitor.run(JvmPauseMonitor.java:186)
	at java.lang.Thread.run(Thread.java:745)
Exception in thread "org.apache.hadoop.util.JvmPauseMonitor$Monitor@aacd4c9" java.lang.NoSuchMethodError: com.google.common.base.Stopwatch.elapsedMillis()J
	at org.apache.hadoop.util.JvmPauseMonitor$Monitor.run(JvmPauseMonitor.java:186)
	at java.lang.Thread.run(Thread.java:745)
Exception in thread "org.apache.hadoop.util.JvmPauseMonitor$Monitor@1267982e" java.lang.NoSuchMethodError: com.google.common.base.Stopwatch.elapsedMillis()J
	at org.apache.hadoop.util.JvmPauseMonitor$Monitor.run(JvmPauseMonitor.java:186)
	at java.lang.Thread.run(Thread.java:745)
May 18, 2016 8:22:05 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
May 18, 2016 8:22:05 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
May 18, 2016 8:22:05 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 8:22:05 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 18, 2016 8:22:05 AM 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 18, 2016 8:22:06 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 18, 2016 8:22:06 AM 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 18, 2016 8:22:06 AM 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 18, 2016 8:22:07 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
May 18, 2016 8:22:07 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
May 18, 2016 8:22:07 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 8:22:07 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 18, 2016 8:22:07 AM 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 18, 2016 8:22:07 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 18, 2016 8:22:07 AM 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 18, 2016 8:22:07 AM 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 18, 2016 8:22:08 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 18, 2016 8:22:08 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 8:22:08 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 18, 2016 8:22:08 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 18, 2016 8:22:08 AM 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 18, 2016 8:22:08 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 18, 2016 8:22:08 AM 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 18, 2016 8:22:08 AM 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 18, 2016 8:22:09 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 18, 2016 8:22:09 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 8:22:09 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 18, 2016 8:22:09 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 18, 2016 8:22:09 AM 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 18, 2016 8:22:09 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 18, 2016 8:22:09 AM 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 18, 2016 8:22:09 AM 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 18, 2016 8:22:10 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 18, 2016 8:22:10 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 8:22:10 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 18, 2016 8:22:10 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 18, 2016 8:22:10 AM 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 18, 2016 8:22:10 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 18, 2016 8:22:10 AM 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 18, 2016 8:22:10 AM 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.