2015-08-14 03:57:47,098 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 03:57:47,157 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 03:57:47,157 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.flow.hadoop.FlowPlatformTest
2015-08-14 03:57:47,199 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 03:57:48,073 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
2015-08-14 03:57:48,823 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 03:57:49,415 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 03:57:52,873 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.
2015-08-14 03:57:53,113 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.
2015-08-14 03:57:53,286 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.
2015-08-14 03:57:53,465 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.
2015-08-14 03:58:10,579 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 03:58:10,610 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: ECD753E8AD1A459BAD54DE5E90F2972B
2015-08-14 03:58:10,653 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:58:10,654 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:58:10,746 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 03:58:10,848 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:58:10,849 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:58:10,862 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 03:58:10,897 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 03:58:11,047 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:58:11,047 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:58:11,155 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 03:58:11,190 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 03:58:11,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 03:58:11,192 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:58:11,192 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:58:11,193 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped"]
2015-08-14 03:58:11,194 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 03:58:11,195 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 03:58:11,195 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 03:58:11,197 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 03:58:11,197 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 03:58:12,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0001
2015-08-14 03:58:12,353 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0001/
2015-08-14 03:58:12,356 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0002
2015-08-14 03:58:12,356 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0002/
2015-08-14 03:58:32,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0001_01_000003 is : 143
2015-08-14 03:58:33,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0001_01_000002 is : 143
2015-08-14 03:58:33,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0001_01_000004 is : 143
2015-08-14 03:58:33,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0002_01_000003 is : 143
2015-08-14 03:58:34,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0002_01_000002 is : 143
2015-08-14 03:58:34,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0001_01_000005 is : 143
2015-08-14 03:58:34,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0002_01_000005 is : 143
2015-08-14 03:58:34,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0002_01_000006 is : 143
2015-08-14 03:58:34,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0002_01_000004 is : 143
2015-08-14 03:58:36,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0001_01_000006 is : 143
2015-08-14 03:58:40,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0001_01_000007 is : 143
2015-08-14 03:58:41,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0002_01_000007 is : 143
2015-08-14 03:58:42,786 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...latform/COMPLETED/stopped
2015-08-14 03:58:43,047 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0003
2015-08-14 03:58:43,048 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0003/
2015-08-14 03:59:00,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0003_01_000002 is : 143
2015-08-14 03:59:00,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0003_01_000003 is : 143
2015-08-14 03:59:08,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0003_01_000004 is : 143
2015-08-14 03:59:09,439 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped/_temporary
2015-08-14 03:59:09,441 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@1ce6942e 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:1548)
at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1303)
at cascading.flow.BaseFlow.run(BaseFlow.java:1187)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:78)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:834)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 03:59:09,446 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 03:59:09,447 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/COMPLETED/stopped
2015-08-14 03:59:09,449 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 03:59:13,133 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 03:59:16,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 03:59:16,357 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/COMPLETED/stopped
2015-08-14 03:59:16,419 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:59:16,420 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:59:16,485 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 03:59:16,490 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 03:59:16,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:59:16,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:59:16,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/THROWABLE/stopped"]
2015-08-14 03:59:16,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 03:59:16,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 03:59:16,493 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 03:59:16,497 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 03:59:16,497 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 03:59:16,747 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0004
2015-08-14 03:59:16,748 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0004/
2015-08-14 03:59:16,753 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0005
2015-08-14 03:59:16,754 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0005/
2015-08-14 03:59:33,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0004_01_000003 is : 143
2015-08-14 03:59:34,436 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0004_01_000004 is : 143
2015-08-14 03:59:34,724 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0004_01_000006 is : 143
2015-08-14 03:59:34,799 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0004_01_000005 is : 143
2015-08-14 03:59:36,218 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000005 is : 143
2015-08-14 03:59:36,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000006 is : 143
2015-08-14 03:59:37,648 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000004 is : 143
2015-08-14 03:59:38,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000002 is : 143
2015-08-14 03:59:38,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000003 is : 143
2015-08-14 03:59:40,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0004_01_000007 is : 143
2015-08-14 03:59:40,629 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000012
2015-08-14 03:59:42,126 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000013
2015-08-14 03:59:42,179 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000014
2015-08-14 03:59:44,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000007 is : 143
2015-08-14 03:59:45,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000009 is : 143
2015-08-14 03:59:45,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000010 is : 143
2015-08-14 03:59:45,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000011 is : 143
2015-08-14 03:59:50,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000015 is : 143
2015-08-14 03:59:52,211 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000016 is : 143
2015-08-14 03:59:52,240 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000018 is : 143
2015-08-14 03:59:52,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000017 is : 143
2015-08-14 03:59:55,303 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000023
2015-08-14 03:59:56,197 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000024
2015-08-14 03:59:56,227 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000025
2015-08-14 03:59:56,303 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1439524685076_0005_01_000026
2015-08-14 03:59:57,142 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000019 is : 143
2015-08-14 03:59:57,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000020 is : 143
2015-08-14 03:59:57,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000022 is : 143
2015-08-14 03:59:57,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000021 is : 143
2015-08-14 03:59:57,218 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0005_01_000008 is : 143
2015-08-14 03:59:58,357 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] hadoop job job_1439524685076_0005 state at FAILED
2015-08-14 03:59:58,361 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] failure info: Task failed task_1439524685076_0005_m_000003
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-08-14 03:59:58,395 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events identify failed tasks
2015-08-14 03:59:58,395 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events count: 10
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000004_0, Status : SUCCEEDED
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000003_0, Status : FAILED
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000002_0, Status : FAILED
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000000_0, Status : FAILED
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000001_0, Status : FAILED
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000003_1, Status : FAILED
2015-08-14 03:59:58,396 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000002_1, Status : FAILED
2015-08-14 03:59:58,397 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000000_1, Status : FAILED
2015-08-14 03:59:58,397 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000001_1, Status : FAILED
2015-08-14 03:59:58,397 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439524685076_0005_m_000003_2, Status : FAILED
2015-08-14 03:59:58,443 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...latform/THROWABLE/stopped, predecessor failed: (2/3)
2015-08-14 03:59:58,443 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 03:59:58,444 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-08-14 03:59:58,445 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-08-14 03:59:58,445 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 03:59:58,447 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 04:00:01,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 04:00:01,636 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@55a21c7d 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:1560)
at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1323)
at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1221)
at cascading.flow.BaseFlow.run(BaseFlow.java:1176)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:78)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:834)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:00:01,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 04:00:01,637 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-08-14 04:00:01,637 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 04:00:01,638 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 04:00:01,641 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 04:00:01,642 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/THROWABLE/stopped
2015-08-14 04:00:01,670 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:01,670 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:01,719 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(198)) - calling start
2015-08-14 04:00:01,723 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 04:00:01,724 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:01,724 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 04:00:01,724 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 04:00:01,724 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/stopped"]
2015-08-14 04:00:01,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 04:00:01,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 04:00:01,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 04:00:01,727 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 04:00:01,727 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 04:00:02,014 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0006
2015-08-14 04:00:02,014 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0006/
2015-08-14 04:00:02,015 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0007
2015-08-14 04:00:02,015 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0007/
2015-08-14 04:00:02,727 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:03,728 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:04,730 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:05,731 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:06,733 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:07,734 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:08,736 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:09,738 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:10,739 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:11,740 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:12,764 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:13,767 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:14,776 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:15,799 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:16,810 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:17,818 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:17,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0006_01_000002 is : 143
2015-08-14 04:00:18,128 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0006_01_000005 is : 143
2015-08-14 04:00:18,339 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0006_01_000006 is : 143
2015-08-14 04:00:18,579 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0006_01_000003 is : 143
2015-08-14 04:00:18,819 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:19,820 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:20,828 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:21,835 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:22,837 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 04:00:23,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0007_01_000005 is : 143
2015-08-14 04:00:23,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0007_01_000006 is : 143
2015-08-14 04:00:23,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0007_01_000003 is : 143
2015-08-14 04:00:23,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0007_01_000002 is : 143
2015-08-14 04:00:23,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0007_01_000004 is : 143
2015-08-14 04:00:23,840 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2015-08-14 04:00:23,840 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2015-08-14 04:00:23,840 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 04:00:23,842 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-08-14 04:00:23,844 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 04:00:23,877 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0006_01_000007 is : 143
2015-08-14 04:00:25,870 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 04:00:27,891 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 04:00:27,892 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-08-14 04:00:27,938 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (1/3)
2015-08-14 04:00:27,938 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-08-14 04:00:27,938 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (2/3)
2015-08-14 04:00:27,938 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-08-14 04:00:27,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-08-14 04:00:27,939 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/stopped
2015-08-14 04:00:27,969 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:27,969 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:28,017 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 04:00:28,020 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@1af653a6 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:1524)
at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1350)
at cascading.flow.BaseFlow.run(BaseFlow.java:1125)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:78)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:834)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:00:28,021 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 04:00:28,021 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STARTING/stopped
2015-08-14 04:00:28,022 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 04:00:28,023 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 04:00:28,023 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 04:00:28,023 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 04:00:28,023 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 04:00:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 04:00:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/STARTING/stopped"]
2015-08-14 04:00:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 04:00:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 04:00:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 04:00:28,025 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/STARTING/stopped
2015-08-14 04:00:28,049 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:28,049 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:28,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopping all jobs
2015-08-14 04:00:28,070 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] stopping: (1/1) ...r1/flowplatform/startstop
2015-08-14 04:00:28,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopped all jobs
2015-08-14 04:00:28,070 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/startstop
2015-08-14 04:00:28,113 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:28,113 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:28,155 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 04:00:28,160 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 04:00:28,160 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:28,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 04:00:28,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 04:00:28,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/STOPPING/stopped"]
2015-08-14 04:00:28,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 04:00:28,162 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 04:00:28,162 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 04:00:28,163 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 04:00:28,163 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 04:00:28,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0008
2015-08-14 04:00:28,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0008/
2015-08-14 04:00:28,406 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439524685076_0009
2015-08-14 04:00:28,406 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0009/
2015-08-14 04:00:29,162 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:30,165 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:31,167 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:32,168 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:33,170 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:34,171 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:35,173 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:36,174 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:37,176 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:38,177 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:39,178 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:40,180 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:41,192 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:42,216 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:43,255 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:44,275 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:45,291 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:46,292 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 04:00:46,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0008_01_000004 is : 143
2015-08-14 04:00:46,645 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0008_01_000005 is : 143
2015-08-14 04:00:46,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0008_01_000003 is : 143
2015-08-14 04:00:46,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0008_01_000002 is : 143
2015-08-14 04:00:47,294 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(416)) - calling stop
2015-08-14 04:00:47,295 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@d7adfa0 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:1536)
at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1338)
at cascading.flow.BaseFlow.stop(BaseFlow.java:854)
at cascading.flow.hadoop.FlowPlatformTest.failingListenerTest(FlowPlatformTest.java:418)
at cascading.flow.hadoop.FlowPlatformTest.testFailingListenerStopping(FlowPlatformTest.java:328)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
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:271)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:80)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:47)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:49)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
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:103)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
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:355)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:66)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:00:47,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 04:00:47,298 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-08-14 04:00:47,306 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 04:00:47,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0009_01_000003 is : 143
2015-08-14 04:00:47,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0009_01_000005 is : 143
2015-08-14 04:00:47,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0009_01_000002 is : 143
2015-08-14 04:00:47,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0009_01_000004 is : 143
2015-08-14 04:00:47,635 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0009_01_000006 is : 143
2015-08-14 04:00:49,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 04:00:49,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-0_0/usercache/teamcity/appcache/application_1439524685076_0008/container_1439524685076_0008_01_000007]
2015-08-14 04:00:49,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-0_1/usercache/teamcity/appcache/application_1439524685076_0008/container_1439524685076_0008_01_000007]
2015-08-14 04:00:49,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-0_2/usercache/teamcity/appcache/application_1439524685076_0008/container_1439524685076_0008_01_000007]
2015-08-14 04:00:49,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:deleteAsUser(372)) - delete returned false for path: [/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/target/Hadoop2MR1Platform/Hadoop2MR1Platform-localDir-nm-0_3/usercache/teamcity/appcache/application_1439524685076_0008/container_1439524685076_0008_01_000007]
2015-08-14 04:00:51,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 04:00:51,383 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-08-14 04:00:51,431 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (1/3)
2015-08-14 04:00:51,431 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-08-14 04:00:51,431 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (2/3)
2015-08-14 04:00:51,432 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-08-14 04:00:51,432 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-08-14 04:00:51,433 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/STOPPING/stopped
2015-08-14 04:00:51,454 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:51,455 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:51,463 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-08-14 04:00:51,482 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-08-14 04:00:51,503 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:51,504 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:51,553 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:00:51,553 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:00:51,569 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-14 04:00:51,570 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 04:00:51,570 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete"]
2015-08-14 04:00:51,570 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-08-14 04:00:51,570 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-08-14 04:00:51,571 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-08-14 04:00:51,572 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...wplatform/withoutcomplete
2015-08-14 04:00:51,743 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439524685076_0010
2015-08-14 04:00:51,743 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://ip-10-235-34-50.ec2.internal:41092/proxy/application_1439524685076_0010/
2015-08-14 04:01:08,715 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0010_01_000005 is : 143
2015-08-14 04:01:08,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0010_01_000002 is : 143
2015-08-14 04:01:08,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0010_01_000006 is : 143
2015-08-14 04:01:08,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0010_01_000003 is : 143
2015-08-14 04:01:09,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0010_01_000004 is : 143
2015-08-14 04:01:15,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524685076_0010_01_000007 is : 143
2015-08-14 04:01:16,892 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete/_temporary
2015-08-14 04:01:16,893 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/withoutcomplete
2015-08-14 04:01:16,920 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:01:16,920 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:01:16,926 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 04:01:16,946 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:01:16,947 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:01:16,953 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 04:01:16,978 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:01:16,979 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:01:17,001 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/flowplatform/badserialization