2016-01-15 04:53:06,383 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 04:53:06,410 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-mr1
2016-01-15 04:53:06,444 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-15 04:53:07,582 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 04:53:08,326 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-15 04:53:12,736 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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 04:53:12,965 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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 04:53:13,195 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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 04:53:13,382 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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 04:53:30,477 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 04:53:30,499 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 992F7AC603A745ADBA4F1C3CD726A0EF
2016-01-15 04:53:30,528 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:53:30,529 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 04:53:30,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2016-01-15 04:53:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:53:30,707 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-15 04:53:30,732 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-15 04:53:30,818 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:53:30,818 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 04:53:30,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-15 04:53:30,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:53:30,868 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-15 04:53:30,870 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-15 04:53:30,969 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:53:30,970 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 04:53:31,122 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.142
2016-01-15 04:53:31,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 04:53:31,126 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-15 04:53:31,199 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-15 04:53:31,221 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 04:53:31,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 04:53:31,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:53:31,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:53:31,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2016-01-15 04:53:31,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 04:53:31,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 04:53:31,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 04:53:31,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-15 04:53:31,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-15 04:53:32,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0001
2016-01-15 04:53:32,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0002
2016-01-15 04:53:32,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0001/
2016-01-15 04:53:32,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0002/
2016-01-15 04:53:52,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0001_01_000002 is : 143
2016-01-15 04:53:53,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0001_01_000005 is : 143
2016-01-15 04:53:53,939 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0001_01_000006 is : 143
2016-01-15 04:53:54,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0001_01_000004 is : 143
2016-01-15 04:53:59,754 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0001_01_000007 is : 143
2016-01-15 04:54:25,997 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0002_01_000002 is : 143
2016-01-15 04:54:26,131 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0002_01_000003 is : 143
2016-01-15 04:54:26,572 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0002_01_000004 is : 143
2016-01-15 04:54:26,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0002_01_000006 is : 143
2016-01-15 04:54:33,572 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0002_01_000007 is : 143
2016-01-15 04:54:34,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...mpleted/COMPLETED/stopped
2016-01-15 04:54:34,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0003
2016-01-15 04:54:34,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0003/
2016-01-15 04:54:53,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0003_01_000003 is : 143
2016-01-15 04:54:53,478 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0003_01_000002 is : 143
2016-01-15 04:54:59,986 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0003_01_000004 is : 143
2016-01-15 04:55:01,210 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2016-01-15 04:55:01,212 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@3a999cef 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-15 04:55:01,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-15 04:55:01,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...mpleted/COMPLETED/stopped
2016-01-15 04:55:01,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-15 04:55:04,570 WARN hdfs.DFSClient (DFSInputStream.java:close(669)) - DFSInputStream has been closed already
2016-01-15 04:55:04,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-15 04:55:07,772 WARN hdfs.DFSClient (DFSInputStream.java:close(669)) - DFSInputStream has been closed already
2016-01-15 04:55:07,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-15 04:55:07,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:29.980, using cpu time: 00:16.870
2016-01-15 04:55:07,775 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2016-01-15 04:55:07,820 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:55:07,820 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 04:55:07,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.127
2016-01-15 04:55:07,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 04:55:07,960 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-15 04:55:08,020 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-15 04:55:08,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 04:55:08,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:55:08,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:55:08,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2016-01-15 04:55:08,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 04:55:08,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 04:55:08,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 04:55:08,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-15 04:55:08,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-15 04:55:08,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0004
2016-01-15 04:55:08,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0004/
2016-01-15 04:55:08,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0005
2016-01-15 04:55:08,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0005/
2016-01-15 04:55:27,680 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000004 is : 143
2016-01-15 04:55:27,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000003 is : 143
2016-01-15 04:55:28,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000002 is : 143
2016-01-15 04:55:28,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000005 is : 143
2016-01-15 04:55:28,878 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000006 is : 143
2016-01-15 04:55:40,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000007 is : 143
2016-01-15 04:55:41,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000009 is : 143
2016-01-15 04:55:41,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000010 is : 143
2016-01-15 04:55:42,431 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000008 is : 143
2016-01-15 04:55:45,412 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000016
2016-01-15 04:55:45,455 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000017
2016-01-15 04:55:46,412 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000018
2016-01-15 04:55:51,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000012 is : 143
2016-01-15 04:55:51,950 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000013 is : 143
2016-01-15 04:55:52,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000014 is : 143
2016-01-15 04:55:52,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000015 is : 143
2016-01-15 04:55:55,615 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000023
2016-01-15 04:55:56,307 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000024
2016-01-15 04:55:56,460 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000025
2016-01-15 04:55:56,558 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452833604975_0004_01_000026
2016-01-15 04:56:01,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000019 is : 143
2016-01-15 04:56:01,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000011 is : 143
2016-01-15 04:56:01,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000021 is : 143
2016-01-15 04:56:01,666 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000022 is : 143
2016-01-15 04:56:01,667 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0004_01_000020 is : 143
2016-01-15 04:56:02,794 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] hadoop job job_1452833604975_0004 state at FAILED
2016-01-15 04:56:02,795 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] failure info: Task failed task_1452833604975_0004_m_000002
Job failed as tasks failed. failedMaps:1 failedReduces:0
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events identify failed tasks
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events count: 10
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000002_0, Status : FAILED
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000001_0, Status : FAILED
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000000_0, Status : FAILED
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000003_0, Status : FAILED
2016-01-15 04:56:02,832 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000004_0, Status : SUCCEEDED
2016-01-15 04:56:02,833 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000002_1, Status : FAILED
2016-01-15 04:56:02,833 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000000_1, Status : FAILED
2016-01-15 04:56:02,833 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000003_1, Status : FAILED
2016-01-15 04:56:02,833 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000001_1, Status : FAILED
2016-01-15 04:56:02,833 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452833604975_0004_m_000002_2, Status : FAILED
2016-01-15 04:56:27,812 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0005_01_000006 is : 143
2016-01-15 04:56:27,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0005_01_000002 is : 143
2016-01-15 04:56:28,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0005_01_000003 is : 143
2016-01-15 04:56:28,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0005_01_000004 is : 143
2016-01-15 04:56:28,498 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0005_01_000005 is : 143
2016-01-15 04:56:34,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0005_01_000007 is : 143
2016-01-15 04:56:36,064 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (2/3)
2016-01-15 04:56:36,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-15 04:56:36,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-15 04:56:36,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-15 04:56:36,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-15 04:56:39,266 WARN hdfs.DFSClient (DFSInputStream.java:close(669)) - DFSInputStream has been closed already
2016-01-15 04:56:39,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-15 04:56:39,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-15 04:56:39,270 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@3fc9cb31 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-15 04:56:39,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-15 04:56:39,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-15 04:56:39,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-15 04:56:39,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-15 04:56:39,273 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-15 04:56:39,274 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:31.247, using cpu time: 00:07.770
2016-01-15 04:56:39,275 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2016-01-15 04:56:39,296 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:56:39,296 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 04:56:39,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-01-15 04:56:39,389 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 04:56:39,389 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-15 04:56:39,426 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2016-01-15 04:56:39,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 04:56:39,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:56:39,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:56:39,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testStop/stopped"]
2016-01-15 04:56:39,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 04:56:39,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 04:56:39,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 04:56:39,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-15 04:56:39,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-15 04:56:39,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0006
2016-01-15 04:56:39,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0006/
2016-01-15 04:56:39,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0007
2016-01-15 04:56:39,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0007/
2016-01-15 04:56:44,427 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:45,429 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:46,430 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:47,431 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:48,432 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:49,433 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:50,434 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:51,436 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:52,438 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:53,439 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:54,441 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:55,442 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:56,443 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:57,444 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:58,447 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:56:59,448 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:57:00,449 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-15 04:57:00,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0006_01_000002 is : 143
2016-01-15 04:57:00,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0006_01_000005 is : 143
2016-01-15 04:57:01,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0006_01_000003 is : 143
2016-01-15 04:57:01,408 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0006_01_000006 is : 143
2016-01-15 04:57:01,452 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2016-01-15 04:57:01,452 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2016-01-15 04:57:01,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-15 04:57:01,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-15 04:57:01,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-15 04:57:01,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0006_01_000004 is : 143
2016-01-15 04:57:01,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-15 04:57:03,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-15 04:57:03,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2016-01-15 04:57:03,689 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (1/3)
2016-01-15 04:57:03,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-15 04:57:03,690 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (2/3)
2016-01-15 04:57:03,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-15 04:57:03,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2016-01-15 04:57:03,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:22.025, using cpu time: 00:05.430
2016-01-15 04:57:03,725 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testStop/stopped
2016-01-15 04:57:03,748 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:57:03,748 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 04:57:03,831 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-15 04:57:03,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 04:57:03,833 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-15 04:57:03,875 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-15 04:57:03,878 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@178a250 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-15 04:57:03,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-15 04:57:03,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Starting/STARTING/stopped
2016-01-15 04:57:03,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-15 04:57:03,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-15 04:57:03,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-15 04:57:03,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 04:57:03,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:57:03,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:57:03,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2016-01-15 04:57:03,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 04:57:03,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 04:57:03,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 04:57:03,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.002
2016-01-15 04:57:03,884 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped
2016-01-15 04:57:03,902 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:57:03,902 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 04:57:03,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-15 04:57:03,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:57:03,948 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-15 04:57:03,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping all jobs
2016-01-15 04:57:03,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2016-01-15 04:57:03,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopped all jobs
2016-01-15 04:57:03,967 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testStartStopRace/startstop
2016-01-15 04:57:03,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 16815:04:57:03.966
2016-01-15 04:57:04,001 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:57:04,001 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 04:57:04,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-01-15 04:57:04,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-15 04:57:04,089 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-15 04:57:04,139 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-15 04:57:04,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 04:57:04,142 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:04,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:57:04,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:57:04,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2016-01-15 04:57:04,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-15 04:57:04,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-15 04:57:04,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-15 04:57:04,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-15 04:57:04,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-15 04:57:04,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0008
2016-01-15 04:57:04,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0008/
2016-01-15 04:57:04,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452833604975_0009
2016-01-15 04:57:04,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0009/
2016-01-15 04:57:05,144 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:06,148 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:07,149 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:08,150 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:09,151 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:10,152 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:11,153 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:12,154 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:13,155 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:14,156 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:15,157 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:16,158 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:17,160 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:18,161 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:19,162 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:20,164 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:21,165 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:22,166 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:23,168 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:24,170 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:25,176 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:26,177 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:27,177 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-15 04:57:28,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0008_01_000004 is : 143
2016-01-15 04:57:28,178 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2016-01-15 04:57:28,178 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@7c9a1aeb 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-15 04:57:28,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-15 04:57:28,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-15 04:57:28,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-15 04:57:28,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-15 04:57:28,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0008_01_000005 is : 143
2016-01-15 04:57:28,574 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0008_01_000006 is : 143
2016-01-15 04:57:28,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0008_01_000002 is : 143
2016-01-15 04:57:30,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-15 04:57:30,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2016-01-15 04:57:30,418 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (1/3)
2016-01-15 04:57:30,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-15 04:57:30,418 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (2/3)
2016-01-15 04:57:30,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-15 04:57:30,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2016-01-15 04:57:30,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.038, using cpu time: 00:02.180
2016-01-15 04:57:30,456 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped
2016-01-15 04:57:30,472 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:57:30,472 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 04:57:30,503 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-15 04:57:30,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:57:30,504 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-15 04:57:30,518 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2016-01-15 04:57:30,535 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:57:30,536 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 04:57:30,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-15 04:57:30,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:57:30,558 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-15 04:57:30,585 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:57:30,585 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 04:57:30,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-15 04:57:30,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:57:30,616 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-15 04:57:30,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-15 04:57:30,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:57:30,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete"]
2016-01-15 04:57:30,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-15 04:57:30,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-15 04:57:30,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-15 04:57:30,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2016-01-15 04:57:30,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452833604975_0010
2016-01-15 04:57:30,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165:38682/proxy/application_1452833604975_0010/
2016-01-15 04:57:54,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0010_01_000004 is : 143
2016-01-15 04:57:54,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0010_01_000003 is : 143
2016-01-15 04:57:54,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0010_01_000002 is : 143
2016-01-15 04:57:55,027 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0010_01_000006 is : 143
2016-01-15 04:57:55,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0010_01_000005 is : 143
2016-01-15 04:58:01,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452833604975_0010_01_000007 is : 143
2016-01-15 04:58:02,701 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2016-01-15 04:58:02,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:32.072, using cpu time: 00:06.860
2016-01-15 04:58:02,703 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete
2016-01-15 04:58:02,726 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:58:02,726 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 04:58:02,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 04:58:02,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:58:02,748 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-15 04:58:02,749 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-15 04:58:02,764 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:58:02,765 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 04:58:02,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-15 04:58:02,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:58:02,797 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-15 04:58:02,799 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-15 04:58:02,818 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:58:02,819 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 04:58:02,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 04:58:02,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 04:58:02,853 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-15 04:58:02,865 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailedSerialization/badserialization