2016-05-18 11:36:46,042 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 11:36:46,062 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-mr1
2016-05-18 11:36:46,088 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 11:36:47,122 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 11:36:47,739 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 11:36:52,050 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 11:36:52,273 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 11:36:52,478 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 11:36:52,659 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 11:37:09,757 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 11:37:09,781 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: CCAD3C4A767B4A13924B83C7EC6D4EBC
2016-05-18 11:37:09,808 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:37:09,809 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 11:37:09,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-18 11:37:09,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 11:37:09,989 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 11:37:10,019 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 11:37:10,110 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:37:10,111 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 11:37:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 11:37:10,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 11:37:10,155 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 11:37:10,157 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 11:37:10,261 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:37:10,262 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 11:37:10,420 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.147
2016-05-18 11:37:10,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 11:37:10,423 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 11:37:10,511 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 11:37:10,533 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 11:37:10,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 11:37:10,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 11:37:10,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 11:37:10,535 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.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2016-05-18 11:37:10,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 11:37:10,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 11:37:10,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 11:37:10,540 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 11:37:10,540 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 11:37:11,550 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0002
2016-05-18 11:37:11,550 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0001
2016-05-18 11:37:11,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0001/
2016-05-18 11:37:11,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0002/
2016-05-18 11:37:32,909 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0001_01_000003 is : 143
2016-05-18 11:37:33,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0001_01_000002 is : 143
2016-05-18 11:37:34,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0001_01_000005 is : 143
2016-05-18 11:37:34,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0001_01_000004 is : 143
2016-05-18 11:37:34,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0001_01_000006 is : 143
2016-05-18 11:37:39,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0001_01_000007 is : 143
2016-05-18 11:38:07,482 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0002_01_000006 is : 143
2016-05-18 11:38:07,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0002_01_000002 is : 143
2016-05-18 11:38:07,827 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0002_01_000004 is : 143
2016-05-18 11:38:07,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0002_01_000003 is : 143
2016-05-18 11:38:08,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0002_01_000005 is : 143
2016-05-18 11:38:14,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0002_01_000007 is : 143
2016-05-18 11:38:15,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...mpleted/COMPLETED/stopped
2016-05-18 11:38:15,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0003
2016-05-18 11:38:15,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0003/
2016-05-18 11:38:20,413 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0002_01_000001
2016-05-18 11:38:34,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0003_01_000002 is : 143
2016-05-18 11:38:34,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0003_01_000003 is : 143
2016-05-18 11:38:40,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0003_01_000004 is : 143
2016-05-18 11:38:42,183 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2016-05-18 11:38:42,184 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@6e4851b6 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 11:38:42,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 11:38:42,188 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...mpleted/COMPLETED/stopped
2016-05-18 11:38:42,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 11:38:45,541 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 11:38:48,766 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 11:38:48,768 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 01:31.642, using cpu time: 00:17.650
2016-05-18 11:38:48,769 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2016-05-18 11:38:48,812 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:38:48,813 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 11:38:48,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.107
2016-05-18 11:38:48,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 11:38:48,929 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 11:38:49,004 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 11:38:49,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 11:38:49,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 11:38:49,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 11:38:49,007 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.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2016-05-18 11:38:49,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 11:38:49,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 11:38:49,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 11:38:49,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 11:38:49,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 11:38:49,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0004
2016-05-18 11:38:49,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0004/
2016-05-18 11:38:49,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0005
2016-05-18 11:38:49,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0005/
2016-05-18 11:39:09,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000003 is : 143
2016-05-18 11:39:09,890 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000006 is : 143
2016-05-18 11:39:09,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000002 is : 143
2016-05-18 11:39:10,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000004 is : 143
2016-05-18 11:39:23,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000008 is : 143
2016-05-18 11:39:23,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000009 is : 143
2016-05-18 11:39:23,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000007 is : 143
2016-05-18 11:39:24,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000010 is : 143
2016-05-18 11:39:27,348 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000016
2016-05-18 11:39:27,810 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000017
2016-05-18 11:39:28,077 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000018
2016-05-18 11:39:28,349 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000019
2016-05-18 11:39:33,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000012 is : 143
2016-05-18 11:39:34,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000014 is : 143
2016-05-18 11:39:34,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000015 is : 143
2016-05-18 11:39:35,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000013 is : 143
2016-05-18 11:39:37,987 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000024
2016-05-18 11:39:38,352 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000025
2016-05-18 11:39:38,766 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0004_01_000026
2016-05-18 11:39:43,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000020 is : 143
2016-05-18 11:39:43,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000022 is : 143
2016-05-18 11:39:43,466 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000011 is : 143
2016-05-18 11:39:43,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000021 is : 143
2016-05-18 11:39:43,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0004_01_000023 is : 143
2016-05-18 11:39:44,681 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] hadoop job job_1463571424255_0004 state at FAILED
2016-05-18 11:39:44,682 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] failure info: Task failed task_1463571424255_0004_m_000001
Job failed as tasks failed. failedMaps:1 failedReduces:0
2016-05-18 11:39:44,707 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] task completion events identify failed tasks
2016-05-18 11:39:44,708 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] task completion events count: 10
2016-05-18 11:39:44,708 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000003_0, Status : FAILED
2016-05-18 11:39:44,708 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000001_0, Status : FAILED
2016-05-18 11:39:44,708 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000004_0, Status : SUCCEEDED
2016-05-18 11:39:44,708 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000000_0, Status : FAILED
2016-05-18 11:39:44,708 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000002_0, Status : FAILED
2016-05-18 11:39:44,709 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000001_1, Status : FAILED
2016-05-18 11:39:44,709 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000000_1, Status : FAILED
2016-05-18 11:39:44,709 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000003_1, Status : FAILED
2016-05-18 11:39:44,709 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000002_1, Status : FAILED
2016-05-18 11:39:44,709 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] event = Task Id : attempt_1463571424255_0004_m_000001_2, Status : FAILED
2016-05-18 11:39:44,709 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (1/3)
2016-05-18 11:39:44,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 11:39:44,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 11:39:44,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 11:39:44,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 11:39:44,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 11:39:44,956 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (2/3)
2016-05-18 11:39:44,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 11:39:44,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 11:39:44,960 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@70c192ec 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 11:39:44,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 11:39:44,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2016-05-18 11:39:44,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 11:39:44,962 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 11:39:44,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 11:39:44,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:55.954, using cpu time: 00:01.190
2016-05-18 11:39:44,966 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2016-05-18 11:39:44,992 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:39:44,993 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 11:39:45,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 11:39:45,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 11:39:45,085 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 11:39:45,125 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2016-05-18 11:39:45,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 11:39:45,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 11:39:45,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 11:39:45,129 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.7.x/build/test/output/hadoop2-mr1/flowplatform/testStop/stopped"]
2016-05-18 11:39:45,130 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 11:39:45,130 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 11:39:45,130 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 11:39:45,131 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 11:39:45,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 11:39:45,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0007
2016-05-18 11:39:45,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0007/
2016-05-18 11:39:45,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0006
2016-05-18 11:39:45,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0006/
2016-05-18 11:39:50,128 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:51,129 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:52,130 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:53,131 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:54,132 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:55,133 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:56,134 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:57,135 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:58,135 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:39:59,166 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:00,167 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:01,169 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:02,170 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:03,172 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:04,173 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:05,174 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:06,176 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:07,177 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:08,178 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:09,184 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:10,184 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:10,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0006_01_000003 is : 143
2016-05-18 11:40:10,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0006_01_000004 is : 143
2016-05-18 11:40:11,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0006_01_000005 is : 143
2016-05-18 11:40:11,188 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:11,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0006_01_000006 is : 143
2016-05-18 11:40:11,348 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0006_01_000002 is : 143
2016-05-18 11:40:12,189 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:13,190 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:14,191 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:15,192 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:16,193 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:17,193 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:17,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0006_01_000007 is : 143
2016-05-18 11:40:18,194 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:19,195 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:20,196 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:21,197 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:22,198 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:23,199 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:24,199 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:24,380 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463571424255_0006_01_000001
2016-05-18 11:40:25,200 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:26,201 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:27,204 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:28,208 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:29,209 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:30,209 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:31,209 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:32,210 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:33,210 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:34,212 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:35,212 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:36,213 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:37,214 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:38,214 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:39,214 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:40,215 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:41,215 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:42,216 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:43,216 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 11:40:43,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0007_01_000002 is : 143
2016-05-18 11:40:44,223 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2016-05-18 11:40:44,223 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2016-05-18 11:40:44,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 11:40:44,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-05-18 11:40:44,227 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 11:40:44,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0007_01_000005 is : 143
2016-05-18 11:40:44,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0007_01_000003 is : 143
2016-05-18 11:40:44,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0007_01_000006 is : 143
2016-05-18 11:40:45,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0007_01_000004 is : 143
2016-05-18 11:40:47,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 11:40:47,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0007_01_000007 is : 143
2016-05-18 11:40:49,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 11:40:49,473 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (1/3)
2016-05-18 11:40:49,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2016-05-18 11:40:49,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:59.097, using cpu time: 00:13.170
2016-05-18 11:40:49,509 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testStop/stopped
2016-05-18 11:40:49,530 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:40:49,531 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 11:40:49,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-05-18 11:40:49,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 11:40:49,622 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 11:40:49,663 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 11:40:49,666 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@4d9408e4 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 11:40:49,667 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 11:40:49,667 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Starting/STARTING/stopped
2016-05-18 11:40:49,668 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 11:40:49,668 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 11:40:49,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 11:40:49,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 11:40:49,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 11:40:49,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 11:40:49,669 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.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2016-05-18 11:40:49,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 11:40:49,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 11:40:49,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 11:40:49,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:00.001
2016-05-18 11:40:49,670 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped
2016-05-18 11:40:49,689 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:40:49,689 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 11:40:49,730 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 11:40:49,731 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 11:40:49,732 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 11:40:49,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopping all jobs
2016-05-18 11:40:49,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2016-05-18 11:40:49,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 16939:11:40:49.752
2016-05-18 11:40:49,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopped all jobs
2016-05-18 11:40:49,753 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testStartStopRace/startstop
2016-05-18 11:40:49,785 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:40:49,786 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 11:40:49,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.095
2016-05-18 11:40:49,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2016-05-18 11:40:49,892 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 11:40:49,939 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 11:40:49,942 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 11:40:49,942 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:49,942 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 11:40:49,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 11:40:49,944 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.7.x/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2016-05-18 11:40:49,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 11:40:49,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 3
2016-05-18 11:40:49,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 3
2016-05-18 11:40:49,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 11:40:49,950 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 11:40:50,213 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0009
2016-05-18 11:40:50,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0009/
2016-05-18 11:40:50,390 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463571424255_0008
2016-05-18 11:40:50,390 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0008/
2016-05-18 11:40:50,943 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:51,944 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:52,944 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:53,945 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:54,945 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:55,945 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:56,946 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:57,946 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:58,947 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:40:59,947 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:00,948 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:01,948 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:02,956 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:03,956 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:04,956 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:05,957 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:06,957 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:07,958 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:08,958 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:09,959 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:10,959 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:11,960 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:12,960 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:13,961 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 11:41:14,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0008_01_000004 is : 143
2016-05-18 11:41:14,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0008_01_000002 is : 143
2016-05-18 11:41:14,994 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2016-05-18 11:41:14,994 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@17f17e2d 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 11:41:14,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 11:41:15,012 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-05-18 11:41:15,023 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (2/3)
2016-05-18 11:41:15,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-05-18 11:41:15,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0008_01_000005 is : 143
2016-05-18 11:41:15,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/3)
2016-05-18 11:41:15,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0008_01_000006 is : 143
2016-05-18 11:41:15,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0008_01_000003 is : 143
2016-05-18 11:41:17,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 11:41:17,330 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (1/3)
2016-05-18 11:41:17,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-05-18 11:41:17,331 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (2/3)
2016-05-18 11:41:17,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2016-05-18 11:41:17,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:25.053, using cpu time: 00:03.310
2016-05-18 11:41:17,371 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped
2016-05-18 11:41:17,387 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:41:17,387 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 11:41:17,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 11:41:17,409 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 11:41:17,409 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 11:41:17,413 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 11:41:17,430 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:41:17,430 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 11:41:17,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 11:41:17,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 11:41:17,458 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 11:41:17,484 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:41:17,484 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 11:41:17,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 11:41:17,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 11:41:17,514 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 11:41:17,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 11:41:17,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 11:41:17,525 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.7.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete"]
2016-05-18 11:41:17,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 11:41:17,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 11:41:17,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 11:41:17,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2016-05-18 11:41:17,640 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463571424255_0010
2016-05-18 11:41:17,640 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:57600/proxy/application_1463571424255_0010/
2016-05-18 11:41:41,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0010_01_000003 is : 143
2016-05-18 11:41:42,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0010_01_000002 is : 143
2016-05-18 11:41:43,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0010_01_000006 is : 143
2016-05-18 11:41:43,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0010_01_000004 is : 143
2016-05-18 11:41:43,192 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0010_01_000005 is : 143
2016-05-18 11:41:48,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463571424255_0010_01_000007 is : 143
2016-05-18 11:41:50,066 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2016-05-18 11:41:50,067 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete
2016-05-18 11:41:50,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:32.538, using cpu time: 00:07.590
2016-05-18 11:41:50,087 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:41:50,088 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 11:41:50,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 11:41:50,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 11:41:50,110 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 11:41:50,112 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 11:41:50,128 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:41:50,128 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 11:41:50,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 11:41:50,149 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 11:41:50,149 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 11:41:50,150 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 11:41:50,170 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:41:50,171 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 11:41:50,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 11:41:50,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 11:41:50,201 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 11:41:50,214 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/flowplatform/testFailedSerialization/badserialization