2016-01-14 21:24:23,201 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 21:24:23,224 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-mr1
2016-01-14 21:24:23,260 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-14 21:24:24,128 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2016-01-14 21:24:24,907 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 21:24:25,488 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(162)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 21:24:28,595 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 21:24:28,740 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 21:24:28,859 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 21:24:28,972 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 21:24:46,048 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 21:24:46,074 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 56F0CFF649EA4EF88B7BFC2C4C7694FE
2016-01-14 21:24:46,102 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:24:46,103 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:24:46,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-14 21:24:46,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:24:46,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:24:46,296 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 21:24:46,375 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:24:46,376 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:24:46,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 21:24:46,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:24:46,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:24:46,426 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 21:24:46,531 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:24:46,532 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:24:46,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.135
2016-01-14 21:24:46,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 21:24:46,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:24:46,800 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 21:24:46,821 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 21:24:46,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:24:46,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-01-14 21:24:46,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-01-14 21:24:46,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2016-01-14 21:24:46,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 21:24:46,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 21:24:46,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 21:24:46,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 21:24:46,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 21:24:47,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0001
2016-01-14 21:24:47,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0001/
2016-01-14 21:24:48,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0002
2016-01-14 21:24:48,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0002/
2016-01-14 21:25:20,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0001_01_000005 is : 143
2016-01-14 21:25:20,748 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0001_01_000006 is : 143
2016-01-14 21:25:21,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0001_01_000002 is : 143
2016-01-14 21:25:21,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0001_01_000004 is : 143
2016-01-14 21:25:21,568 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0001_01_000003 is : 143
2016-01-14 21:25:22,282 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0002_01_000004 is : 143
2016-01-14 21:25:23,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0002_01_000003 is : 143
2016-01-14 21:25:23,435 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0002_01_000006 is : 143
2016-01-14 21:25:23,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0002_01_000002 is : 143
2016-01-14 21:25:23,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0002_01_000005 is : 143
2016-01-14 21:25:29,316 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0001_01_000007 is : 143
2016-01-14 21:25:30,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0002_01_000007 is : 143
2016-01-14 21:25:31,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...mpleted/COMPLETED/stopped
2016-01-14 21:25:31,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0003
2016-01-14 21:25:31,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0003/
2016-01-14 21:25:48,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0003_01_000003 is : 143
2016-01-14 21:25:48,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0003_01_000002 is : 143
2016-01-14 21:25:55,950 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0003_01_000004 is : 143
2016-01-14 21:25:57,185 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2016-01-14 21:25:57,186 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@16f5bb4b threw throwable
java.lang.RuntimeException: intentionally failed on: COMPLETED
at cascading.flow.FailingFlowListener.onCompleted(FailingFlowListener.java:61)
at cascading.flow.BaseFlow$SafeFlowListener.onCompleted(BaseFlow.java:1632)
at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1353)
at cascading.flow.BaseFlow.run(BaseFlow.java:1223)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:25:57,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 21:25:57,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...mpleted/COMPLETED/stopped
2016-01-14 21:25:57,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 21:26:00,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 21:26:03,916 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 21:26:03,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:10.354, using cpu time: 00:17.440
2016-01-14 21:26:03,919 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2016-01-14 21:26:03,961 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:26:03,962 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:26:04,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.115
2016-01-14 21:26:04,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 21:26:04,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:26:04,145 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 21:26:04,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:26:04,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-01-14 21:26:04,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-01-14 21:26:04,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2016-01-14 21:26:04,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 21:26:04,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 21:26:04,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 21:26:04,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 21:26:04,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 21:26:04,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0004
2016-01-14 21:26:04,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0004/
2016-01-14 21:26:04,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0005
2016-01-14 21:26:04,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0005/
2016-01-14 21:26:33,095 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000003 is : 143
2016-01-14 21:26:33,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000002 is : 143
2016-01-14 21:26:35,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000005 is : 143
2016-01-14 21:26:35,306 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000004 is : 143
2016-01-14 21:26:35,924 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000006 is : 143
2016-01-14 21:26:37,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0005_01_000005 is : 143
2016-01-14 21:26:37,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0005_01_000006 is : 143
2016-01-14 21:26:38,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0005_01_000003 is : 143
2016-01-14 21:26:38,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0005_01_000004 is : 143
2016-01-14 21:26:39,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0005_01_000002 is : 143
2016-01-14 21:26:50,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000007 is : 143
2016-01-14 21:26:51,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000010 is : 143
2016-01-14 21:26:52,131 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000009 is : 143
2016-01-14 21:26:52,380 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000008 is : 143
2016-01-14 21:26:53,969 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0005_01_000007 is : 143
2016-01-14 21:26:55,852 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452806680546_0004_01_000017
2016-01-14 21:26:55,902 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452806680546_0004_01_000018
2016-01-14 21:26:55,924 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(831)) - Event EventType: KILL_CONTAINER sent to absent container container_1452806680546_0004_01_000016
2016-01-14 21:27:00,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000012 is : 143
2016-01-14 21:27:02,306 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000015 is : 143
2016-01-14 21:27:02,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000013 is : 143
2016-01-14 21:27:02,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000014 is : 143
2016-01-14 21:27:07,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000020 is : 143
2016-01-14 21:27:07,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000019 is : 143
2016-01-14 21:27:07,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000022 is : 143
2016-01-14 21:27:07,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000011 is : 143
2016-01-14 21:27:07,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0004_01_000021 is : 143
2016-01-14 21:27:09,069 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] hadoop job job_1452806680546_0004 state at FAILED
2016-01-14 21:27:09,070 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] failure info: Task failed task_1452806680546_0004_m_000001
Job failed as tasks failed. failedMaps:1 failedReduces:0
2016-01-14 21:27:09,094 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events identify failed tasks
2016-01-14 21:27:09,094 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events count: 10
2016-01-14 21:27:09,094 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000001_0, Status : FAILED
2016-01-14 21:27:09,094 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000000_0, Status : FAILED
2016-01-14 21:27:09,094 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000003_0, Status : FAILED
2016-01-14 21:27:09,094 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000002_0, Status : FAILED
2016-01-14 21:27:09,095 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000004_0, Status : SUCCEEDED
2016-01-14 21:27:09,095 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000001_1, Status : FAILED
2016-01-14 21:27:09,095 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000002_1, Status : FAILED
2016-01-14 21:27:09,095 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000003_1, Status : FAILED
2016-01-14 21:27:09,095 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000000_1, Status : FAILED
2016-01-14 21:27:09,096 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1452806680546_0004_m_000001_2, Status : FAILED
2016-01-14 21:27:09,096 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (2/3)
2016-01-14 21:27:09,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-14 21:27:09,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 21:27:09,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-14 21:27:09,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 21:27:09,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 21:27:12,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 21:27:12,300 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@48a7a01 threw throwable
java.lang.RuntimeException: intentionally failed on: THROWABLE
at cascading.flow.FailingFlowListener.onThrowable(FailingFlowListener.java:69)
at cascading.flow.BaseFlow$SafeFlowListener.onThrowable(BaseFlow.java:1644)
at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1373)
at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1272)
at cascading.flow.BaseFlow.run(BaseFlow.java:1212)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:27:12,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 21:27:12,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-01-14 21:27:12,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 21:27:12,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 21:27:12,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 21:27:12,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:08.152, using cpu time: 00:08.390
2016-01-14 21:27:12,306 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2016-01-14 21:27:12,325 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:27:12,325 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:27:12,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-01-14 21:27:12,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 21:27:12,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:27:12,459 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2016-01-14 21:27:12,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:27:12,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-01-14 21:27:12,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-01-14 21:27:12,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testStop/stopped"]
2016-01-14 21:27:12,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 21:27:12,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 21:27:12,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 21:27:12,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 21:27:12,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 21:27:12,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0007
2016-01-14 21:27:12,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0007/
2016-01-14 21:27:12,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0006
2016-01-14 21:27:12,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0006/
2016-01-14 21:27:17,461 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:18,462 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:19,466 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:20,468 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:21,489 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:22,496 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:23,497 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:24,498 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:25,499 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:26,500 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:27,502 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:28,503 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:29,504 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:30,507 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:30,877 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0007_01_000004 is : 143
2016-01-14 21:27:30,890 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0007_01_000006 is : 143
2016-01-14 21:27:31,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0007_01_000005 is : 143
2016-01-14 21:27:31,479 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0007_01_000002 is : 143
2016-01-14 21:27:31,508 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:31,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0007_01_000003 is : 143
2016-01-14 21:27:32,509 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:33,510 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:34,512 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:35,513 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:36,524 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:37,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0007_01_000007 is : 143
2016-01-14 21:27:37,525 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:38,526 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:39,527 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:40,528 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:41,529 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:42,530 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:43,531 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:44,532 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:45,533 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:46,534 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:47,535 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:48,536 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:49,637 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:50,637 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:51,639 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:52,640 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:53,641 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:54,642 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:55,664 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:56,665 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:57,665 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:58,666 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:27:59,666 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:28:00,667 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:28:01,667 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-01-14 21:28:02,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0006_01_000004 is : 143
2016-01-14 21:28:02,673 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2016-01-14 21:28:02,673 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2016-01-14 21:28:02,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 21:28:02,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-14 21:28:02,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 21:28:03,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0006_01_000005 is : 143
2016-01-14 21:28:03,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0006_01_000002 is : 143
2016-01-14 21:28:03,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0006_01_000003 is : 143
2016-01-14 21:28:03,410 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0006_01_000006 is : 143
2016-01-14 21:28:05,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 21:28:05,873 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (1/3)
2016-01-14 21:28:05,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-01-14 21:28:05,921 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0006_01_000007 is : 143
2016-01-14 21:28:07,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 21:28:07,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2016-01-14 21:28:07,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2016-01-14 21:28:07,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:50.212, using cpu time: 00:11.650
2016-01-14 21:28:07,950 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testStop/stopped
2016-01-14 21:28:07,968 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:28:07,968 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:28:08,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2016-01-14 21:28:08,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 21:28:08,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:28:08,091 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 21:28:08,094 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@5bfc224c threw throwable
java.lang.RuntimeException: intentionally failed on: STARTING
at cascading.flow.FailingFlowListener.onStarting(FailingFlowListener.java:45)
at cascading.flow.BaseFlow$SafeFlowListener.onStarting(BaseFlow.java:1608)
at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1400)
at cascading.flow.BaseFlow.run(BaseFlow.java:1161)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:28:08,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 21:28:08,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Starting/STARTING/stopped
2016-01-14 21:28:08,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 21:28:08,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 21:28:08,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 21:28:08,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.003
2016-01-14 21:28:08,101 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped
2016-01-14 21:28:08,117 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:28:08,117 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:28:08,153 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 21:28:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:28:08,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:28:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping all jobs
2016-01-14 21:28:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2016-01-14 21:28:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopped all jobs
2016-01-14 21:28:08,168 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testStartStopRace/startstop
2016-01-14 21:28:08,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 16814:21:28:08.167
2016-01-14 21:28:08,186 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:28:08,187 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:28:08,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-01-14 21:28:08,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-01-14 21:28:08,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:28:08,324 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-01-14 21:28:08,327 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:08,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:28:08,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-01-14 21:28:08,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-01-14 21:28:08,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2016-01-14 21:28:08,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2016-01-14 21:28:08,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2016-01-14 21:28:08,331 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2016-01-14 21:28:08,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 21:28:08,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 21:28:08,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0008
2016-01-14 21:28:08,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0008/
2016-01-14 21:28:08,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452806680546_0009
2016-01-14 21:28:08,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0009/
2016-01-14 21:28:09,328 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:10,328 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:11,329 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:12,329 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:13,330 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:14,330 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:15,330 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:16,331 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:17,331 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:18,335 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:19,336 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:20,336 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:21,337 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:22,338 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:23,339 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:24,339 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:25,341 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:26,341 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:27,342 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:28,342 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:29,343 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:30,343 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-01-14 21:28:30,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0008_01_000003 is : 143
2016-01-14 21:28:31,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0008_01_000002 is : 143
2016-01-14 21:28:31,347 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2016-01-14 21:28:31,348 WARN flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@275d331f threw throwable
java.lang.RuntimeException: intentionally failed on: STOPPING
at cascading.flow.FailingFlowListener.onStopping(FailingFlowListener.java:53)
at cascading.flow.BaseFlow$SafeFlowListener.onStopping(BaseFlow.java:1620)
at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1388)
at cascading.flow.BaseFlow.stop(BaseFlow.java:890)
at cascading.flow.hadoop.FlowPlatformTest.failingListenerTest(FlowPlatformTest.java:419)
at cascading.flow.hadoop.FlowPlatformTest.testFailingListenerStopping(FlowPlatformTest.java:328)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 21:28:31,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2016-01-14 21:28:31,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-14 21:28:31,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2016-01-14 21:28:31,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0008_01_000005 is : 143
2016-01-14 21:28:31,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2016-01-14 21:28:31,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0008_01_000004 is : 143
2016-01-14 21:28:31,624 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0008_01_000006 is : 143
2016-01-14 21:28:33,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2016-01-14 21:28:33,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2016-01-14 21:28:33,587 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (1/3)
2016-01-14 21:28:33,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-14 21:28:33,587 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (2/3)
2016-01-14 21:28:33,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-01-14 21:28:33,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2016-01-14 21:28:33,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.022, using cpu time: 00:03.050
2016-01-14 21:28:33,628 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped
2016-01-14 21:28:33,646 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:28:33,647 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:28:33,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 21:28:33,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:28:33,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:28:33,678 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2016-01-14 21:28:33,692 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:28:33,692 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:28:33,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 21:28:33,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:28:33,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:28:33,746 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:28:33,746 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:28:33,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 21:28:33,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:28:33,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:28:33,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-14 21:28:33,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-01-14 21:28:33,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete"]
2016-01-14 21:28:33,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2016-01-14 21:28:33,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2016-01-14 21:28:33,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2016-01-14 21:28:33,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2016-01-14 21:28:33,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452806680546_0010
2016-01-14 21:28:33,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165:53250/proxy/application_1452806680546_0010/
2016-01-14 21:28:56,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0010_01_000006 is : 143
2016-01-14 21:28:56,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0010_01_000003 is : 143
2016-01-14 21:28:56,621 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0010_01_000002 is : 143
2016-01-14 21:28:56,943 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0010_01_000005 is : 143
2016-01-14 21:28:57,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0010_01_000004 is : 143
2016-01-14 21:29:02,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452806680546_0010_01_000007 is : 143
2016-01-14 21:29:04,174 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2016-01-14 21:29:04,175 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete
2016-01-14 21:29:04,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:30.386, using cpu time: 00:06.430
2016-01-14 21:29:04,196 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:29:04,196 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:29:04,216 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 21:29:04,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:29:04,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:29:04,219 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 21:29:04,233 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:29:04,233 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:29:04,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 21:29:04,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:29:04,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:29:04,256 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2016-01-14 21:29:04,275 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:29:04,275 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:29:04,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 21:29:04,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:29:04,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:29:04,318 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/flowplatform/testFailedSerialization/badserialization