2015-08-14 02:07:13,391 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 02:07:13,450 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 02:07:13,451 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.flow.hadoop.FlowPlatformTest
2015-08-14 02:07:13,489 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 02:07:14,368 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 02:07:15,145 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 02:07:20,507 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 02:07:21,783 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 02:07:22,994 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 02:07:24,210 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 02:07:26,784 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 02:07:26,815 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: E80476B39E844F589780CE8DB5717DE8
2015-08-14 02:07:26,850 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:07:26,851 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 02:07:26,933 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 02:07:27,020 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:07:27,022 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 02:07:27,033 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 02:07:27,061 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 02:07:27,186 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:07:27,186 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 02:07:27,289 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 02:07:27,318 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 02:07:27,319 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:07:27,320 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/upper.txt"]
2015-08-14 02:07:27,321 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/lower.txt"]
2015-08-14 02:07:27,321 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped"]
2015-08-14 02:07:27,322 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 02:07:27,322 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 02:07:27,322 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 02:07:27,324 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 02:07:27,324 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 02:07:29,234 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0002
2015-08-14 02:07:29,234 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0001
2015-08-14 02:07:29,235 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0001/
2015-08-14 02:07:29,235 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0002/
2015-08-14 02:07:49,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0002_01_000002 is : 143
2015-08-14 02:07:49,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0001_01_000006 is : 143
2015-08-14 02:07:50,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0002_01_000004 is : 143
2015-08-14 02:07:50,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0002_01_000005 is : 143
2015-08-14 02:07:50,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0001_01_000002 is : 143
2015-08-14 02:07:50,381 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0002_01_000003 is : 143
2015-08-14 02:07:50,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0001_01_000004 is : 143
2015-08-14 02:07:50,458 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0001_01_000003 is : 143
2015-08-14 02:07:50,460 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0002_01_000006 is : 143
2015-08-14 02:07:50,491 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0001_01_000005 is : 143
2015-08-14 02:07:56,993 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0001_01_000007 is : 143
2015-08-14 02:07:57,591 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0002_01_000007 is : 143
2015-08-14 02:07:58,875 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...latform/COMPLETED/stopped
2015-08-14 02:07:59,098 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0003
2015-08-14 02:07:59,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0003/
2015-08-14 02:08:17,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0003_01_000003 is : 143
2015-08-14 02:08:17,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0003_01_000002 is : 143
2015-08-14 02:08:24,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0003_01_000004 is : 143
2015-08-14 02:08:25,841 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped/_temporary
2015-08-14 02:08:25,843 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@7e694d91 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 02:08:25,848 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 02:08:25,849 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/COMPLETED/stopped
2015-08-14 02:08:25,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 02:08:29,512 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 02:08:32,729 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 02:08:32,730 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/COMPLETED/stopped
2015-08-14 02:08:32,771 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:08:32,772 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 02:08:32,837 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 02:08:32,842 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:08:32,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/upper.txt"]
2015-08-14 02:08:32,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/lower.txt"]
2015-08-14 02:08:32,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/THROWABLE/stopped"]
2015-08-14 02:08:32,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 02:08:32,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 02:08:32,843 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 02:08:32,846 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 02:08:32,847 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 02:08:33,087 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0004
2015-08-14 02:08:33,087 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0004/
2015-08-14 02:08:33,107 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0005
2015-08-14 02:08:33,107 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0005/
2015-08-14 02:08:51,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0004_01_000002 is : 143
2015-08-14 02:08:51,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0004_01_000003 is : 143
2015-08-14 02:08:52,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000005 is : 143
2015-08-14 02:08:52,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0004_01_000006 is : 143
2015-08-14 02:08:52,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000006 is : 143
2015-08-14 02:08:52,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0004_01_000004 is : 143
2015-08-14 02:08:52,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0004_01_000005 is : 143
2015-08-14 02:08:55,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000002 is : 143
2015-08-14 02:08:55,312 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000003 is : 143
2015-08-14 02:08:55,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000004 is : 143
2015-08-14 02:08:58,497 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000012
2015-08-14 02:08:58,593 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000013
2015-08-14 02:08:59,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000007 is : 143
2015-08-14 02:08:59,370 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000014
2015-08-14 02:08:59,667 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0004_01_000007 is : 143
2015-08-14 02:09:02,651 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000009 is : 143
2015-08-14 02:09:02,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000010 is : 143
2015-08-14 02:09:03,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000011 is : 143
2015-08-14 02:09:05,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000015 is : 143
2015-08-14 02:09:06,572 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000019
2015-08-14 02:09:06,919 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000020
2015-08-14 02:09:08,573 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000022
2015-08-14 02:09:09,228 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000017 is : 143
2015-08-14 02:09:09,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000016 is : 143
2015-08-14 02:09:10,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000018 is : 143
2015-08-14 02:09:11,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000021 is : 143
2015-08-14 02:09:11,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000024 is : 143
2015-08-14 02:09:11,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000008 is : 143
2015-08-14 02:09:11,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0005_01_000023 is : 143
2015-08-14 02:09:12,521 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] hadoop job job_1439518038534_0005 state at FAILED
2015-08-14 02:09:12,523 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] failure info: Task failed task_1439518038534_0005_m_000003
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-08-14 02:09:12,561 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events identify failed tasks
2015-08-14 02:09:12,561 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events count: 10
2015-08-14 02:09:12,561 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000003_0, Status : FAILED
2015-08-14 02:09:12,561 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000004_0, Status : SUCCEEDED
2015-08-14 02:09:12,562 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000000_0, Status : FAILED
2015-08-14 02:09:12,562 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000001_0, Status : FAILED
2015-08-14 02:09:12,562 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000002_0, Status : FAILED
2015-08-14 02:09:12,562 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000003_1, Status : FAILED
2015-08-14 02:09:12,562 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000000_1, Status : FAILED
2015-08-14 02:09:12,562 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000001_1, Status : FAILED
2015-08-14 02:09:12,563 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000002_1, Status : FAILED
2015-08-14 02:09:12,563 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1439518038534_0005_m_000003_2, Status : FAILED
2015-08-14 02:09:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 02:09:12,610 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...latform/THROWABLE/stopped, predecessor failed: (2/3)
2015-08-14 02:09:12,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-08-14 02:09:12,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-08-14 02:09:12,612 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 02:09:12,614 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 02:09:15,800 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 02:09:15,800 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@ed71c51 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 02:09:15,801 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 02:09:15,801 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-08-14 02:09:15,801 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 02:09:15,803 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 02:09:15,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 02:09:15,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/THROWABLE/stopped
2015-08-14 02:09:15,834 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:09:15,835 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 02:09:15,885 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(198)) - calling start
2015-08-14 02:09:15,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:09:15,888 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:15,889 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/upper.txt"]
2015-08-14 02:09:15,890 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/lower.txt"]
2015-08-14 02:09:15,891 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/stopped"]
2015-08-14 02:09:15,892 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 02:09:15,892 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 02:09:15,892 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 02:09:15,894 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 02:09:15,894 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 02:09:16,178 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0006
2015-08-14 02:09:16,179 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0006/
2015-08-14 02:09:16,199 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0007
2015-08-14 02:09:16,199 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0007/
2015-08-14 02:09:16,891 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:17,892 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:18,893 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:19,334 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000025
2015-08-14 02:09:19,335 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000026
2015-08-14 02:09:19,338 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(817)) - Event EventType: KILL_CONTAINER sent to absent container container_1439518038534_0005_01_000027
2015-08-14 02:09:19,895 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:20,897 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:21,898 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:22,899 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:23,902 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:24,904 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:25,908 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:26,909 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:27,918 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:28,920 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:29,921 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:30,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0006_01_000003 is : 143
2015-08-14 02:09:30,923 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:31,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0006_01_000002 is : 143
2015-08-14 02:09:31,734 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0006_01_000004 is : 143
2015-08-14 02:09:31,849 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0006_01_000005 is : 143
2015-08-14 02:09:31,924 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:32,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0006_01_000006 is : 143
2015-08-14 02:09:32,926 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:33,927 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:34,929 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:35,935 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:36,947 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-08-14 02:09:37,741 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0007_01_000003 is : 143
2015-08-14 02:09:37,942 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0007_01_000002 is : 143
2015-08-14 02:09:37,962 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2015-08-14 02:09:37,962 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2015-08-14 02:09:37,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 02:09:37,969 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-08-14 02:09:37,970 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 02:09:38,024 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0006_01_000007 is : 143
2015-08-14 02:09:38,092 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0007_01_000004 is : 143
2015-08-14 02:09:38,130 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0007_01_000005 is : 143
2015-08-14 02:09:38,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0007_01_000006 is : 143
2015-08-14 02:09:40,007 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 02:09:42,024 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 02:09:42,025 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-08-14 02:09:42,070 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (1/3)
2015-08-14 02:09:42,071 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-08-14 02:09:42,072 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (2/3)
2015-08-14 02:09:42,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-08-14 02:09:42,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-08-14 02:09:42,073 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/stopped
2015-08-14 02:09:42,100 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:09:42,100 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 02:09:42,148 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 02:09:42,151 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@2c84d9d 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 02:09:42,152 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 02:09:42,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STARTING/stopped
2015-08-14 02:09:42,153 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 02:09:42,153 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 02:09:42,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 02:09:42,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:09:42,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/upper.txt"]
2015-08-14 02:09:42,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/lower.txt"]
2015-08-14 02:09:42,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/STARTING/stopped"]
2015-08-14 02:09:42,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 02:09:42,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 02:09:42,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 02:09:42,156 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/STARTING/stopped
2015-08-14 02:09:42,178 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:09:42,179 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 02:09:42,196 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopping all jobs
2015-08-14 02:09:42,197 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] stopping: (1/1) ...r1/flowplatform/startstop
2015-08-14 02:09:42,198 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopped all jobs
2015-08-14 02:09:42,198 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/startstop
2015-08-14 02:09:42,223 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:09:42,223 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 02:09:42,269 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-08-14 02:09:42,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:09:42,272 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:42,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/upper.txt"]
2015-08-14 02:09:42,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/lower.txt"]
2015-08-14 02:09:42,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/STOPPING/stopped"]
2015-08-14 02:09:42,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 02:09:42,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 02:09:42,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 02:09:42,276 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 02:09:42,276 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 02:09:42,501 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0009
2015-08-14 02:09:42,501 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0009/
2015-08-14 02:09:42,502 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439518038534_0008
2015-08-14 02:09:42,502 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0008/
2015-08-14 02:09:43,274 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:44,277 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:45,280 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:46,283 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:47,284 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:48,287 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:49,290 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:50,291 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:51,293 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:52,297 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:53,299 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:54,300 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:55,312 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:56,322 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:57,324 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:58,378 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:09:59,413 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:10:00,413 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-08-14 02:10:01,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0008_01_000003 is : 143
2015-08-14 02:10:01,486 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(416)) - calling stop
2015-08-14 02:10:01,487 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@74e821 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 02:10:01,490 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-14 02:10:01,502 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-08-14 02:10:01,515 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-08-14 02:10:01,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0008_01_000002 is : 143
2015-08-14 02:10:01,745 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0008_01_000006 is : 143
2015-08-14 02:10:01,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0009_01_000004 is : 143
2015-08-14 02:10:01,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0009_01_000005 is : 143
2015-08-14 02:10:01,912 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0009_01_000002 is : 143
2015-08-14 02:10:01,960 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0009_01_000006 is : 143
2015-08-14 02:10:01,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0009_01_000003 is : 143
2015-08-14 02:10:03,737 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-08-14 02:10:05,756 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-14 02:10:05,757 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-08-14 02:10:05,808 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (1/3)
2015-08-14 02:10:05,809 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-08-14 02:10:05,809 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (2/3)
2015-08-14 02:10:05,809 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-08-14 02:10:05,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-08-14 02:10:05,810 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/STOPPING/stopped
2015-08-14 02:10:05,831 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:10:05,832 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 02:10:05,839 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-08-14 02:10:05,858 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-08-14 02:10:05,878 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:10:05,879 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 02:10:05,926 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:10:05,926 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 02:10:05,942 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-14 02:10:05,943 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/lower.txt"]
2015-08-14 02:10:05,943 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete"]
2015-08-14 02:10:05,943 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-08-14 02:10:05,943 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-08-14 02:10:05,943 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-08-14 02:10:05,944 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...wplatform/withoutcomplete
2015-08-14 02:10:06,107 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439518038534_0010
2015-08-14 02:10:06,107 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://ip-10-235-34-50:45443/proxy/application_1439518038534_0010/
2015-08-14 02:10:23,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0010_01_000006 is : 143
2015-08-14 02:10:23,300 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0010_01_000004 is : 143
2015-08-14 02:10:23,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0010_01_000005 is : 143
2015-08-14 02:10:23,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0010_01_000003 is : 143
2015-08-14 02:10:23,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0010_01_000002 is : 143
2015-08-14 02:10:30,715 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439518038534_0010_01_000007 is : 143
2015-08-14 02:10:31,971 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete/_temporary
2015-08-14 02:10:31,973 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/withoutcomplete
2015-08-14 02:10:31,999 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:10:32,000 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 02:10:32,007 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 02:10:32,026 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:10:32,027 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 02:10:32,033 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-08-14 02:10:32,058 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:10:32,058 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 02:10:32,080 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/flowplatform/badserialization