Class cascading.cascade.CascadePlatformTest

8

tests

0

failures

0

ignored

5m39.22s

duration

100%

successful

Tests

Test Duration Result
testCascadeID 0.166s passed
testCheckpointTapCascade 1m49.18s passed
testMultiTapCascade 1m3.84s passed
testPlannerFailureDuplicateSinks 0.112s passed
testSimpleCascade 1m23.45s passed
testSimpleCascadeFail 42.883s passed
testSimpleCascadeStop 26.694s passed
testSkippedCascade 12.897s passed

Standard output

2016-05-17 22:09:07,746 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:09:07,776 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.cascade.CascadePlatformTest, with platform: hadoop2-mr1
2016-05-17 22:09:07,808 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-17 22:09:08,626 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:09:09,145 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 22:09:13,998 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:09:15,236 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:09:16,383 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:09:17,516 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:09:20,061 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-17 22:09:20,149 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,150 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:09:20,216 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: A42669EF03DF4CADAD375B917DA78895
2016-05-17 22:09:20,320 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-17 22:09:20,322 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,323 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,446 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,447 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:09:20,496 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 22:09:20,498 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,498 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,532 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,532 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:09:20,570 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 22:09:20,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,602 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,602 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:09:20,648 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 22:09:20,650 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,650 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,680 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:09:20,680 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting
2016-05-17 22:09:20,685 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth]  parallel execution of flows is enabled: true
2016-05-17 22:09:20,685 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth]  executing total flows: 4
2016-05-17 22:09:20,686 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth]  allocating management threads: 4
2016-05-17 22:09:20,686 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: first
2016-05-17 22:09:20,688 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: first
2016-05-17 22:09:20,689 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: second
2016-05-17 22:09:20,690 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: second
2016-05-17 22:09:20,691 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: third
2016-05-17 22:09:20,691 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: third
2016-05-17 22:09:20,692 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: fourth
2016-05-17 22:09:20,693 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: fourth
2016-05-17 22:09:20,698 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/cascadeplatform/testSkippedCascade/skipped/second
2016-05-17 22:09:20,699 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/cascadeplatform/testSkippedCascade/skipped/third
2016-05-17 22:09:20,700 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/cascadeplatform/testSkippedCascade/skipped/fourth
2016-05-17 22:09:20,702 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/cascadeplatform/testSkippedCascade/skipped/first
2016-05-17 22:09:20,725 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,726 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:09:20,774 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:09:20,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,820 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,821 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:09:20,865 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 22:09:20,867 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,892 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:09:20,893 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:09:20,926 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:09:20,927 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:09:20,927 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:09:20,944 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting
2016-05-17 22:09:20,946 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...]  parallel execution of flows is enabled: true
2016-05-17 22:09:20,946 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...]  executing total flows: 3
2016-05-17 22:09:20,946 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...]  allocating management threads: 3
2016-05-17 22:09:20,947 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: previous-multi-tap-second
2016-05-17 22:09:20,947 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] at least one sink is marked for delete
2016-05-17 22:09:20,947 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: previous-multi-tap-first
2016-05-17 22:09:20,948 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] at least one sink is marked for delete
2016-05-17 22:09:20,948 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:09:20,948 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:09:20,966 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] starting
2016-05-17 22:09:20,967 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] starting
2016-05-17 22:09:20,967 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second]  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:09:20,968 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first]  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:09:20,968 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/second"]
2016-05-17 22:09:20,968 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/first"]
2016-05-17 22:09:20,969 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first]  parallel execution of steps is enabled: true
2016-05-17 22:09:20,968 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second]  parallel execution of steps is enabled: true
2016-05-17 22:09:20,969 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second]  executing total steps: 1
2016-05-17 22:09:20,969 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second]  allocating management threads: 1
2016-05-17 22:09:20,970 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first]  executing total steps: 1
2016-05-17 22:09:20,970 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] starting step: (1/1) ...apCascade/multitap/second
2016-05-17 22:09:20,970 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first]  allocating management threads: 1
2016-05-17 22:09:20,972 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] starting step: (1/1) ...TapCascade/multitap/first
2016-05-17 22:09:21,739 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] submitted hadoop job: job_1463522952116_0002
2016-05-17 22:09:21,739 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] submitted hadoop job: job_1463522952116_0001
2016-05-17 22:09:21,739 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0001/
2016-05-17 22:09:21,739 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0002/
2016-05-17 22:09:48,548 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0002_01_000005 is : 143
2016-05-17 22:09:48,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0002_01_000004 is : 143
2016-05-17 22:09:49,747 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0002_01_000003 is : 143
2016-05-17 22:09:50,088 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0001_01_000002 is : 143
2016-05-17 22:09:50,164 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0001_01_000004 is : 143
2016-05-17 22:09:50,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0001_01_000003 is : 143
2016-05-17 22:09:50,567 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0001_01_000005 is : 143
2016-05-17 22:09:51,855 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/cascadeplatform/testMultiTapCascade/multitap/second/_temporary
2016-05-17 22:09:51,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-second]  completed in: 00:30.885, using cpu time: 00:04.400
2016-05-17 22:09:51,857 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: previous-multi-tap-second
2016-05-17 22:09:51,857 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/cascadeplatform/testMultiTapCascade/multitap/first/_temporary
2016-05-17 22:09:51,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [previous-multi-tap-first]  completed in: 00:30.882, using cpu time: 00:03.900
2016-05-17 22:09:51,859 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: previous-multi-tap-first
2016-05-17 22:09:51,860 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: multi-tap
2016-05-17 22:09:51,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] at least one sink is marked for delete
2016-05-17 22:09:51,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:09:51,863 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] starting
2016-05-17 22:09:51,864 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap]  source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/first"], Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/second"]]]
2016-05-17 22:09:51,864 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/multitap"]
2016-05-17 22:09:51,865 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap]  parallel execution of steps is enabled: true
2016-05-17 22:09:51,865 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap]  executing total steps: 1
2016-05-17 22:09:51,865 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap]  allocating management threads: 1
2016-05-17 22:09:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] starting step: (1/1) ...Cascade/multitap/multitap
2016-05-17 22:09:52,041 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] submitted hadoop job: job_1463522952116_0003
2016-05-17 22:09:52,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0003/
2016-05-17 22:10:22,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0003_01_000009 is : 143
2016-05-17 22:10:22,776 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0003_01_000008 is : 143
2016-05-17 22:10:22,850 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0003_01_000002 is : 143
2016-05-17 22:10:22,929 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0003_01_000005 is : 143
2016-05-17 22:10:23,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0003_01_000003 is : 143
2016-05-17 22:10:23,144 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0003_01_000007 is : 143
2016-05-17 22:10:24,415 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/cascadeplatform/testMultiTapCascade/multitap/multitap/_temporary
2016-05-17 22:10:24,416 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [multi-tap]  completed in: 00:32.549, using cpu time: 00:08.110
2016-05-17 22:10:24,416 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: multi-tap
2016-05-17 22:10:24,497 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/cascadeplatform/testMultiTapCascade/multitap/multitap
2016-05-17 22:10:24,518 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/cascadeplatform/testMultiTapCascade/multitap/first
2016-05-17 22:10:24,530 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/cascadeplatform/testMultiTapCascade/multitap/second
2016-05-17 22:10:24,556 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:10:24,557 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:10:24,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-17 22:10:24,593 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:10:24,593 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:10:24,614 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:10:24,615 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:10:24,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 22:10:24,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:10:24,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:10:24,674 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:10:24,675 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:10:24,686 INFO  planner.FlowPlanner (FlowPlanner.java:makeTempTap(768)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/third"]
2016-05-17 22:10:24,719 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 22:10:24,721 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 22:10:24,721 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:10:24,750 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:10:24,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-17 22:10:24,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:10:24,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:10:24,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:10:24,796 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting
2016-05-17 22:10:24,797 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first]  parallel execution of flows is enabled: true
2016-05-17 22:10:24,797 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first]  executing total flows: 4
2016-05-17 22:10:24,798 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first]  allocating management threads: 4
2016-05-17 22:10:24,799 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: first
2016-05-17 22:10:24,799 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 22:10:24,799 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:10:24,802 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 22:10:24,802 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  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:10:24,802 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/first"]
2016-05-17 22:10:24,802 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  parallel execution of steps is enabled: true
2016-05-17 22:10:24,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  executing total steps: 1
2016-05-17 22:10:24,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  allocating management threads: 1
2016-05-17 22:10:24,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...pCascade/checkpoint/first
2016-05-17 22:10:24,951 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_1463522952116_0004
2016-05-17 22:10:24,951 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0004/
2016-05-17 22:10:40,491 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0004_01_000005 is : 143
2016-05-17 22:10:40,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0004_01_000003 is : 143
2016-05-17 22:10:40,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0004_01_000002 is : 143
2016-05-17 22:10:40,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0004_01_000004 is : 143
2016-05-17 22:10:41,865 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/cascadeplatform/testCheckpointTapCascade/checkpoint/first/_temporary
2016-05-17 22:10:41,867 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  completed in: 00:17.061, using cpu time: 00:03.850
2016-05-17 22:10:41,867 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: first
2016-05-17 22:10:41,868 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: second
2016-05-17 22:10:41,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] at least one sink is marked for delete
2016-05-17 22:10:41,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:10:41,871 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting
2016-05-17 22:10:41,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/first"]
2016-05-17 22:10:41,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/second"]
2016-05-17 22:10:41,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  parallel execution of steps is enabled: true
2016-05-17 22:10:41,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  executing total steps: 1
2016-05-17 22:10:41,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  allocating management threads: 1
2016-05-17 22:10:41,876 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting step: (1/1) ...Cascade/checkpoint/second
2016-05-17 22:10:42,031 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] submitted hadoop job: job_1463522952116_0005
2016-05-17 22:10:42,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0005/
2016-05-17 22:10:59,673 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0005_01_000003 is : 143
2016-05-17 22:10:59,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0005_01_000005 is : 143
2016-05-17 22:10:59,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0005_01_000002 is : 143
2016-05-17 22:11:00,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0005_01_000004 is : 143
2016-05-17 22:11:00,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0005_01_000006 is : 143
2016-05-17 22:11:01,573 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/cascadeplatform/testCheckpointTapCascade/checkpoint/second/_temporary
2016-05-17 22:11:01,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  completed in: 00:19.699, using cpu time: 00:04.590
2016-05-17 22:11:01,574 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: second
2016-05-17 22:11:01,574 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: null
2016-05-17 22:11:01,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] at least one sink is marked for delete
2016-05-17 22:11:01,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:11:01,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-17 22:11:01,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/second"]
2016-05-17 22:11:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/unusedpath"]
2016-05-17 22:11:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-17 22:11:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 2
2016-05-17 22:11:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 2
2016-05-17 22:11:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/2) ...pCascade/checkpoint/third
2016-05-17 22:11:01,754 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463522952116_0006
2016-05-17 22:11:01,754 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0006/
2016-05-17 22:11:21,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0006_01_000006 is : 143
2016-05-17 22:11:21,377 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0006_01_000007 is : 143
2016-05-17 22:11:21,930 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0006_01_000004 is : 143
2016-05-17 22:11:22,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0006_01_000002 is : 143
2016-05-17 22:11:22,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0006_01_000003 is : 143
2016-05-17 22:11:23,137 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0006_01_000005 is : 143
2016-05-17 22:11:24,335 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/2) ...ointTapCascade/unusedpath
2016-05-17 22:11:24,468 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463522952116_0007
2016-05-17 22:11:24,468 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0007/
2016-05-17 22:11:47,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000004 is : 143
2016-05-17 22:11:47,162 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000006 is : 143
2016-05-17 22:11:47,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000008 is : 143
2016-05-17 22:11:47,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000007 is : 143
2016-05-17 22:11:47,415 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000003 is : 143
2016-05-17 22:11:48,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000005 is : 143
2016-05-17 22:11:48,242 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0007_01_000002 is : 143
2016-05-17 22:11:49,469 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/cascadeplatform/testCheckpointTapCascade/checkpoint/third/_temporary
2016-05-17 22:11:49,471 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/cascadeplatform/testCheckpointTapCascade/unusedpath/_temporary
2016-05-17 22:11:49,473 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:47.889, using cpu time: 00:12.160
2016-05-17 22:11:49,473 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: null
2016-05-17 22:11:49,473 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: fourth
2016-05-17 22:11:49,473 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] at least one sink is marked for delete
2016-05-17 22:11:49,474 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:11:49,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting
2016-05-17 22:11:49,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/third"]
2016-05-17 22:11:49,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/fourth"]
2016-05-17 22:11:49,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  parallel execution of steps is enabled: true
2016-05-17 22:11:49,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  executing total steps: 1
2016-05-17 22:11:49,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  allocating management threads: 1
2016-05-17 22:11:49,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting step: (1/1) ...Cascade/checkpoint/fourth
2016-05-17 22:11:49,597 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] submitted hadoop job: job_1463522952116_0008
2016-05-17 22:11:49,597 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0008/
2016-05-17 22:12:10,835 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000006 is : 143
2016-05-17 22:12:11,188 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000007 is : 143
2016-05-17 22:12:12,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000008 is : 143
2016-05-17 22:12:12,085 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000004 is : 143
2016-05-17 22:12:12,285 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000003 is : 143
2016-05-17 22:12:12,350 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000002 is : 143
2016-05-17 22:12:12,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0008_01_000005 is : 143
2016-05-17 22:12:13,637 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/cascadeplatform/testCheckpointTapCascade/checkpoint/fourth/_temporary
2016-05-17 22:12:13,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  completed in: 00:24.158, using cpu time: 00:06.720
2016-05-17 22:12:13,638 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: fourth
2016-05-17 22:12:13,661 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/cascadeplatform/testCheckpointTapCascade/checkpoint/third
2016-05-17 22:12:13,674 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/cascadeplatform/testCheckpointTapCascade/checkpoint/fourth
2016-05-17 22:12:13,687 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/cascadeplatform/testCheckpointTapCascade/unusedpath
2016-05-17 22:12:13,699 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/cascadeplatform/testCheckpointTapCascade/checkpoint/second
2016-05-17 22:12:13,710 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/cascadeplatform/testCheckpointTapCascade/checkpoint/first
2016-05-17 22:12:13,732 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:13,732 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:12:13,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-17 22:12:13,760 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:13,760 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:13,782 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:13,782 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:12:13,806 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-17 22:12:13,806 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:13,807 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:13,837 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:13,838 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:12:13,861 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:12:13,862 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:13,863 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:13,880 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:13,881 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:12:13,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-17 22:12:13,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:13,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:13,916 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting
2016-05-17 22:12:13,916 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first]  parallel execution of flows is enabled: true
2016-05-17 22:12:13,917 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first]  executing total flows: 4
2016-05-17 22:12:13,917 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first]  allocating management threads: 4
2016-05-17 22:12:13,917 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: first
2016-05-17 22:12:13,917 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 22:12:13,918 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:12:13,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 22:12:13,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  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:12:13,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/first"]
2016-05-17 22:12:13,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  parallel execution of steps is enabled: true
2016-05-17 22:12:13,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  executing total steps: 1
2016-05-17 22:12:13,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  allocating management threads: 1
2016-05-17 22:12:13,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...eCascadeFail/simple/first
2016-05-17 22:12:14,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_1463522952116_0009
2016-05-17 22:12:14,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0009/
2016-05-17 22:12:29,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000003 is : 143
2016-05-17 22:12:29,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000004 is : 143
2016-05-17 22:12:29,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000002 is : 143
2016-05-17 22:12:29,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000005 is : 143
2016-05-17 22:12:33,069 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000010
2016-05-17 22:12:33,150 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000011
2016-05-17 22:12:33,358 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000012
2016-05-17 22:12:33,388 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000013
2016-05-17 22:12:38,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000006 is : 143
2016-05-17 22:12:38,865 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000007 is : 143
2016-05-17 22:12:39,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000008 is : 143
2016-05-17 22:12:39,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000009 is : 143
2016-05-17 22:12:43,074 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000018
2016-05-17 22:12:43,154 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000019
2016-05-17 22:12:43,384 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000020
2016-05-17 22:12:43,423 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000021
2016-05-17 22:12:47,991 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000015 is : 143
2016-05-17 22:12:48,544 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000014 is : 143
2016-05-17 22:12:49,368 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000017 is : 143
2016-05-17 22:12:49,614 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000016 is : 143
2016-05-17 22:12:52,605 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000026
2016-05-17 22:12:53,079 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000027
2016-05-17 22:12:53,355 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1463522952116_0009_01_000028
2016-05-17 22:12:55,228 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000022 is : 143
2016-05-17 22:12:55,312 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000025 is : 143
2016-05-17 22:12:55,368 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000024 is : 143
2016-05-17 22:12:55,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0009_01_000023 is : 143
2016-05-17 22:12:56,528 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] hadoop job job_1463522952116_0009 state at FAILED
2016-05-17 22:12:56,529 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] failure info: Task failed task_1463522952116_0009_m_000002
Job failed as tasks failed. failedMaps:1 failedReduces:0

