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'