2016-01-15 01:53:16,751 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 01:53:16,785 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.cascade.CascadePlatformTest, with platform: hadoop2-mr1
2016-01-15 01:53:16,822 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-15 01:53:17,867 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-01-15 01:53:18,573 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-15 01:53:23,037 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-15 01:53:23,256 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-15 01:53:23,437 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-15 01:53:23,622 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-15 01:53:40,743 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 01:53:40,840 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:40,841 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:40,932 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 1E2E494488414C83A2C906817A258DE4
2016-01-15 01:53:41,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-01-15 01:53:41,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,043 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,163 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:41,164 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:41,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-01-15 01:53:41,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,258 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:41,258 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:41,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-15 01:53:41,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,353 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:41,354 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:41,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-15 01:53:41,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,444 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 01:53:41,445 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting
2016-01-15 01:53:41,449 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] parallel execution of flows is enabled: true
2016-01-15 01:53:41,450 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] executing total flows: 4
2016-01-15 01:53:41,450 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] allocating management threads: 4
2016-01-15 01:53:41,451 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: first
2016-01-15 01:53:41,457 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: first
2016-01-15 01:53:41,458 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: second
2016-01-15 01:53:41,458 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: second
2016-01-15 01:53:41,460 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: third
2016-01-15 01:53:41,460 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: third
2016-01-15 01:53:41,461 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: fourth
2016-01-15 01:53:41,462 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: fourth
2016-01-15 01:53:41,469 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSkippedCascade/skipped/fourth
2016-01-15 01:53:41,470 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSkippedCascade/skipped/third
2016-01-15 01:53:41,471 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSkippedCascade/skipped/second
2016-01-15 01:53:41,473 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSkippedCascade/skipped/first
2016-01-15 01:53:41,539 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:41,540 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:41,579 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-15 01:53:41,580 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,581 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,609 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:41,610 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:41,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-15 01:53:41,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,675 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:53:41,675 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:53:41,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 01:53:41,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:53:41,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:53:41,729 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting
2016-01-15 01:53:41,731 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] parallel execution of flows is enabled: true
2016-01-15 01:53:41,731 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] executing total flows: 3
2016-01-15 01:53:41,731 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] allocating management threads: 3
2016-01-15 01:53:41,732 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: previous-multi-tap-second
2016-01-15 01:53:41,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] at least one sink is marked for delete
2016-01-15 01:53:41,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:53:41,732 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: previous-multi-tap-first
2016-01-15 01:53:41,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] at least one sink is marked for delete
2016-01-15 01:53:41,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:53:41,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] starting
2016-01-15 01:53:41,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] starting
2016-01-15 01:53:41,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 01:53:41,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/first"]
2016-01-15 01:53:41,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] parallel execution of steps is enabled: true
2016-01-15 01:53:41,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] executing total steps: 1
2016-01-15 01:53:41,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] allocating management threads: 1
2016-01-15 01:53:41,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 01:53:41,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/second"]
2016-01-15 01:53:41,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] parallel execution of steps is enabled: true
2016-01-15 01:53:41,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] executing total steps: 1
2016-01-15 01:53:41,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] allocating management threads: 1
2016-01-15 01:53:41,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] starting step: (1/1) ...apCascade/multitap/second
2016-01-15 01:53:41,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] starting step: (1/1) ...TapCascade/multitap/first
2016-01-15 01:53:42,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] submitted hadoop job: job_1452822815241_0001
2016-01-15 01:53:42,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] submitted hadoop job: job_1452822815241_0002
2016-01-15 01:53:42,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0002/
2016-01-15 01:53:42,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0001/
2016-01-15 01:54:11,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0001_01_000003 is : 143
2016-01-15 01:54:11,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0001_01_000002 is : 143
2016-01-15 01:54:13,694 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0001_01_000004 is : 143
2016-01-15 01:54:14,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0001_01_000005 is : 143
2016-01-15 01:54:14,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0002_01_000002 is : 143
2016-01-15 01:54:14,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0002_01_000005 is : 143
2016-01-15 01:54:15,349 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0002_01_000004 is : 143
2016-01-15 01:54:15,980 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/first/_temporary
2016-01-15 01:54:15,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] completed in: 00:34.215, using cpu time: 00:04.770
2016-01-15 01:54:15,982 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: previous-multi-tap-first
2016-01-15 01:54:16,579 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/second/_temporary
2016-01-15 01:54:16,581 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] completed in: 00:34.819, using cpu time: 00:04.850
2016-01-15 01:54:16,581 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: previous-multi-tap-second
2016-01-15 01:54:16,581 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: multi-tap
2016-01-15 01:54:16,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] at least one sink is marked for delete
2016-01-15 01:54:16,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:54:16,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] starting
2016-01-15 01:54:16,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/first"], Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/second"]]]
2016-01-15 01:54:16,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/multitap"]
2016-01-15 01:54:16,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] parallel execution of steps is enabled: true
2016-01-15 01:54:16,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] executing total steps: 1
2016-01-15 01:54:16,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] allocating management threads: 1
2016-01-15 01:54:16,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] starting step: (1/1) ...Cascade/multitap/multitap
2016-01-15 01:54:16,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] submitted hadoop job: job_1452822815241_0003
2016-01-15 01:54:16,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0003/
2016-01-15 01:54:47,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000007 is : 143
2016-01-15 01:54:47,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000005 is : 143
2016-01-15 01:54:48,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000002 is : 143
2016-01-15 01:54:48,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000009 is : 143
2016-01-15 01:54:48,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000003 is : 143
2016-01-15 01:54:48,829 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000008 is : 143
2016-01-15 01:54:48,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0003_01_000004 is : 143
2016-01-15 01:54:50,174 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/multitap/_temporary
2016-01-15 01:54:50,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] completed in: 00:33.585, using cpu time: 00:09.530
2016-01-15 01:54:50,175 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: multi-tap
2016-01-15 01:54:50,220 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/second
2016-01-15 01:54:50,233 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/first
2016-01-15 01:54:50,247 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testMultiTapCascade/multitap/multitap
2016-01-15 01:54:50,286 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:54:50,287 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:54:50,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-15 01:54:50,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:54:50,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:54:50,358 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:54:50,358 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:54:50,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 01:54:50,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:54:50,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:54:50,408 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:54:50,408 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:54:50,419 INFO planner.FlowPlanner (FlowPlanner.java:makeTempTap(767)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/third"]
2016-01-15 01:54:50,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-15 01:54:50,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-15 01:54:50,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:54:50,497 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:54:50,497 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:54:50,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 01:54:50,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:54:50,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:54:50,540 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting
2016-01-15 01:54:50,540 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] parallel execution of flows is enabled: true
2016-01-15 01:54:50,540 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] executing total flows: 4
2016-01-15 01:54:50,540 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] allocating management threads: 4
2016-01-15 01:54:50,541 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: first
2016-01-15 01:54:50,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-15 01:54:50,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:54:50,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-15 01:54:50,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 01:54:50,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/first"]
2016-01-15 01:54:50,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-15 01:54:50,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-15 01:54:50,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-15 01:54:50,547 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...pCascade/checkpoint/first
2016-01-15 01:54:50,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_1452822815241_0004
2016-01-15 01:54:50,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0004/
2016-01-15 01:55:07,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0004_01_000005 is : 143
2016-01-15 01:55:08,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0004_01_000004 is : 143
2016-01-15 01:55:08,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0004_01_000002 is : 143
2016-01-15 01:55:08,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0004_01_000003 is : 143
2016-01-15 01:55:09,478 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/first/_temporary
2016-01-15 01:55:09,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:18.931, using cpu time: 00:04.710
2016-01-15 01:55:09,480 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: first
2016-01-15 01:55:09,480 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: second
2016-01-15 01:55:09,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] at least one sink is marked for delete
2016-01-15 01:55:09,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:55:09,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2016-01-15 01:55:09,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/first"]
2016-01-15 01:55:09,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/second"]
2016-01-15 01:55:09,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] parallel execution of steps is enabled: true
2016-01-15 01:55:09,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executing total steps: 1
2016-01-15 01:55:09,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] allocating management threads: 1
2016-01-15 01:55:09,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...Cascade/checkpoint/second
2016-01-15 01:55:09,617 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted hadoop job: job_1452822815241_0005
2016-01-15 01:55:09,617 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0005/
2016-01-15 01:55:28,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0005_01_000003 is : 143
2016-01-15 01:55:28,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0005_01_000002 is : 143
2016-01-15 01:55:28,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0005_01_000006 is : 143
2016-01-15 01:55:29,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0005_01_000004 is : 143
2016-01-15 01:55:29,919 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0005_01_000005 is : 143
2016-01-15 01:55:31,104 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/second/_temporary
2016-01-15 01:55:31,106 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] completed in: 00:21.618, using cpu time: 00:05.590
2016-01-15 01:55:31,106 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: second
2016-01-15 01:55:31,106 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: null
2016-01-15 01:55:31,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] at least one sink is marked for delete
2016-01-15 01:55:31,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:55:31,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-15 01:55:31,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/second"]
2016-01-15 01:55:31,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/unusedpath"]
2016-01-15 01:55:31,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2016-01-15 01:55:31,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 2
2016-01-15 01:55:31,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 2
2016-01-15 01:55:31,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...pCascade/checkpoint/third
2016-01-15 01:55:31,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452822815241_0006
2016-01-15 01:55:31,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0006/
2016-01-15 01:55:52,548 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0006_01_000002 is : 143
2016-01-15 01:55:52,670 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0006_01_000003 is : 143
2016-01-15 01:55:53,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0006_01_000004 is : 143
2016-01-15 01:55:53,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0006_01_000005 is : 143
2016-01-15 01:55:53,711 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0006_01_000007 is : 143
2016-01-15 01:55:53,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0006_01_000006 is : 143
2016-01-15 01:55:55,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...ointTapCascade/unusedpath
2016-01-15 01:55:55,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452822815241_0007
2016-01-15 01:55:55,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0007/
2016-01-15 01:56:18,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000003 is : 143
2016-01-15 01:56:18,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000002 is : 143
2016-01-15 01:56:18,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000008 is : 143
2016-01-15 01:56:19,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000006 is : 143
2016-01-15 01:56:19,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000007 is : 143
2016-01-15 01:56:19,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000005 is : 143
2016-01-15 01:56:19,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0007_01_000004 is : 143
2016-01-15 01:56:20,939 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/third/_temporary
2016-01-15 01:56:20,941 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/unusedpath/_temporary
2016-01-15 01:56:20,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:49.826, using cpu time: 00:14.150
2016-01-15 01:56:20,943 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: null
2016-01-15 01:56:20,943 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] starting flow: fourth
2016-01-15 01:56:20,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] at least one sink is marked for delete
2016-01-15 01:56:20,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:56:20,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting
2016-01-15 01:56:20,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/third"]
2016-01-15 01:56:20,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/fourth"]
2016-01-15 01:56:20,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] parallel execution of steps is enabled: true
2016-01-15 01:56:20,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executing total steps: 1
2016-01-15 01:56:20,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] allocating management threads: 1
2016-01-15 01:56:20,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting step: (1/1) ...Cascade/checkpoint/fourth
2016-01-15 01:56:21,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] submitted hadoop job: job_1452822815241_0008
2016-01-15 01:56:21,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0008/
2016-01-15 01:56:43,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000002 is : 143
2016-01-15 01:56:44,047 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000003 is : 143
2016-01-15 01:56:44,791 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000008 is : 143
2016-01-15 01:56:45,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000006 is : 143
2016-01-15 01:56:45,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000007 is : 143
2016-01-15 01:56:45,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000004 is : 143
2016-01-15 01:56:45,647 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0008_01_000005 is : 143
2016-01-15 01:56:46,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/fourth/_temporary
2016-01-15 01:56:46,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] completed in: 00:25.912, using cpu time: 00:07.490
2016-01-15 01:56:46,862 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second++first] completed flow: fourth
2016-01-15 01:56:46,889 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/third
2016-01-15 01:56:46,903 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/fourth
2016-01-15 01:56:46,919 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/second
2016-01-15 01:56:46,932 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/checkpoint/first
2016-01-15 01:56:46,943 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCheckpointTapCascade/unusedpath
2016-01-15 01:56:46,973 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:56:46,974 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:56:47,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-15 01:56:47,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:56:47,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:56:47,030 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:56:47,030 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:56:47,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 01:56:47,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:56:47,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:56:47,076 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:56:47,076 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:56:47,103 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-15 01:56:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:56:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:56:47,123 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:56:47,123 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:56:47,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 01:56:47,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:56:47,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:56:47,159 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting
2016-01-15 01:56:47,160 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] parallel execution of flows is enabled: true
2016-01-15 01:56:47,160 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] executing total flows: 4
2016-01-15 01:56:47,161 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] allocating management threads: 4
2016-01-15 01:56:47,162 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: first
2016-01-15 01:56:47,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-15 01:56:47,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:56:47,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-15 01:56:47,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 01:56:47,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/first"]
2016-01-15 01:56:47,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-15 01:56:47,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-15 01:56:47,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-15 01:56:47,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...eCascadeFail/simple/first
2016-01-15 01:56:47,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_1452822815241_0009
2016-01-15 01:56:47,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0009/
2016-01-15 01:57:03,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000003 is : 143
2016-01-15 01:57:04,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000005 is : 143
2016-01-15 01:57:14,614 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000006 is : 143
2016-01-15 01:57:14,711 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000009 is : 143
2016-01-15 01:57:15,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000008 is : 143
2016-01-15 01:57:15,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000007 is : 143
2016-01-15 01:57:25,458 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000012 is : 143
2016-01-15 01:57:25,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000010 is : 143
2016-01-15 01:57:25,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000011 is : 143
2016-01-15 01:57:25,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000013 is : 143
2016-01-15 01:57:29,433 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1452822815241_0009_01_000018
2016-01-15 01:57:29,492 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1452822815241_0009_01_000019
2016-01-15 01:57:29,669 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1452822815241_0009_01_000020
2016-01-15 01:57:29,832 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1452822815241_0009_01_000021
2016-01-15 01:57:34,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000015 is : 143
2016-01-15 01:57:34,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000014 is : 143
2016-01-15 01:57:35,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000017 is : 143
2016-01-15 01:57:35,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0009_01_000016 is : 143
2016-01-15 01:57:36,172 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] hadoop job job_1452822815241_0009 state at FAILED
2016-01-15 01:57:36,173 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] failure info: Task failed task_1452822815241_0009_m_000000
Job failed as tasks failed. failedMaps:1 failedReduces:0
2016-01-15 01:57:36,197 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] task completion events identify failed tasks
2016-01-15 01:57:36,198 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] task completion events count: 10
2016-01-15 01:57:36,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000000_0, Status : FAILED
2016-01-15 01:57:36,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000001_0, Status : FAILED
2016-01-15 01:57:36,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000002_0, Status : FAILED
2016-01-15 01:57:36,200 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000003_0, Status : FAILED
2016-01-15 01:57:36,200 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000000_1, Status : FAILED
2016-01-15 01:57:36,200 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000003_1, Status : FAILED
2016-01-15 01:57:36,201 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000002_1, Status : FAILED
2016-01-15 01:57:36,201 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000001_1, Status : FAILED
2016-01-15 01:57:36,201 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000002_2, Status : FAILED
2016-01-15 01:57:36,201 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [first] event = Task Id : attempt_1452822815241_0009_m_000000_2, Status : FAILED
2016-01-15 01:57:36,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping all jobs
2016-01-15 01:57:36,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping: (1/1) ...eCascadeFail/simple/first
2016-01-15 01:57:36,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopped all jobs
2016-01-15 01:57:36,234 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/first/_temporary
2016-01-15 01:57:36,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:49.067
2016-01-15 01:57:36,236 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: DE85B328BE334F53819E703912FE8DBE, job id: job_1452822815241_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-01-15 01:57:36,239 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping all flows
2016-01-15 01:57:36,239 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: fourth
2016-01-15 01:57:36,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping all jobs
2016-01-15 01:57:36,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping: (1/1) ...CascadeFail/simple/fourth
2016-01-15 01:57:36,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopped all jobs
2016-01-15 01:57:36,243 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: third
2016-01-15 01:57:36,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping all jobs
2016-01-15 01:57:36,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping: (1/1) ...eCascadeFail/simple/third
2016-01-15 01:57:36,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopped all jobs
2016-01-15 01:57:36,244 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: second
2016-01-15 01:57:36,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping all jobs
2016-01-15 01:57:36,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping: (1/1) ...CascadeFail/simple/second
2016-01-15 01:57:36,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopped all jobs
2016-01-15 01:57:36,245 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: first
2016-01-15 01:57:36,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping all jobs
2016-01-15 01:57:36,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping: (1/1) ...eCascadeFail/simple/first
2016-01-15 01:57:36,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopped all jobs
2016-01-15 01:57:36,246 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopped all flows
2016-01-15 01:57:36,246 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/first
2016-01-15 01:57:36,249 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/third
2016-01-15 01:57:36,250 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/second
2016-01-15 01:57:36,251 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeFail/simple/fourth
2016-01-15 01:57:36,266 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:36,267 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:36,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 01:57:36,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:36,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:36,319 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:36,320 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:36,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 01:57:36,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:36,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:36,364 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:36,364 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:36,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 01:57:36,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:36,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:36,416 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:36,416 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:36,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 01:57:36,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:36,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
calling start
2016-01-15 01:57:36,454 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting
2016-01-15 01:57:36,455 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] parallel execution of flows is enabled: true
2016-01-15 01:57:36,455 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] executing total flows: 4
2016-01-15 01:57:36,455 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] allocating management threads: 4
2016-01-15 01:57:36,455 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: first
2016-01-15 01:57:36,456 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-15 01:57:36,456 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
testing if running
2016-01-15 01:57:36,459 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-15 01:57:36,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 01:57:36,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascadeStop/stopped/first-nondeterministic"]
2016-01-15 01:57:36,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-15 01:57:36,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-15 01:57:36,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-15 01:57:36,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2016-01-15 01:57:36,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_1452822815241_0010
2016-01-15 01:57:36,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0010/
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
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
2016-01-15 01:57:52,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0010_01_000002 is : 143
2016-01-15 01:57:53,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0010_01_000003 is : 143
calling stop
2016-01-15 01:57:53,477 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping all flows
2016-01-15 01:57:53,477 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: fourth
2016-01-15 01:57:53,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping all jobs
2016-01-15 01:57:53,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2016-01-15 01:57:53,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopped all jobs
2016-01-15 01:57:53,478 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: third
2016-01-15 01:57:53,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping all jobs
2016-01-15 01:57:53,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2016-01-15 01:57:53,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopped all jobs
2016-01-15 01:57:53,479 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: second
2016-01-15 01:57:53,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping all jobs
2016-01-15 01:57:53,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping: (1/1) ...d/second-nondeterministic
2016-01-15 01:57:53,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopped all jobs
2016-01-15 01:57:53,480 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: first
2016-01-15 01:57:53,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping all jobs
2016-01-15 01:57:53,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2016-01-15 01:57:53,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0010_01_000005 is : 143
2016-01-15 01:57:53,595 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0010_01_000004 is : 143
2016-01-15 01:57:55,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopped all jobs
2016-01-15 01:57:55,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] shutting down job executor
2016-01-15 01:57:55,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] shutdown complete
2016-01-15 01:57:55,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:17.021, using cpu time: 00:02.400
2016-01-15 01:57:55,540 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] completed flow: first
2016-01-15 01:57:55,540 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopped all flows
2016-01-15 01:57:55,543 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] shutting down flow executor
2016-01-15 01:57:55,544 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] shutdown complete
2016-01-15 01:57:55,544 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeStop/stopped/third-nondeterministic
2016-01-15 01:57:55,546 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeStop/stopped/second-nondeterministic
2016-01-15 01:57:55,547 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeStop/stopped/fourth-nondeterministic
2016-01-15 01:57:55,547 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascadeStop/stopped/first-nondeterministic
2016-01-15 01:57:55,564 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:55,564 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:55,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-15 01:57:55,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:55,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:55,608 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:55,609 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:55,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-15 01:57:55,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:55,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:55,657 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:55,658 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:55,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 01:57:55,686 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:55,686 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:55,719 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:57:55,720 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:57:55,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-15 01:57:55,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:57:55,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:57:55,756 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting
2016-01-15 01:57:55,756 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] parallel execution of flows is enabled: true
2016-01-15 01:57:55,756 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] executing total flows: 4
2016-01-15 01:57:55,757 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] allocating management threads: 4
2016-01-15 01:57:55,758 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: first
2016-01-15 01:57:55,758 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-15 01:57:55,758 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:57:55,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-15 01:57:55,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 01:57:55,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/first"]
2016-01-15 01:57:55,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-15 01:57:55,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-15 01:57:55,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-15 01:57:55,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...impleCascade/simple/first
2016-01-15 01:57:55,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_1452822815241_0011
2016-01-15 01:57:55,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0011/
2016-01-15 01:58:12,693 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0011_01_000003 is : 143
2016-01-15 01:58:12,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0011_01_000005 is : 143
2016-01-15 01:58:13,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0011_01_000004 is : 143
2016-01-15 01:58:14,255 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/first/_temporary
2016-01-15 01:58:14,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:18.490, using cpu time: 00:04.720
2016-01-15 01:58:14,256 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: first
2016-01-15 01:58:14,256 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: second
2016-01-15 01:58:14,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] at least one sink is marked for delete
2016-01-15 01:58:14,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:58:14,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2016-01-15 01:58:14,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/first"]
2016-01-15 01:58:14,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/second"]
2016-01-15 01:58:14,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] parallel execution of steps is enabled: true
2016-01-15 01:58:14,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executing total steps: 1
2016-01-15 01:58:14,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] allocating management threads: 1
2016-01-15 01:58:14,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...mpleCascade/simple/second
2016-01-15 01:58:14,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted hadoop job: job_1452822815241_0012
2016-01-15 01:58:14,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0012/
2016-01-15 01:58:32,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0012_01_000002 is : 143
2016-01-15 01:58:33,010 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0012_01_000003 is : 143
2016-01-15 01:58:33,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0012_01_000006 is : 143
2016-01-15 01:58:33,572 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0012_01_000004 is : 143
2016-01-15 01:58:33,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0012_01_000005 is : 143
2016-01-15 01:58:35,089 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/second/_temporary
2016-01-15 01:58:35,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] completed in: 00:20.827, using cpu time: 00:05.520
2016-01-15 01:58:35,091 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: second
2016-01-15 01:58:35,091 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: third
2016-01-15 01:58:35,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] at least one sink is marked for delete
2016-01-15 01:58:35,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:58:35,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting
2016-01-15 01:58:35,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/second"]
2016-01-15 01:58:35,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/third"]
2016-01-15 01:58:35,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] parallel execution of steps is enabled: true
2016-01-15 01:58:35,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executing total steps: 1
2016-01-15 01:58:35,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] allocating management threads: 1
2016-01-15 01:58:35,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting step: (1/1) ...impleCascade/simple/third
2016-01-15 01:58:35,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] submitted hadoop job: job_1452822815241_0013
2016-01-15 01:58:35,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0013/
2016-01-15 01:58:57,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0013_01_000005 is : 143
2016-01-15 01:58:57,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0013_01_000007 is : 143
2016-01-15 01:58:57,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0013_01_000006 is : 143
2016-01-15 01:58:57,759 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0013_01_000002 is : 143
2016-01-15 01:58:57,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0013_01_000004 is : 143
2016-01-15 01:58:58,624 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0013_01_000003 is : 143
2016-01-15 01:58:59,825 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/third/_temporary
2016-01-15 01:58:59,826 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] completed in: 00:24.729, using cpu time: 00:06.610
2016-01-15 01:58:59,826 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: third
2016-01-15 01:58:59,827 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: fourth
2016-01-15 01:58:59,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] at least one sink is marked for delete
2016-01-15 01:58:59,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 01:58:59,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting
2016-01-15 01:58:59,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/third"]
2016-01-15 01:58:59,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/fourth"]
2016-01-15 01:58:59,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] parallel execution of steps is enabled: true
2016-01-15 01:58:59,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executing total steps: 1
2016-01-15 01:58:59,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] allocating management threads: 1
2016-01-15 01:58:59,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting step: (1/1) ...mpleCascade/simple/fourth
2016-01-15 01:58:59,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] submitted hadoop job: job_1452822815241_0014
2016-01-15 01:58:59,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] tracking url: http://ip-10-167-78-165:41503/proxy/application_1452822815241_0014/
2016-01-15 01:59:22,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0014_01_000003 is : 143
2016-01-15 01:59:23,581 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0014_01_000002 is : 143
2016-01-15 01:59:24,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0014_01_000006 is : 143
2016-01-15 01:59:24,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0014_01_000008 is : 143
2016-01-15 01:59:24,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0014_01_000004 is : 143
2016-01-15 01:59:24,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452822815241_0014_01_000007 is : 143
2016-01-15 01:59:25,632 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/fourth/_temporary
2016-01-15 01:59:25,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] completed in: 00:25.798, using cpu time: 00:07.580
2016-01-15 01:59:25,634 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: fourth
2016-01-15 01:59:25,660 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/third
2016-01-15 01:59:25,674 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/second
2016-01-15 01:59:25,686 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/first
2016-01-15 01:59:25,697 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testSimpleCascade/simple/fourth
2016-01-15 01:59:25,750 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:59:25,751 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:59:25,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 01:59:25,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:59:25,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:59:25,804 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:59:25,805 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:59:25,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 01:59:25,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:59:25,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:59:25,847 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:59:25,847 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:59:25,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 01:59:25,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:59:25,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:59:25,889 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:59:25,889 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:59:25,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 01:59:25,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:59:25,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:59:25,919 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCascadeID/idtest/second
2016-01-15 01:59:25,920 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCascadeID/idtest/third
2016-01-15 01:59:25,921 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCascadeID/idtest/fourth
2016-01-15 01:59:25,922 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/testCascadeID/idtest/first
2016-01-15 01:59:25,936 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:59:25,937 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:59:25,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 01:59:25,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 01:59:25,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 01:59:25,987 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:59:25,987 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:59:26,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-15 01:59:26,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-15 01:59:26,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'