2016-01-14 19:04:47,002 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 19:04:47,029 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-mr1
2016-01-14 19:04:47,066 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-14 19:04:47,969 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-14 19:04:48,511 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 19:04:49,086 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 19:04:51,957 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 19:04:52,102 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 19:04:52,214 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 19:04:52,329 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 19:05:09,403 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 19:05:09,427 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 612593C2BBB14C4FA0724D882E3700DB
2016-01-14 19:05:09,453 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:05:09,453 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-14 19:05:09,622 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2016-01-14 19:05:09,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:05:09,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:05:09,650 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 19:05:09,734 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:05:09,734 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-14 19:05:09,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 19:05:09,779 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:05:09,779 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:05:09,782 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 19:05:09,884 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:05:09,884 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-14 19:05:10,045 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.152
2016-01-14 19:05:10,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 19:05:10,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:05:10,139 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 19:05:10,160 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 19:05:10,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 19:05:10,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 19:05:10,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:05:10,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2016-01-14 19:05:10,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 19:05:10,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 19:05:10,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 19:05:10,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 19:05:10,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 19:05:11,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0001
2016-01-14 19:05:11,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0001/
2016-01-14 19:05:11,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0002
2016-01-14 19:05:11,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0002/
2016-01-14 19:05:46,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0002_01_000005 is : 143
2016-01-14 19:05:47,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0001_01_000006 is : 143
2016-01-14 19:05:47,308 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0002_01_000006 is : 143
2016-01-14 19:05:47,642 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0002_01_000004 is : 143
2016-01-14 19:05:47,766 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0002_01_000003 is : 143
2016-01-14 19:05:47,987 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0001_01_000004 is : 143
2016-01-14 19:05:49,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0002_01_000002 is : 143
2016-01-14 19:05:55,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0001_01_000007 is : 143
2016-01-14 19:05:56,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0002_01_000007 is : 143
2016-01-14 19:05:57,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...mpleted/COMPLETED/stopped
2016-01-14 19:05:57,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0003
2016-01-14 19:05:57,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0003/
2016-01-14 19:06:15,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0003_01_000002 is : 143
2016-01-14 19:06:15,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0003_01_000003 is : 143
2016-01-14 19:06:22,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0003_01_000004 is : 143
2016-01-14 19:06:23,406 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2016-01-14 19:06:23,407 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@1b1b505c threw throwable
java.lang.RuntimeException: intentionally failed on: COMPLETED
at cascading.flow.FailingFlowListener.onCompleted(FailingFlowListener.java:61)
at cascading.flow.BaseFlow$SafeFlowListener.onCompleted(BaseFlow.java:1632)
at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1353)
at cascading.flow.BaseFlow.run(BaseFlow.java:1223)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 19:06:23,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 19:06:23,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...mpleted/COMPLETED/stopped
2016-01-14 19:06:23,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 19:06:26,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 19:06:30,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 19:06:30,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:13.235, using cpu time: 00:16.400
2016-01-14 19:06:30,208 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2016-01-14 19:06:30,244 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:06:30,245 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-14 19:06:30,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.119
2016-01-14 19:06:30,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 19:06:30,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:06:30,428 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 19:06:30,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 19:06:30,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 19:06:30,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:06:30,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2016-01-14 19:06:30,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 19:06:30,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 19:06:30,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 19:06:30,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 19:06:30,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 19:06:30,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0004
2016-01-14 19:06:30,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0004/
2016-01-14 19:06:30,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0005
2016-01-14 19:06:30,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0005/
2016-01-14 19:07:00,278 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0004_01_000002 is : 143
2016-01-14 19:07:03,539 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0004_01_000004 is : 143
2016-01-14 19:07:04,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0004_01_000005 is : 143
2016-01-14 19:07:04,803 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0004_01_000006 is : 143
2016-01-14 19:07:05,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000006 is : 143
2016-01-14 19:07:05,614 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000005 is : 143
2016-01-14 19:07:06,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000003 is : 143
2016-01-14 19:07:07,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000004 is : 143
2016-01-14 19:07:07,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000002 is : 143
2016-01-14 19:07:10,575 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000012
2016-01-14 19:07:10,673 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000013
2016-01-14 19:07:11,575 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000014
2016-01-14 19:07:16,921 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0004_01_000007 is : 143
2016-01-14 19:07:21,760 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000007 is : 143
2016-01-14 19:07:22,086 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000008 is : 143
2016-01-14 19:07:22,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000009 is : 143
2016-01-14 19:07:22,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000011 is : 143
2016-01-14 19:07:25,595 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000019
2016-01-14 19:07:25,699 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000020
2016-01-14 19:07:26,141 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000021
2016-01-14 19:07:26,595 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000022
2016-01-14 19:07:32,123 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000016 is : 143
2016-01-14 19:07:32,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000017 is : 143
2016-01-14 19:07:32,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000015 is : 143
2016-01-14 19:07:33,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000018 is : 143
2016-01-14 19:07:36,431 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000028
2016-01-14 19:07:37,083 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000029
2016-01-14 19:07:37,343 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452798303900_0005_01_000027
2016-01-14 19:07:42,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000023 is : 143
2016-01-14 19:07:42,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000025 is : 143
2016-01-14 19:07:42,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000026 is : 143
2016-01-14 19:07:42,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000024 is : 143
2016-01-14 19:07:42,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0005_01_000010 is : 143
2016-01-14 19:07:43,475 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] hadoop job job_1452798303900_0005 state at FAILED
2016-01-14 19:07:43,477 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] failure info: Task failed task_1452798303900_0005_m_000001
Job failed as tasks failed. failedMaps:1 failedReduces:0
2016-01-14 19:07:43,503 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events identify failed tasks
2016-01-14 19:07:43,504 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events count: 10
2016-01-14 19:07:43,504 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000004_0, Status : SUCCEEDED
2016-01-14 19:07:43,504 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000003_0, Status : FAILED
2016-01-14 19:07:43,504 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000001_0, Status : FAILED
2016-01-14 19:07:43,504 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000002_0, Status : FAILED
2016-01-14 19:07:43,505 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000000_0, Status : FAILED
2016-01-14 19:07:43,505 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000003_1, Status : FAILED
2016-01-14 19:07:43,505 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000001_1, Status : FAILED
2016-01-14 19:07:43,505 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000002_1, Status : FAILED
2016-01-14 19:07:43,506 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000000_1, Status : FAILED
2016-01-14 19:07:43,506 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452798303900_0005_m_000001_2, Status : FAILED
2016-01-14 19:07:43,506 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (2/3)
2016-01-14 19:07:43,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-14 19:07:43,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 19:07:43,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-14 19:07:43,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 19:07:43,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 19:07:46,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 19:07:46,707 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@4111f10d threw throwable
java.lang.RuntimeException: intentionally failed on: THROWABLE
at cascading.flow.FailingFlowListener.onThrowable(FailingFlowListener.java:69)
at cascading.flow.BaseFlow$SafeFlowListener.onThrowable(BaseFlow.java:1644)
at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1373)
at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1272)
at cascading.flow.BaseFlow.run(BaseFlow.java:1212)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 19:07:46,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 19:07:46,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-14 19:07:46,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 19:07:46,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 19:07:46,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 19:07:46,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:16.276, using cpu time: 00:08.270
2016-01-14 19:07:46,713 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2016-01-14 19:07:46,732 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:07:46,732 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-14 19:07:46,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-01-14 19:07:46,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 19:07:46,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:07:46,862 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2016-01-14 19:07:46,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 19:07:46,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 19:07:46,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:07:46,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testStop/stopped"]
2016-01-14 19:07:46,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 19:07:46,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 19:07:46,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 19:07:46,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 19:07:46,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 19:07:47,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0006
2016-01-14 19:07:47,152 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0006/
2016-01-14 19:07:47,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0007
2016-01-14 19:07:47,195 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0007/
2016-01-14 19:07:51,863 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:52,874 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:53,899 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:54,901 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:55,902 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:56,923 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:57,926 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:58,928 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:07:59,963 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:00,997 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:02,035 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:03,074 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:04,116 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:05,175 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:06,179 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:07,216 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:08,244 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:09,276 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:10,357 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:11,399 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:12,421 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:13,427 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:14,447 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 19:08:15,515 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2016-01-14 19:08:15,515 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2016-01-14 19:08:15,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 19:08:15,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-14 19:08:15,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0006_01_000003 is : 143
2016-01-14 19:08:15,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 19:08:16,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0007_01_000005 is : 143
2016-01-14 19:08:16,376 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0006_01_000002 is : 143
2016-01-14 19:08:16,533 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0007_01_000004 is : 143
2016-01-14 19:08:16,583 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0007_01_000006 is : 143
2016-01-14 19:08:16,815 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0007_01_000002 is : 143
2016-01-14 19:08:16,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0007_01_000003 is : 143
2016-01-14 19:08:17,022 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0006_01_000005 is : 143
2016-01-14 19:08:17,189 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0006_01_000004 is : 143
2016-01-14 19:08:18,715 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 19:08:18,726 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (1/3)
2016-01-14 19:08:18,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-14 19:08:18,727 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (2/3)
2016-01-14 19:08:18,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-14 19:08:18,830 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-01-14 19:08:18,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0006_01_000007 is : 143
2016-01-14 19:08:20,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 19:08:20,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2016-01-14 19:08:20,861 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2016-01-14 19:08:20,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:28.650, using cpu time: 00:05.280
2016-01-14 19:08:20,864 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testStop/stopped
2016-01-14 19:08:20,885 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:08:20,885 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-14 19:08:20,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.105
2016-01-14 19:08:21,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 19:08:21,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:08:21,051 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 19:08:21,056 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@1c6a310f threw throwable
java.lang.RuntimeException: intentionally failed on: STARTING
at cascading.flow.FailingFlowListener.onStarting(FailingFlowListener.java:45)
at cascading.flow.BaseFlow$SafeFlowListener.onStarting(BaseFlow.java:1608)
at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1400)
at cascading.flow.BaseFlow.run(BaseFlow.java:1161)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 19:08:21,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 19:08:21,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Starting/STARTING/stopped
2016-01-14 19:08:21,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 19:08:21,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 19:08:21,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 19:08:21,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 19:08:21,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 19:08:21,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:08:21,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2016-01-14 19:08:21,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 19:08:21,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 19:08:21,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 19:08:21,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.004
2016-01-14 19:08:21,065 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped
2016-01-14 19:08:21,081 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:08:21,082 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-14 19:08:21,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 19:08:21,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:08:21,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:08:21,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping all jobs
2016-01-14 19:08:21,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 16814:19:08:21.138
2016-01-14 19:08:21,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2016-01-14 19:08:21,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopped all jobs
2016-01-14 19:08:21,140 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testStartStopRace/startstop
2016-01-14 19:08:21,162 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:08:21,163 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-14 19:08:21,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.092
2016-01-14 19:08:21,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 19:08:21,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:08:21,318 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 19:08:21,321 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:21,322 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 19:08:21,322 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 19:08:21,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:08:21,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2016-01-14 19:08:21,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 19:08:21,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 19:08:21,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 19:08:21,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 19:08:21,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 19:08:21,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0008
2016-01-14 19:08:21,602 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0008/
2016-01-14 19:08:21,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452798303900_0009
2016-01-14 19:08:21,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0009/
2016-01-14 19:08:22,323 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:23,324 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:24,324 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:25,325 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:26,333 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:27,343 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:28,346 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:29,373 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:30,399 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:31,400 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:32,401 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:33,452 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:34,480 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:35,562 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:36,614 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:37,662 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:38,680 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:39,706 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:40,722 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:41,784 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:42,807 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:43,851 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:44,855 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:45,897 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:46,901 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:47,949 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:48,997 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:50,048 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:51,049 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:51,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0008_01_000006 is : 143
2016-01-14 19:08:51,714 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0008_01_000005 is : 143
2016-01-14 19:08:52,097 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:53,116 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:53,395 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0008_01_000002 is : 143
2016-01-14 19:08:54,163 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:54,745 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0008_01_000004 is : 143
2016-01-14 19:08:55,193 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:56,237 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:57,251 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:58,283 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:59,290 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 19:08:59,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0009_01_000002 is : 143
2016-01-14 19:08:59,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0009_01_000004 is : 143
2016-01-14 19:09:00,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0009_01_000005 is : 143
2016-01-14 19:09:00,251 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0009_01_000006 is : 143
2016-01-14 19:09:00,299 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2016-01-14 19:09:00,299 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@7e717965 threw throwable
java.lang.RuntimeException: intentionally failed on: STOPPING
at cascading.flow.FailingFlowListener.onStopping(FailingFlowListener.java:53)
at cascading.flow.BaseFlow$SafeFlowListener.onStopping(BaseFlow.java:1620)
at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1388)
at cascading.flow.BaseFlow.stop(BaseFlow.java:890)
at cascading.flow.hadoop.FlowPlatformTest.failingListenerTest(FlowPlatformTest.java:419)
at cascading.flow.hadoop.FlowPlatformTest.testFailingListenerStopping(FlowPlatformTest.java:328)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
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-14 19:09:00,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 19:09:00,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-14 19:09:00,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 19:09:00,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0009_01_000003 is : 143
2016-01-14 19:09:00,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0008_01_000007 is : 143
2016-01-14 19:09:02,373 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 19:09:02,400 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-1_0/usercache/teamcity/appcache/application_1452798303900_0009/container_1452798303900_0009_01_000007]
2016-01-14 19:09:02,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-1_1/usercache/teamcity/appcache/application_1452798303900_0009/container_1452798303900_0009_01_000007]
2016-01-14 19:09:02,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-1_2/usercache/teamcity/appcache/application_1452798303900_0009/container_1452798303900_0009_01_000007]
2016-01-14 19:09:02,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-1_3/usercache/teamcity/appcache/application_1452798303900_0009/container_1452798303900_0009_01_000007]
2016-01-14 19:09:02,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-01-14 19:09:04,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 19:09:04,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2016-01-14 19:09:04,394 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (1/3)
2016-01-14 19:09:04,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-14 19:09:04,394 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (2/3)
2016-01-14 19:09:04,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-14 19:09:04,439 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2016-01-14 19:09:04,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:38.980, using cpu time: 00:10.400
2016-01-14 19:09:04,442 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped
2016-01-14 19:09:04,462 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:09:04,463 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-14 19:09:04,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 19:09:04,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:09:04,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:09:04,494 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2016-01-14 19:09:04,521 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:09:04,521 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-14 19:09:04,547 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 19:09:04,548 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:09:04,548 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:09:04,580 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:09:04,581 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-14 19:09:04,610 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 19:09:04,611 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:09:04,611 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:09:04,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-14 19:09:04,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:09:04,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete"]
2016-01-14 19:09:04,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-14 19:09:04,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-14 19:09:04,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-14 19:09:04,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2016-01-14 19:09:04,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452798303900_0010
2016-01-14 19:09:04,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165.ec2.internal:43884/proxy/application_1452798303900_0010/
2016-01-14 19:09:26,716 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0010_01_000006 is : 143
2016-01-14 19:09:26,842 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0010_01_000003 is : 143
2016-01-14 19:09:27,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0010_01_000005 is : 143
2016-01-14 19:09:27,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0010_01_000002 is : 143
2016-01-14 19:09:27,234 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0010_01_000004 is : 143
2016-01-14 19:09:33,648 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452798303900_0010_01_000007 is : 143
2016-01-14 19:09:34,865 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2016-01-14 19:09:34,866 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete
2016-01-14 19:09:34,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:30.235, using cpu time: 00:06.020
2016-01-14 19:09:34,888 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:09:34,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-14 19:09:34,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 19:09:34,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:09:34,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:09:34,911 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 19:09:34,938 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:09:34,938 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-14 19:09:34,958 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 19:09:34,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:09:34,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:09:34,961 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 19:09:34,984 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:09:34,985 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-14 19:09:35,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 19:09:35,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 19:09:35,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:09:35,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/testFailedSerialization/badserialization