2016-05-18 05:33:10,468 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 05:33:10,486 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-mr1
2016-05-18 05:33:10,510 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 05:33:11,237 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-05-18 05:33:11,868 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 05:33:12,422 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 05:33:15,472 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - 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-05-18 05:33:15,619 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - 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-05-18 05:33:15,738 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - 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-05-18 05:33:15,849 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - 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-05-18 05:33:27,670 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 05:33:28,623 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 05:33:28,623 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 05:33:32,925 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 05:33:32,949 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 485FD4C20CCD41E69A1B4145D8389A58
2016-05-18 05:33:32,976 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:33:32,978 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:33:33,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-18 05:33:33,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:33:33,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:33:33,180 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 05:33:33,273 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:33:33,274 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:33:33,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 05:33:33,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:33:33,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:33:33,321 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 05:33:33,425 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:33:33,425 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:33:33,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.130
2016-05-18 05:33:33,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:33:33,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:33:33,641 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 05:33:33,664 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 05:33:33,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 05:33:33,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 05:33:33,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:33:33,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2016-05-18 05:33:33,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 05:33:33,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 05:33:33,667 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 05:33:33,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 05:33:33,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 05:33:34,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0002
2016-05-18 05:33:34,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0002/
2016-05-18 05:33:34,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0001
2016-05-18 05:33:34,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0001/
2016-05-18 05:34:05,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0001_01_000005 is : 143
2016-05-18 05:34:06,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0001_01_000006 is : 143
2016-05-18 05:34:06,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0001_01_000003 is : 143
2016-05-18 05:34:07,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0001_01_000002 is : 143
2016-05-18 05:34:07,340 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0001_01_000004 is : 143
2016-05-18 05:34:09,861 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0002_01_000002 is : 143
2016-05-18 05:34:10,074 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0002_01_000006 is : 143
2016-05-18 05:34:10,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0002_01_000005 is : 143
2016-05-18 05:34:10,493 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0002_01_000004 is : 143
2016-05-18 05:34:10,785 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0002_01_000003 is : 143
2016-05-18 05:34:15,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0001_01_000007 is : 143
2016-05-18 05:34:17,947 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0002_01_000007 is : 143
2016-05-18 05:34:19,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...mpleted/COMPLETED/stopped
2016-05-18 05:34:19,332 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0003
2016-05-18 05:34:19,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0003/
2016-05-18 05:34:34,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0003_01_000003 is : 143
2016-05-18 05:34:34,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0003_01_000002 is : 143
2016-05-18 05:34:40,986 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0003_01_000004 is : 143
2016-05-18 05:34:42,251 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2016-05-18 05:34:42,253 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@62e7e178 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:1703)
at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1424)
at cascading.flow.BaseFlow.run(BaseFlow.java:1281)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:82)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:928)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 05:34:42,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 05:34:42,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...mpleted/COMPLETED/stopped
2016-05-18 05:34:42,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 05:34:45,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 05:34:49,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 05:34:49,034 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:08.577, using cpu time: 00:17.410
2016-05-18 05:34:49,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2016-05-18 05:34:49,066 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:34:49,067 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:34:49,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.100
2016-05-18 05:34:49,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:34:49,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:34:49,235 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 05:34:49,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 05:34:49,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 05:34:49,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:34:49,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2016-05-18 05:34:49,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 05:34:49,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 05:34:49,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 05:34:49,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 05:34:49,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 05:34:49,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0004
2016-05-18 05:34:49,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0004/
2016-05-18 05:34:49,661 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0005
2016-05-18 05:34:49,661 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0005/
2016-05-18 05:35:19,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000003 is : 143
2016-05-18 05:35:19,338 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000002 is : 143
2016-05-18 05:35:21,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000005 is : 143
2016-05-18 05:35:21,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000004 is : 143
2016-05-18 05:35:22,767 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0005_01_000006 is : 143
2016-05-18 05:35:22,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0005_01_000005 is : 143
2016-05-18 05:35:23,299 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000006 is : 143
2016-05-18 05:35:26,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0005_01_000002 is : 143
2016-05-18 05:35:26,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0005_01_000003 is : 143
2016-05-18 05:35:37,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000008 is : 143
2016-05-18 05:35:38,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000007 is : 143
2016-05-18 05:35:39,080 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000009 is : 143
2016-05-18 05:35:39,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000010 is : 143
2016-05-18 05:35:40,197 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0005_01_000007 is : 143
2016-05-18 05:35:49,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000013 is : 143
2016-05-18 05:35:49,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000015 is : 143
2016-05-18 05:35:49,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000014 is : 143
2016-05-18 05:35:52,227 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463549607423_0004_01_000020
2016-05-18 05:35:53,070 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463549607423_0004_01_000021
2016-05-18 05:35:53,108 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463549607423_0004_01_000022
2016-05-18 05:35:53,158 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1463549607423_0004_01_000023
2016-05-18 05:35:57,760 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000016 is : 143
2016-05-18 05:35:57,908 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000018 is : 143
2016-05-18 05:35:57,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000017 is : 143
2016-05-18 05:35:57,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000011 is : 143
2016-05-18 05:35:57,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0004_01_000019 is : 143
2016-05-18 05:35:59,428 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] hadoop job job_1463549607423_0004 state at FAILED
2016-05-18 05:35:59,429 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] failure info: Task failed task_1463549607423_0004_m_000000
Job failed as tasks failed. failedMaps:1 failedReduces:0
2016-05-18 05:35:59,453 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] task completion events identify failed tasks
2016-05-18 05:35:59,453 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] task completion events count: 10
2016-05-18 05:35:59,453 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000001_0, Status : FAILED
2016-05-18 05:35:59,453 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000000_0, Status : FAILED
2016-05-18 05:35:59,453 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000003_0, Status : FAILED
2016-05-18 05:35:59,453 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000002_0, Status : FAILED
2016-05-18 05:35:59,454 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000004_0, Status : SUCCEEDED
2016-05-18 05:35:59,454 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000000_1, Status : FAILED
2016-05-18 05:35:59,455 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000001_1, Status : FAILED
2016-05-18 05:35:59,455 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000003_1, Status : FAILED
2016-05-18 05:35:59,455 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000002_1, Status : FAILED
2016-05-18 05:35:59,456 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463549607423_0004_m_000000_2, Status : FAILED
2016-05-18 05:35:59,456 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (1/3)
2016-05-18 05:35:59,456 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 05:35:59,487 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 05:35:59,487 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 05:35:59,488 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 05:36:02,662 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 05:36:02,665 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 05:36:02,665 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@765f2b0f 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:1715)
at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1444)
at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1336)
at cascading.flow.BaseFlow.run(BaseFlow.java:1270)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:82)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:928)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 05:36:02,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 05:36:02,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 05:36:02,666 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 05:36:02,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 05:36:02,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 05:36:02,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:13.427, using cpu time: 00:08.740
2016-05-18 05:36:02,671 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2016-05-18 05:36:02,690 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:02,691 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:36:02,779 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 05:36:02,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:36:02,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:02,826 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2016-05-18 05:36:02,828 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 05:36:02,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 05:36:02,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:36:02,829 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testStop/stopped"]
2016-05-18 05:36:02,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 05:36:02,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 05:36:02,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 05:36:02,833 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 05:36:02,833 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 05:36:03,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0006
2016-05-18 05:36:03,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0006/
2016-05-18 05:36:03,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0007
2016-05-18 05:36:03,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0007/
2016-05-18 05:36:07,828 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:08,830 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:09,831 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:10,832 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:11,861 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:12,862 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:14,092 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:15,096 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:16,114 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:17,126 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:18,147 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:19,164 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:20,178 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:21,193 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:22,194 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:23,195 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:24,197 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:25,198 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:26,199 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:27,205 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:28,206 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:29,207 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:30,208 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:31,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0006_01_000004 is : 143
2016-05-18 05:36:31,281 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:32,101 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0006_01_000005 is : 143
2016-05-18 05:36:32,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0006_01_000006 is : 143
2016-05-18 05:36:32,283 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:32,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0006_01_000003 is : 143
2016-05-18 05:36:33,285 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:34,286 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:35,287 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:36,288 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:37,289 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 05:36:37,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0007_01_000006 is : 143
2016-05-18 05:36:37,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0007_01_000003 is : 143
2016-05-18 05:36:38,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0007_01_000002 is : 143
2016-05-18 05:36:38,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0007_01_000005 is : 143
2016-05-18 05:36:38,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0007_01_000004 is : 143
2016-05-18 05:36:38,292 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2016-05-18 05:36:38,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 05:36:38,292 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2016-05-18 05:36:38,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-05-18 05:36:38,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 05:36:38,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0006_01_000007 is : 143
2016-05-18 05:36:40,320 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 05:36:40,349 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0007_01_000007 is : 143
2016-05-18 05:36:42,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 05:36:42,339 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (1/3)
2016-05-18 05:36:42,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-05-18 05:36:42,339 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (2/3)
2016-05-18 05:36:42,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-05-18 05:36:42,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:35.464, using cpu time: 00:10.800
2016-05-18 05:36:42,373 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testStop/stopped
2016-05-18 05:36:42,393 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:42,394 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:36:42,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-05-18 05:36:42,478 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:36:42,478 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:42,515 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 05:36:42,518 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@4af8300e 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:1679)
at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1471)
at cascading.flow.BaseFlow.run(BaseFlow.java:1219)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:82)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:928)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 05:36:42,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 05:36:42,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Starting/STARTING/stopped
2016-05-18 05:36:42,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 05:36:42,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 05:36:42,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 05:36:42,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 05:36:42,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 05:36:42,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:36:42,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2016-05-18 05:36:42,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 05:36:42,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 05:36:42,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 05:36:42,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:00.001
2016-05-18 05:36:42,522 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped
2016-05-18 05:36:42,546 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:42,546 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:36:42,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:36:42,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:36:42,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:42,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopping all jobs
2016-05-18 05:36:42,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 16939:05:36:42.613
2016-05-18 05:36:42,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2016-05-18 05:36:42,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopped all jobs
2016-05-18 05:36:42,616 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testStartStopRace/startstop
2016-05-18 05:36:42,634 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:36:42,635 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:36:42,730 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-18 05:36:42,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 05:36:42,732 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:36:42,786 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 05:36:42,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 05:36:42,789 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:42,790 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 05:36:42,790 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:36:42,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2016-05-18 05:36:42,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 05:36:42,792 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 05:36:42,792 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 05:36:42,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 05:36:42,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 05:36:43,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0008
2016-05-18 05:36:43,035 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0008/
2016-05-18 05:36:43,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463549607423_0009
2016-05-18 05:36:43,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0009/
2016-05-18 05:36:43,791 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:44,792 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:45,793 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:46,794 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:47,795 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:48,796 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:49,797 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:50,802 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:51,803 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:52,803 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:53,804 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:54,804 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:55,805 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:56,805 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:57,806 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:58,806 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:36:59,807 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:00,807 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:01,808 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:02,808 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:03,809 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:04,809 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:05,810 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:06,810 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:07,811 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:08,811 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:09,812 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:10,812 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:11,813 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:12,816 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 05:37:13,822 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2016-05-18 05:37:13,822 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@7c6f3d42 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:1691)
at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1459)
at cascading.flow.BaseFlow.stop(BaseFlow.java:948)
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:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
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-05-18 05:37:13,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 05:37:13,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-05-18 05:37:13,905 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 05:37:14,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0009_01_000006 is : 143
2016-05-18 05:37:14,285 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0009_01_000002 is : 143
2016-05-18 05:37:14,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0009_01_000005 is : 143
2016-05-18 05:37:14,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0009_01_000003 is : 143
2016-05-18 05:37:14,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0008_01_000002 is : 143
2016-05-18 05:37:14,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0009_01_000004 is : 143
2016-05-18 05:37:14,949 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0008_01_000005 is : 143
2016-05-18 05:37:16,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 05:37:17,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0008_01_000007 is : 143
2016-05-18 05:37:18,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 05:37:18,986 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (1/3)
2016-05-18 05:37:18,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-05-18 05:37:18,986 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (2/3)
2016-05-18 05:37:18,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-05-18 05:37:19,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:31.035, using cpu time: 00:05.450
2016-05-18 05:37:19,021 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped
2016-05-18 05:37:19,035 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:37:19,035 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:37:19,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 05:37:19,058 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:37:19,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:37:19,062 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via sink: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["output/path"]
2016-05-18 05:37:19,079 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:37:19,080 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:37:19,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 05:37:19,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:37:19,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:37:19,128 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:37:19,129 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:37:19,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:37:19,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:37:19,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:37:19,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 05:37:19,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 05:37:19,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete"]
2016-05-18 05:37:19,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 05:37:19,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 05:37:19,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 05:37:19,173 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2016-05-18 05:37:19,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463549607423_0010
2016-05-18 05:37:19,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:39927/proxy/application_1463549607423_0010/
2016-05-18 05:37:39,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0010_01_000003 is : 143
2016-05-18 05:37:39,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0010_01_000002 is : 143
2016-05-18 05:37:40,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0010_01_000005 is : 143
2016-05-18 05:37:40,159 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0010_01_000004 is : 143
2016-05-18 05:37:40,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0010_01_000006 is : 143
2016-05-18 05:37:45,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463549607423_0010_01_000007 is : 143
2016-05-18 05:37:46,650 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2016-05-18 05:37:46,653 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete
2016-05-18 05:37:46,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:27.477, using cpu time: 00:06.540
2016-05-18 05:37:46,670 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:37:46,671 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:37:46,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 05:37:46,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:37:46,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:37:46,693 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 05:37:46,707 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:37:46,707 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:37:46,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 05:37:46,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:37:46,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:37:46,729 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 05:37:46,747 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:37:46,747 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:37:46,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 05:37:46,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 05:37:46,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:37:46,788 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/flowplatform/testFailedSerialization/badserialization