2016-05-17 22:14:48,436 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:14:48,466 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-mr1
2016-05-17 22:14:48,494 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-17 22:14:49,243 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-17 22:14:49,863 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 22:14:54,907 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-17 22:14:56,133 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-17 22:14:57,268 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-17 22:14:58,399 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-17 22:15:00,948 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 22:15:01,042 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:01,044 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-17 22:15:01,113 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 7A6EFE303D8940688AA57C6FE6A5355C
2016-05-17 22:15:01,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-05-17 22:15:01,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:01,233 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-17 22:15:01,346 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2016-05-17 22:15:01,346 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:15:01,346 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2016-05-17 22:15:01,347 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2016-05-17 22:15:01,369 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:01,370 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-17 22:15:01,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-05-17 22:15:01,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:01,429 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-17 22:15:01,475 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2016-05-17 22:15:01,477 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] parallel execution of flows is enabled: false
2016-05-17 22:15:01,478 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] executing total flows: 1
2016-05-17 22:15:01,478 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] allocating management threads: 1
2016-05-17 22:15:01,479 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2016-05-17 22:15:01,480 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] at least one sink is marked for delete
2016-05-17 22:15:01,480 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-17 22:15:01,498 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2016-05-17 22:15:01,498 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] starting
2016-05-17 22:15:01,499 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2016-05-17 22:15:01,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping all jobs
2016-05-17 22:15:01,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:01,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopped all jobs
2016-05-17 22:15:01,500 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2016-05-17 22:15:01,501 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2016-05-17 22:15:01,502 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:01,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic"]
2016-05-17 22:15:01,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] parallel execution of steps is enabled: true
2016-05-17 22:15:01,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executing total steps: 1
2016-05-17 22:15:01,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] allocating management threads: 1
2016-05-17 22:15:01,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] completed in: 00:00.002
2016-05-17 22:15:01,504 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2016-05-17 22:15:01,505 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2016-05-17 22:15:01,522 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:01,522 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-17 22:15:01,565 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 22:15:01,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:01,567 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-17 22:15:01,582 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2016-05-17 22:15:01,583 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:01,583 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] executing total flows: 1
2016-05-17 22:15:01,583 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] allocating management threads: 1
2016-05-17 22:15:01,584 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2016-05-17 22:15:01,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:01,584 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-17 22:15:01,591 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting
2016-05-17 22:15:01,591 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:01,592 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2016-05-17 22:15:01,592 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:01,593 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executing total steps: 1
2016-05-17 22:15:01,593 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] allocating management threads: 1
2016-05-17 22:15:01,595 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:01,682 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2016-05-17 22:15:01,683 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2016-05-17 22:15:01,683 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping all jobs
2016-05-17 22:15:01,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:01,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopped all jobs
2016-05-17 22:15:02,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] submitted hadoop job: job_1463523293069_0001
2016-05-17 22:15:02,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0001/
2016-05-17 22:15:02,283 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2016-05-17 22:15:02,284 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2016-05-17 22:15:02,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] completed in: 00:00.092
2016-05-17 22:15:02,287 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2016-05-17 22:15:02,290 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2016-05-17 22:15:02,307 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:02,307 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-17 22:15:02,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-17 22:15:02,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:02,370 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-17 22:15:02,386 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2016-05-17 22:15:02,387 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:02,388 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] executing total flows: 1
2016-05-17 22:15:02,388 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] allocating management threads: 1
2016-05-17 22:15:02,389 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2016-05-17 22:15:02,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:02,390 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-17 22:15:02,393 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting
2016-05-17 22:15:02,393 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:02,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2016-05-17 22:15:02,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:02,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executing total steps: 1
2016-05-17 22:15:02,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] allocating management threads: 1
2016-05-17 22:15:02,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:02,536 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2016-05-17 22:15:02,539 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2016-05-17 22:15:02,539 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping all jobs
2016-05-17 22:15:02,539 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:02,540 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopped all jobs
2016-05-17 22:15:02,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] submitted hadoop job: job_1463523293069_0002
2016-05-17 22:15:02,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0002/
2016-05-17 22:15:02,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] completed in: 00:00.146
2016-05-17 22:15:02,658 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2016-05-17 22:15:02,658 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutting down flow executor
2016-05-17 22:15:02,658 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2016-05-17 22:15:02,660 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutdown complete
2016-05-17 22:15:02,679 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:02,680 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-17 22:15:02,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-17 22:15:02,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:02,759 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-17 22:15:02,778 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2016-05-17 22:15:02,784 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:02,784 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] executing total flows: 1
2016-05-17 22:15:02,784 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] allocating management threads: 1
2016-05-17 22:15:02,787 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2016-05-17 22:15:02,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:02,787 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-17 22:15:02,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting
2016-05-17 22:15:02,798 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:02,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2016-05-17 22:15:02,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:02,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executing total steps: 1
2016-05-17 22:15:02,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] allocating management threads: 1
2016-05-17 22:15:02,805 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:02,978 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2016-05-17 22:15:02,979 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2016-05-17 22:15:02,979 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping all jobs
2016-05-17 22:15:02,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:02,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopped all jobs
2016-05-17 22:15:03,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] submitted hadoop job: job_1463523293069_0003
2016-05-17 22:15:03,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0003/
2016-05-17 22:15:03,113 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2016-05-17 22:15:03,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] completed in: 00:00.182
2016-05-17 22:15:03,116 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2016-05-17 22:15:03,116 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2016-05-17 22:15:03,116 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2016-05-17 22:15:03,142 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:03,142 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-17 22:15:03,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-17 22:15:03,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:03,188 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-17 22:15:03,206 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2016-05-17 22:15:03,207 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:03,208 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] executing total flows: 1
2016-05-17 22:15:03,208 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] allocating management threads: 1
2016-05-17 22:15:03,209 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2016-05-17 22:15:03,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:03,210 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-17 22:15:03,213 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting
2016-05-17 22:15:03,214 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:03,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2016-05-17 22:15:03,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:03,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executing total steps: 1
2016-05-17 22:15:03,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] allocating management threads: 1
2016-05-17 22:15:03,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:03,457 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2016-05-17 22:15:03,459 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2016-05-17 22:15:03,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping all jobs
2016-05-17 22:15:03,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:03,464 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopped all jobs
2016-05-17 22:15:03,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] submitted hadoop job: job_1463523293069_0004
2016-05-17 22:15:03,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0004/
2016-05-17 22:15:03,950 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2016-05-17 22:15:03,950 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] completed in: 00:00.247
2016-05-17 22:15:03,950 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutting down flow executor
2016-05-17 22:15:03,951 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2016-05-17 22:15:03,951 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutdown complete
2016-05-17 22:15:03,972 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:03,972 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-17 22:15:04,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-17 22:15:04,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:04,042 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-17 22:15:04,060 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2016-05-17 22:15:04,061 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:04,061 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] executing total flows: 1
2016-05-17 22:15:04,061 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] allocating management threads: 1
2016-05-17 22:15:04,063 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2016-05-17 22:15:04,063 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:04,063 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-17 22:15:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting
2016-05-17 22:15:04,068 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2016-05-17 22:15:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executing total steps: 1
2016-05-17 22:15:04,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] allocating management threads: 1
2016-05-17 22:15:04,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:04,360 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2016-05-17 22:15:04,362 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2016-05-17 22:15:04,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping all jobs
2016-05-17 22:15:04,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:04,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopped all jobs
2016-05-17 22:15:04,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] submitted hadoop job: job_1463523293069_0005
2016-05-17 22:15:04,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0005/
2016-05-17 22:15:04,392 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2016-05-17 22:15:04,392 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2016-05-17 22:15:04,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] completed in: 00:00.295
2016-05-17 22:15:04,393 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2016-05-17 22:15:04,393 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2016-05-17 22:15:04,429 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:04,430 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-17 22:15:04,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-17 22:15:04,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:04,529 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-17 22:15:04,546 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2016-05-17 22:15:04,546 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:04,547 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] executing total flows: 1
2016-05-17 22:15:04,547 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] allocating management threads: 1
2016-05-17 22:15:04,548 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2016-05-17 22:15:04,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:04,549 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-17 22:15:04,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting
2016-05-17 22:15:04,553 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:04,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2016-05-17 22:15:04,554 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:04,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executing total steps: 1
2016-05-17 22:15:04,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] allocating management threads: 1
2016-05-17 22:15:04,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:04,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] submitted hadoop job: job_1463523293069_0006
2016-05-17 22:15:04,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0006/
2016-05-17 22:15:04,897 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2016-05-17 22:15:04,898 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2016-05-17 22:15:04,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping all jobs
2016-05-17 22:15:04,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:04,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopped all jobs
2016-05-17 22:15:04,918 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2016-05-17 22:15:04,919 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2016-05-17 22:15:04,920 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] completed in: 00:00.345
2016-05-17 22:15:04,920 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2016-05-17 22:15:04,922 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2016-05-17 22:15:04,943 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:04,945 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-17 22:15:05,023 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-17 22:15:05,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:05,025 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-17 22:15:05,039 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2016-05-17 22:15:05,047 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:05,048 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] executing total flows: 1
2016-05-17 22:15:05,048 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] allocating management threads: 1
2016-05-17 22:15:05,057 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2016-05-17 22:15:05,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:05,057 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-17 22:15:05,063 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting
2016-05-17 22:15:05,064 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:05,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2016-05-17 22:15:05,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:05,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executing total steps: 1
2016-05-17 22:15:05,067 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] allocating management threads: 1
2016-05-17 22:15:05,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:05,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] submitted hadoop job: job_1463523293069_0007
2016-05-17 22:15:05,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0007/
2016-05-17 22:15:05,439 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2016-05-17 22:15:05,440 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2016-05-17 22:15:05,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping all jobs
2016-05-17 22:15:05,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:05,447 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopped all jobs
2016-05-17 22:15:05,452 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2016-05-17 22:15:05,452 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2016-05-17 22:15:05,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] completed in: 00:00.377
2016-05-17 22:15:05,453 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2016-05-17 22:15:05,456 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2016-05-17 22:15:05,486 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:05,486 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-17 22:15:05,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-17 22:15:05,580 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:05,581 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-17 22:15:05,607 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2016-05-17 22:15:05,609 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:05,609 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] executing total flows: 1
2016-05-17 22:15:05,609 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] allocating management threads: 1
2016-05-17 22:15:05,621 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2016-05-17 22:15:05,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:05,621 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-17 22:15:05,633 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting
2016-05-17 22:15:05,633 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:05,633 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2016-05-17 22:15:05,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:05,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executing total steps: 1
2016-05-17 22:15:05,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] allocating management threads: 1
2016-05-17 22:15:05,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:06,057 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2016-05-17 22:15:06,058 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2016-05-17 22:15:06,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping all jobs
2016-05-17 22:15:06,060 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-17 22:15:06,060 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopped all jobs
2016-05-17 22:15:06,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] submitted hadoop job: job_1463523293069_0008
2016-05-17 22:15:06,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0008/
2016-05-17 22:15:06,073 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2016-05-17 22:15:06,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] completed in: 00:00.425
2016-05-17 22:15:06,073 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2016-05-17 22:15:06,073 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2016-05-17 22:15:06,074 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2016-05-17 22:15:06,101 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:06,107 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-17 22:15:06,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-05-17 22:15:06,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:06,201 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-17 22:15:06,219 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2016-05-17 22:15:06,221 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] parallel execution of flows is enabled: false
2016-05-17 22:15:06,221 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] executing total flows: 1
2016-05-17 22:15:06,222 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] allocating management threads: 1
2016-05-17 22:15:06,223 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2016-05-17 22:15:06,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] at least one sink is marked for delete
2016-05-17 22:15:06,224 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-17 22:15:06,235 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting
2016-05-17 22:15:06,235 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:06,236 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2016-05-17 22:15:06,236 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] parallel execution of steps is enabled: true
2016-05-17 22:15:06,236 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executing total steps: 1
2016-05-17 22:15:06,238 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] allocating management threads: 1
2016-05-17 22:15:06,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:06,719 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2016-05-17 22:15:06,733 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2016-05-17 22:15:06,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping all jobs
2016-05-17 22:15:06,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-17 22:15:06,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopped all jobs
2016-05-17 22:15:06,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] submitted hadoop job: job_1463523293069_0009
2016-05-17 22:15:06,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0009/
2016-05-17 22:15:06,785 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2016-05-17 22:15:06,786 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2016-05-17 22:15:06,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] completed in: 00:00.498
2016-05-17 22:15:06,795 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2016-05-17 22:15:06,796 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2016-05-17 22:15:06,796 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2016-05-17 22:15:06,800 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2016-05-17 22:15:06,802 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2016-05-17 22:15:06,803 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2016-05-17 22:15:06,804 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2016-05-17 22:15:06,805 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2016-05-17 22:15:06,806 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2016-05-17 22:15:06,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2016-05-17 22:15:06,808 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2016-05-17 22:15:06,809 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2016-05-17 22:15:06,811 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2016-05-17 22:15:06,848 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:06,849 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-17 22:15:06,930 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-17 22:15:06,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:06,943 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-17 22:15:07,015 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:07,016 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-17 22:15:07,060 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:15:07,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:07,061 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-17 22:15:07,096 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:07,097 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-17 22:15:07,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-17 22:15:07,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:07,151 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-17 22:15:07,180 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:07,181 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-17 22:15:07,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:15:07,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:15:07,216 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-17 22:15:07,239 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:15:07,239 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-17 22:15:07,284 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 22:15:07,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:15:07,287 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-17 22:15:07,360 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2016-05-17 22:15:07,362 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] parallel execution of flows is enabled: true
2016-05-17 22:15:07,362 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] executing total flows: 5
2016-05-17 22:15:07,362 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] allocating management threads: 5
2016-05-17 22:15:07,363 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2016-05-17 22:15:07,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] at least one sink is marked for delete
2016-05-17 22:15:07,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:15:07,366 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2016-05-17 22:15:07,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] at least one sink is marked for delete
2016-05-17 22:15:07,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:15:07,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting
2016-05-17 22:15:07,370 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:07,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2016-05-17 22:15:07,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] parallel execution of steps is enabled: true
2016-05-17 22:15:07,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executing total steps: 1
2016-05-17 22:15:07,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] allocating management threads: 1
2016-05-17 22:15:07,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2016-05-17 22:15:07,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting
2016-05-17 22:15:07,375 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.2.x/build/classes/test/data/ips.20.txt"]
2016-05-17 22:15:07,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2016-05-17 22:15:07,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] parallel execution of steps is enabled: true
2016-05-17 22:15:07,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executing total steps: 1
2016-05-17 22:15:07,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] allocating management threads: 1
2016-05-17 22:15:07,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2016-05-17 22:15:07,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] submitted hadoop job: job_1463523293069_0010
2016-05-17 22:15:07,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0010/
2016-05-17 22:15:07,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] submitted hadoop job: job_1463523293069_0011
2016-05-17 22:15:07,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0011/
2016-05-17 22:15:28,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0002_01_000004 is : 143
2016-05-17 22:15:28,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0002_01_000005 is : 143
2016-05-17 22:15:29,813 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0002_01_000002 is : 143
2016-05-17 22:15:31,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0001_01_000004 is : 143
2016-05-17 22:15:31,146 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0001_01_000002 is : 143
2016-05-17 22:15:31,194 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0001_01_000003 is : 143
2016-05-17 22:15:31,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0001_01_000005 is : 143
2016-05-17 22:15:59,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0003_01_000004 is : 143
2016-05-17 22:16:00,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0003_01_000005 is : 143
2016-05-17 22:16:03,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0004_01_000004 is : 143
2016-05-17 22:16:03,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0004_01_000005 is : 143
2016-05-17 22:16:03,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0004_01_000002 is : 143
2016-05-17 22:16:03,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0004_01_000003 is : 143
2016-05-17 22:16:27,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0005_01_000003 is : 143
2016-05-17 22:16:29,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0005_01_000005 is : 143
2016-05-17 22:16:29,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0005_01_000004 is : 143
2016-05-17 22:16:33,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0008_01_000005 is : 143
2016-05-17 22:16:33,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0008_01_000004 is : 143
2016-05-17 22:16:34,501 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0008_01_000003 is : 143
2016-05-17 22:16:34,562 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0008_01_000002 is : 143
2016-05-17 22:16:53,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0009_01_000002 is : 143
2016-05-17 22:16:53,813 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0009_01_000005 is : 143
2016-05-17 22:16:54,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0009_01_000004 is : 143
2016-05-17 22:17:03,247 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0010_01_000005 is : 143
2016-05-17 22:17:03,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0010_01_000002 is : 143
2016-05-17 22:17:03,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0010_01_000003 is : 143
2016-05-17 22:17:04,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0010_01_000004 is : 143
2016-05-17 22:17:05,593 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2/_temporary
2016-05-17 22:17:05,594 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] completed in: 01:58.219, using cpu time: 00:04.080
2016-05-17 22:17:05,595 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2016-05-17 22:17:05,595 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2016-05-17 22:17:05,595 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] at least one sink is marked for delete
2016-05-17 22:17:05,595 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:17:05,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting
2016-05-17 22:17:05,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first2"]
2016-05-17 22:17:05,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2016-05-17 22:17:05,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] parallel execution of steps is enabled: true
2016-05-17 22:17:05,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executing total steps: 1
2016-05-17 22:17:05,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] allocating management threads: 1
2016-05-17 22:17:05,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2016-05-17 22:17:06,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] submitted hadoop job: job_1463523293069_0012
2016-05-17 22:17:06,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0012/
2016-05-17 22:17:19,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0011_01_000004 is : 143
2016-05-17 22:17:19,963 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0011_01_000002 is : 143
2016-05-17 22:17:20,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0011_01_000005 is : 143
2016-05-17 22:17:20,491 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0011_01_000003 is : 143
2016-05-17 22:17:21,741 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1/_temporary
2016-05-17 22:17:21,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] completed in: 02:14.365, using cpu time: 00:03.920
2016-05-17 22:17:21,751 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2016-05-17 22:17:21,751 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2016-05-17 22:17:21,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] at least one sink is marked for delete
2016-05-17 22:17:21,751 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:17:21,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting
2016-05-17 22:17:21,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/first1"]
2016-05-17 22:17:21,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2016-05-17 22:17:21,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] parallel execution of steps is enabled: true
2016-05-17 22:17:21,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executing total steps: 1
2016-05-17 22:17:21,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] allocating management threads: 1
2016-05-17 22:17:21,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2016-05-17 22:17:21,916 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] submitted hadoop job: job_1463523293069_0013
2016-05-17 22:17:21,916 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0013/
2016-05-17 22:17:36,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0012_01_000006 is : 143
2016-05-17 22:17:37,178 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0012_01_000004 is : 143
2016-05-17 22:17:37,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0012_01_000003 is : 143
2016-05-17 22:17:37,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0012_01_000005 is : 143
2016-05-17 22:17:37,875 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0012_01_000002 is : 143
2016-05-17 22:17:39,140 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2/_temporary
2016-05-17 22:17:39,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] completed in: 00:33.534, using cpu time: 00:04.730
2016-05-17 22:17:39,145 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2016-05-17 22:17:53,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0013_01_000005 is : 143
2016-05-17 22:17:53,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0013_01_000003 is : 143
2016-05-17 22:17:53,598 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0013_01_000006 is : 143
2016-05-17 22:17:53,694 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0013_01_000004 is : 143
2016-05-17 22:17:54,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0013_01_000002 is : 143
2016-05-17 22:17:55,566 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1/_temporary
2016-05-17 22:17:55,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] completed in: 00:33.809, using cpu time: 00:04.750
2016-05-17 22:17:55,567 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2016-05-17 22:17:55,568 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2016-05-17 22:17:55,568 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] at least one sink is marked for delete
2016-05-17 22:17:55,568 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:17:55,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-17 22:17:55,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second2"]
2016-05-17 22:17:55,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/second1"]
2016-05-17 22:17:55,571 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.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third"]
2016-05-17 22:17:55,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-17 22:17:55,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 1
2016-05-17 22:17:55,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 1
2016-05-17 22:17:55,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2016-05-17 22:17:55,696 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463523293069_0014
2016-05-17 22:17:55,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:36039/proxy/application_1463523293069_0014/
2016-05-17 22:18:23,568 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000010 is : 143
2016-05-17 22:18:24,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000003 is : 143
2016-05-17 22:18:24,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000011 is : 143
2016-05-17 22:18:24,959 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000002 is : 143
2016-05-17 22:18:25,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000007 is : 143
2016-05-17 22:18:25,161 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000008 is : 143
2016-05-17 22:18:25,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000004 is : 143
2016-05-17 22:18:25,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000009 is : 143
2016-05-17 22:18:25,429 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000006 is : 143
2016-05-17 22:18:25,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000005 is : 143
2016-05-17 22:18:30,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463523293069_0014_01_000012 is : 143
2016-05-17 22:18:31,289 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/testCascade/third/_temporary
2016-05-17 22:18:31,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:35.713, using cpu time: 00:11.630
2016-05-17 22:18:31,291 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2016-05-17 22:18:31,315 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first2
2016-05-17 22:18:31,327 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/first1
2016-05-17 22:18:31,335 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/third
2016-05-17 22:18:31,339 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second2
2016-05-17 22:18:31,349 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/testCascade/second1