2016-05-17 22:12:56,553 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] task completion events identify failed tasks
2016-05-17 22:12:56,553 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] task completion events count: 10
2016-05-17 22:12:56,554 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000001_0, Status : FAILED
2016-05-17 22:12:56,554 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000002_0, Status : FAILED
2016-05-17 22:12:56,554 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000000_0, Status : FAILED
2016-05-17 22:12:56,554 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000003_0, Status : FAILED
2016-05-17 22:12:56,555 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000001_1, Status : FAILED
2016-05-17 22:12:56,555 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000002_1, Status : FAILED
2016-05-17 22:12:56,555 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000000_1, Status : FAILED
2016-05-17 22:12:56,555 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000003_1, Status : FAILED
2016-05-17 22:12:56,556 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000002_2, Status : FAILED
2016-05-17 22:12:56,556 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [first] event = Task Id : attempt_1463522952116_0009_m_000001_2, Status : FAILED
2016-05-17 22:12:56,582 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopping all jobs
2016-05-17 22:12:56,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopping: (1/1) ...eCascadeFail/simple/first
2016-05-17 22:12:56,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopped all jobs
2016-05-17 22:12:56,587 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/cascadeplatform/testSimpleCascadeFail/simple/first/_temporary
2016-05-17 22:12:56,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  completed in: 00:42.665
2016-05-17 22:12:56,589 WARN  cascade.Cascade (BaseCascade.java:logWarn(878)) - [fourth+second+third+first] flow failed: first
cascading.flow.FlowException: step failed: (1/1) ...eCascadeFail/simple/first, step id: A4E080AB6D274E6892A61A5E4B6C9E17, job id: job_1463522952116_0009, please see cluster logs for failure messages
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:295)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:184)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-05-17 22:12:56,592 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping all flows
2016-05-17 22:12:56,592 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: fourth
2016-05-17 22:12:56,594 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] stopping all jobs
2016-05-17 22:12:56,595 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] stopping: (1/1) ...CascadeFail/simple/fourth
2016-05-17 22:12:56,595 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] stopped all jobs
2016-05-17 22:12:56,595 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: third
2016-05-17 22:12:56,595 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] stopping all jobs
2016-05-17 22:12:56,596 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] stopping: (1/1) ...eCascadeFail/simple/third
2016-05-17 22:12:56,596 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] stopped all jobs
2016-05-17 22:12:56,596 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: second
2016-05-17 22:12:56,596 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] stopping all jobs
2016-05-17 22:12:56,596 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] stopping: (1/1) ...CascadeFail/simple/second
2016-05-17 22:12:56,597 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] stopped all jobs
2016-05-17 22:12:56,597 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: first
2016-05-17 22:12:56,597 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopping all jobs
2016-05-17 22:12:56,597 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopping: (1/1) ...eCascadeFail/simple/first
2016-05-17 22:12:56,598 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopped all jobs
2016-05-17 22:12:56,598 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopped all flows
2016-05-17 22:12:56,598 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/cascadeplatform/testSimpleCascadeFail/simple/second
2016-05-17 22:12:56,599 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/cascadeplatform/testSimpleCascadeFail/simple/third
2016-05-17 22:12:56,599 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/cascadeplatform/testSimpleCascadeFail/simple/fourth
2016-05-17 22:12:56,600 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/cascadeplatform/testSimpleCascadeFail/simple/first
2016-05-17 22:12:56,614 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:56,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-17 22:12:56,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:12:56,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:56,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:56,655 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:56,655 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:12:56,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:12:56,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:56,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:56,695 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:56,696 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:12:56,719 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:12:56,720 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:56,721 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:12:56,739 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:12:56,739 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:12:56,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-17 22:12:56,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:12:56,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
calling start
2016-05-17 22:12:56,777 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting
2016-05-17 22:12:56,777 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth]  parallel execution of flows is enabled: true
2016-05-17 22:12:56,778 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth]  executing total flows: 4
2016-05-17 22:12:56,778 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth]  allocating management threads: 4
2016-05-17 22:12:56,778 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: first
2016-05-17 22:12:56,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 22:12:56,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
testing if running
2016-05-17 22:12:56,782 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 22:12:56,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  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:12:56,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascadeStop/stopped/first-nondeterministic"]
2016-05-17 22:12:56,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  parallel execution of steps is enabled: true
2016-05-17 22:12:56,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  executing total steps: 1
2016-05-17 22:12:56,785 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  allocating management threads: 1
2016-05-17 22:12:56,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2016-05-17 22:12:56,917 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_1463522952116_0010
2016-05-17 22:12:56,917 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0010/
testing if running
testing if running
testing if running
testing if running
testing if running
2016-05-17 22:13:02,159 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(833)) - Event EventType: FINISH_APPLICATION sent to absent application application_1463522952116_0009
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
2016-05-17 22:13:12,306 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0010_01_000005 is : 143
2016-05-17 22:13:12,485 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0010_01_000003 is : 143
2016-05-17 22:13:12,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0010_01_000002 is : 143
2016-05-17 22:13:12,696 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0010_01_000004 is : 143
calling stop
2016-05-17 22:13:12,810 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping all flows
2016-05-17 22:13:12,811 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: fourth
2016-05-17 22:13:12,811 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] stopping all jobs
2016-05-17 22:13:12,811 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2016-05-17 22:13:12,811 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] stopped all jobs
2016-05-17 22:13:12,812 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: third
2016-05-17 22:13:12,812 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] stopping all jobs
2016-05-17 22:13:12,812 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2016-05-17 22:13:12,812 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] stopped all jobs
2016-05-17 22:13:12,812 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: second
2016-05-17 22:13:12,813 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] stopping all jobs
2016-05-17 22:13:12,813 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] stopping: (1/1) ...d/second-nondeterministic
2016-05-17 22:13:12,813 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] stopped all jobs
2016-05-17 22:13:12,813 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: first
2016-05-17 22:13:12,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopping all jobs
2016-05-17 22:13:12,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2016-05-17 22:13:23,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] stopped all jobs
2016-05-17 22:13:23,276 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopped all flows
2016-05-17 22:13:23,276 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] shutting down flow executor
2016-05-17 22:13:23,277 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  completed in: 00:16.032, using cpu time: 00:03.770
2016-05-17 22:13:23,277 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] completed flow: first
2016-05-17 22:13:23,278 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] shutdown complete
2016-05-17 22:13:23,279 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/cascadeplatform/testSimpleCascadeStop/stopped/fourth-nondeterministic
2016-05-17 22:13:23,280 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/cascadeplatform/testSimpleCascadeStop/stopped/third-nondeterministic
2016-05-17 22:13:23,281 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/cascadeplatform/testSimpleCascadeStop/stopped/second-nondeterministic
2016-05-17 22:13:23,282 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/cascadeplatform/testSimpleCascadeStop/stopped/first-nondeterministic
2016-05-17 22:13:23,319 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:13:23,319 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:13:23,346 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 22:13:23,348 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:13:23,348 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:13:23,367 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:13:23,367 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:13:23,403 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:13:23,405 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:13:23,406 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:13:23,436 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:13:23,437 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:13:23,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:13:23,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:13:23,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:13:23,526 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:13:23,526 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:13:23,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-17 22:13:23,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:13:23,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:13:23,573 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting
2016-05-17 22:13:23,574 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first]  parallel execution of flows is enabled: true
2016-05-17 22:13:23,574 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first]  executing total flows: 4
2016-05-17 22:13:23,574 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first]  allocating management threads: 4
2016-05-17 22:13:23,576 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: first
2016-05-17 22:13:23,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] at least one sink is marked for delete
2016-05-17 22:13:23,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:13:23,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting
2016-05-17 22:13:23,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  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:13:23,580 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/first"]
2016-05-17 22:13:23,580 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  parallel execution of steps is enabled: true
2016-05-17 22:13:23,581 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  executing total steps: 1
2016-05-17 22:13:23,581 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  allocating management threads: 1
2016-05-17 22:13:23,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] starting step: (1/1) ...impleCascade/simple/first
2016-05-17 22:13:23,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] submitted hadoop job: job_1463522952116_0011
2016-05-17 22:13:23,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0011/
2016-05-17 22:13:39,283 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0011_01_000004 is : 143
2016-05-17 22:13:39,587 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0011_01_000002 is : 143
2016-05-17 22:13:39,627 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0011_01_000003 is : 143
2016-05-17 22:13:39,711 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0011_01_000005 is : 143
2016-05-17 22:13:40,920 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/cascadeplatform/testSimpleCascade/simple/first/_temporary
2016-05-17 22:13:40,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first]  completed in: 00:17.339, using cpu time: 00:03.790
2016-05-17 22:13:40,921 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: first
2016-05-17 22:13:40,921 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: second
2016-05-17 22:13:40,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] at least one sink is marked for delete
2016-05-17 22:13:40,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:13:40,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting
2016-05-17 22:13:40,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/first"]
2016-05-17 22:13:40,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/second"]
2016-05-17 22:13:40,926 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  parallel execution of steps is enabled: true
2016-05-17 22:13:40,926 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  executing total steps: 1
2016-05-17 22:13:40,926 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  allocating management threads: 1
2016-05-17 22:13:40,927 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] starting step: (1/1) ...mpleCascade/simple/second
2016-05-17 22:13:41,039 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] submitted hadoop job: job_1463522952116_0012
2016-05-17 22:13:41,040 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0012/
2016-05-17 22:13:58,476 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0012_01_000002 is : 143
2016-05-17 22:13:58,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0012_01_000004 is : 143
2016-05-17 22:13:58,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0012_01_000006 is : 143
2016-05-17 22:13:58,822 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0012_01_000003 is : 143
2016-05-17 22:14:00,053 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/cascadeplatform/testSimpleCascade/simple/second/_temporary
2016-05-17 22:14:00,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second]  completed in: 00:19.126, using cpu time: 00:04.660
2016-05-17 22:14:00,055 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: second
2016-05-17 22:14:00,055 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: third
2016-05-17 22:14:00,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] at least one sink is marked for delete
2016-05-17 22:14:00,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:14:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] starting
2016-05-17 22:14:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/second"]
2016-05-17 22:14:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/third"]
2016-05-17 22:14:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third]  parallel execution of steps is enabled: true
2016-05-17 22:14:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third]  executing total steps: 1
2016-05-17 22:14:00,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third]  allocating management threads: 1
2016-05-17 22:14:00,060 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] starting step: (1/1) ...impleCascade/simple/third
2016-05-17 22:14:00,179 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] submitted hadoop job: job_1463522952116_0013
2016-05-17 22:14:00,179 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0013/
2016-05-17 22:14:19,570 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0013_01_000007 is : 143
2016-05-17 22:14:19,750 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0013_01_000005 is : 143
2016-05-17 22:14:20,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0013_01_000004 is : 143
2016-05-17 22:14:20,331 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0013_01_000003 is : 143
2016-05-17 22:14:20,487 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0013_01_000002 is : 143
2016-05-17 22:14:21,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0013_01_000006 is : 143
2016-05-17 22:14:22,469 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/cascadeplatform/testSimpleCascade/simple/third/_temporary
2016-05-17 22:14:22,471 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third]  completed in: 00:22.409, using cpu time: 00:05.420
2016-05-17 22:14:22,471 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: third
2016-05-17 22:14:22,471 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: fourth
2016-05-17 22:14:22,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] at least one sink is marked for delete
2016-05-17 22:14:22,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-17 22:14:22,476 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting
2016-05-17 22:14:22,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/third"]
2016-05-17 22:14:22,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/fourth"]
2016-05-17 22:14:22,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  parallel execution of steps is enabled: true
2016-05-17 22:14:22,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  executing total steps: 1
2016-05-17 22:14:22,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  allocating management threads: 1
2016-05-17 22:14:22,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] starting step: (1/1) ...mpleCascade/simple/fourth
2016-05-17 22:14:22,598 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] submitted hadoop job: job_1463522952116_0014
2016-05-17 22:14:22,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] tracking url: http://ip-10-158-37-203:44955/proxy/application_1463522952116_0014/
2016-05-17 22:14:44,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0014_01_000006 is : 143
2016-05-17 22:14:44,353 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0014_01_000007 is : 143
2016-05-17 22:14:45,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0014_01_000005 is : 143
2016-05-17 22:14:45,294 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0014_01_000008 is : 143
2016-05-17 22:14:45,430 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0014_01_000003 is : 143
2016-05-17 22:14:45,458 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463522952116_0014_01_000002 is : 143
2016-05-17 22:14:46,680 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/cascadeplatform/testSimpleCascade/simple/fourth/_temporary
2016-05-17 22:14:46,682 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth]  completed in: 00:24.202, using cpu time: 00:06.660
2016-05-17 22:14:46,682 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: fourth
2016-05-17 22:14:46,706 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/cascadeplatform/testSimpleCascade/simple/first
2016-05-17 22:14:46,716 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/cascadeplatform/testSimpleCascade/simple/second
2016-05-17 22:14:46,726 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/cascadeplatform/testSimpleCascade/simple/fourth
2016-05-17 22:14:46,738 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/cascadeplatform/testSimpleCascade/simple/third
2016-05-17 22:14:46,762 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:14:46,762 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:14:46,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 22:14:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:14:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:14:46,801 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:14:46,801 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:14:46,823 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 22:14:46,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:14:46,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:14:46,840 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:14:46,841 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:14:46,863 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 22:14:46,864 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:14:46,864 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:14:46,881 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:14:46,881 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:14:46,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 22:14:46,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:14:46,905 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:14:46,913 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/cascadeplatform/testCascadeID/idtest/first
2016-05-17 22:14:46,914 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/cascadeplatform/testCascadeID/idtest/fourth
2016-05-17 22:14:46,915 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/cascadeplatform/testCascadeID/idtest/third
2016-05-17 22:14:46,915 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/cascadeplatform/testCascadeID/idtest/second
2016-05-17 22:14:46,928 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:14:46,928 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:14:46,951 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 22:14:46,952 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:14:46,952 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:14:46,985 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:14:46,985 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:14:47,014 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 22:14:47,016 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 22:14:47,016 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'

Standard error

May 17, 2016 10:09:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
May 17, 2016 10:09:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
May 17, 2016 10:09:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 17, 2016 10:09:14 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 17, 2016 10:09:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:14 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:15 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 17, 2016 10:09:15 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:15 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:15 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
May 17, 2016 10:09:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 17, 2016 10:09:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 17, 2016 10:09:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 17, 2016 10:09:16 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 17, 2016 10:09:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:16 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:16 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
May 17, 2016 10:09:17 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 17, 2016 10:09:17 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 17, 2016 10:09:17 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 17, 2016 10:09:17 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 17, 2016 10:09:17 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:17 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:17 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:17 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
May 17, 2016 10:09:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
May 17, 2016 10:09:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 17, 2016 10:09:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
May 17, 2016 10:09:18 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
May 17, 2016 10:09:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
May 17, 2016 10:09:18 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.