Class cascading.flow.hadoop.FlowPlatformTest

13

tests

0

failures

0

ignored

8m38.19s

duration

100%

successful

Tests

Test Duration Result
testCopyConfig 36.035s passed
testFailedSerialization 0.075s passed
testFailingListenerCompleted 2m25.69s passed
testFailingListenerStarting 0.196s passed
testFailingListenerStopping 1m6.60s passed
testFailingListenerThrowable 2m22.61s passed
testFlowID 0.116s passed
testLocalModeSink 0.046s passed
testLocalModeSource 0.090s passed
testNotLocalMode 0.051s passed
testStartStopRace 0.080s passed
testStartWithoutComplete 59.026s passed
testStop 1m7.58s passed

Standard output

2015-09-24 13:45:32,189 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 13:45:32,230 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-mr1
2015-09-24 13:45:32,257 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 13:45:44,236 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-09-24 13:45:44,933 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 13:45:49,592 WARN  fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 13:45:49,953 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.
2015-09-24 13:45:50,232 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.
2015-09-24 13:45:50,477 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.
2015-09-24 13:45:50,745 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.
2015-09-24 13:46:07,895 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-09-24 13:46:07,926 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 088FC72007A34934832C651DDF5AA612
2015-09-24 13:46:07,979 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:46:07,981 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:46:08,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2015-09-24 13:46:08,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 13:46:08,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:46:08,219 INFO  hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-09-24 13:46:08,315 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:46:08,316 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:46:08,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2015-09-24 13:46:08,369 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 13:46:08,369 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:46:08,372 INFO  hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-09-24 13:46:08,509 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:46:08,509 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:46:08,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.151
2015-09-24 13:46:08,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 13:46:08,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:46:08,765 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-09-24 13:46:08,791 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 13:46:08,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 13:46:08,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 13:46:08,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 13:46:08,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2015-09-24 13:46:08,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 13:46:08,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 13:46:08,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 13:46:08,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-09-24 13:46:08,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-09-24 13:46:09,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0001
2015-09-24 13:46:09,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0001/
2015-09-24 13:46:09,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0002
2015-09-24 13:46:09,936 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0002/
2015-09-24 13:46:36,483 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0001_01_000009
2015-09-24 13:46:36,934 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0002_01_000007
2015-09-24 13:47:11,248 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0001_01_000005 is : 143
2015-09-24 13:47:11,514 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0001_01_000002 is : 143
2015-09-24 13:47:11,640 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0002_01_000003 is : 143
2015-09-24 13:47:11,790 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0001_01_000003 is : 143
2015-09-24 13:47:11,931 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0002_01_000004 is : 143
2015-09-24 13:47:11,982 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0001_01_000008 is : 143
2015-09-24 13:47:12,151 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0001_01_000004 is : 143
2015-09-24 13:47:12,276 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0002_01_000002 is : 143
2015-09-24 13:47:12,278 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0002_01_000006 is : 143
2015-09-24 13:47:12,360 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0002_01_000005 is : 143
2015-09-24 13:47:31,212 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0002_01_000008 is : 143
2015-09-24 13:47:31,288 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0001_01_000010 is : 143
2015-09-24 13:47:32,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...mpleted/COMPLETED/stopped
2015-09-24 13:47:32,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0003
2015-09-24 13:47:32,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0003/
2015-09-24 13:48:07,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0003_01_000002 is : 143
2015-09-24 13:48:07,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0003_01_000003 is : 143
2015-09-24 13:48:26,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0003_01_000004 is : 143
2015-09-24 13:48:27,417 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2015-09-24 13:48:27,418 WARN  flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@410cb694 threw throwable
java.lang.RuntimeException: intentionally failed on: COMPLETED
	at cascading.flow.FailingFlowListener.onCompleted(FailingFlowListener.java:61)
	at cascading.flow.BaseFlow$SafeFlowListener.onCompleted(BaseFlow.java:1632)
	at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1353)
	at cascading.flow.BaseFlow.run(BaseFlow.java:1223)
	at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
	at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
	at java.lang.Thread.run(Thread.java:745)
2015-09-24 13:48:27,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-09-24 13:48:27,423 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...mpleted/COMPLETED/stopped
2015-09-24 13:48:27,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2015-09-24 13:48:30,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2015-09-24 13:48:34,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-09-24 13:48:34,052 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 02:18.615
2015-09-24 13:48:34,053 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2015-09-24 13:48:34,112 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:48:34,112 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:48:34,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.112
2015-09-24 13:48:34,233 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 13:48:34,233 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:48:34,280 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-09-24 13:48:34,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 13:48:34,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 13:48:34,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 13:48:34,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2015-09-24 13:48:34,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 13:48:34,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 13:48:34,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 13:48:34,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-09-24 13:48:34,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-09-24 13:48:34,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0004
2015-09-24 13:48:34,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0004/
2015-09-24 13:48:34,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0005
2015-09-24 13:48:34,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0005/
2015-09-24 13:48:59,668 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0004_01_000009
2015-09-24 13:48:59,930 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0005_01_000007
2015-09-24 13:49:34,422 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0005_01_000003 is : 143
2015-09-24 13:49:34,572 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000007 is : 143
2015-09-24 13:49:34,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0005_01_000002 is : 143
2015-09-24 13:49:34,943 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0005_01_000005 is : 143
2015-09-24 13:49:35,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000002 is : 143
2015-09-24 13:49:35,120 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0005_01_000004 is : 143
2015-09-24 13:49:35,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0005_01_000006 is : 143
2015-09-24 13:49:35,237 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000004 is : 143
2015-09-24 13:49:35,240 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000003 is : 143
2015-09-24 13:49:35,300 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000005 is : 143
2015-09-24 13:49:39,279 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0004_01_000014
2015-09-24 13:49:39,930 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0004_01_000015
2015-09-24 13:49:40,108 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0004_01_000016
2015-09-24 13:50:01,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0005_01_000008 is : 143
2015-09-24 13:50:01,614 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000011 is : 143
2015-09-24 13:50:01,663 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000012 is : 143
2015-09-24 13:50:01,668 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000010 is : 143
2015-09-24 13:50:01,789 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000013 is : 143
2015-09-24 13:50:26,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000020 is : 143
2015-09-24 13:50:26,929 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000018 is : 143
2015-09-24 13:50:27,015 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000021 is : 143
2015-09-24 13:50:27,057 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000019 is : 143
2015-09-24 13:50:52,179 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000025 is : 143
2015-09-24 13:50:52,208 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000023 is : 143
2015-09-24 13:50:52,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000022 is : 143
2015-09-24 13:50:52,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000024 is : 143
2015-09-24 13:50:52,289 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0004_01_000017 is : 143
2015-09-24 13:50:53,430 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] hadoop job job_1443116762376_0004 state at FAILED
2015-09-24 13:50:53,430 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] failure info: Task failed task_1443116762376_0004_m_000000
Job failed as tasks failed. failedMaps:1 failedReduces:0

2015-09-24 13:50:53,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events identify failed tasks
2015-09-24 13:50:53,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events count: 10
2015-09-24 13:50:53,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000004_0, Status : SUCCEEDED
2015-09-24 13:50:53,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000000_0, Status : FAILED
2015-09-24 13:50:53,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000001_0, Status : FAILED
2015-09-24 13:50:53,457 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000002_0, Status : FAILED
2015-09-24 13:50:53,457 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000003_0, Status : FAILED
2015-09-24 13:50:53,457 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000001_1, Status : FAILED
2015-09-24 13:50:53,457 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000000_1, Status : FAILED
2015-09-24 13:50:53,457 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000002_1, Status : FAILED
2015-09-24 13:50:53,458 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000003_1, Status : FAILED
2015-09-24 13:50:53,458 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] event = Task Id : attempt_1443116762376_0004_m_000002_2, Status : FAILED
2015-09-24 13:50:53,458 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...rowable/THROWABLE/stopped, predecessor failed: (1/3)
2015-09-24 13:50:53,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2015-09-24 13:50:53,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-09-24 13:50:53,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2015-09-24 13:50:53,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2015-09-24 13:50:56,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2015-09-24 13:50:56,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-09-24 13:50:56,649 WARN  flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@25f8e69a threw throwable
java.lang.RuntimeException: intentionally failed on: THROWABLE
	at cascading.flow.FailingFlowListener.onThrowable(FailingFlowListener.java:69)
	at cascading.flow.BaseFlow$SafeFlowListener.onThrowable(BaseFlow.java:1644)
	at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1373)
	at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1272)
	at cascading.flow.BaseFlow.run(BaseFlow.java:1212)
	at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
	at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
	at java.lang.Thread.run(Thread.java:745)
2015-09-24 13:50:56,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-09-24 13:50:56,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...rowable/THROWABLE/stopped
2015-09-24 13:50:56,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2015-09-24 13:50:56,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2015-09-24 13:50:56,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-09-24 13:50:56,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 02:22.364
2015-09-24 13:50:56,677 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2015-09-24 13:50:56,713 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:50:56,714 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:50:56,825 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.102
2015-09-24 13:50:56,830 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 13:50:56,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:50:56,872 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2015-09-24 13:50:56,877 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 13:50:56,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 13:50:56,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 13:50:56,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testStop/stopped"]
2015-09-24 13:50:56,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 13:50:56,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 13:50:56,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 13:50:56,881 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-09-24 13:50:56,881 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-09-24 13:50:57,174 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0007
2015-09-24 13:50:57,174 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0007/
2015-09-24 13:50:57,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0006
2015-09-24 13:50:57,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0006/
2015-09-24 13:51:01,881 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:02,887 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:03,892 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:04,898 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:05,905 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:06,909 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:07,914 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:08,917 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:09,922 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:10,928 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:11,932 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:12,938 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:13,941 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:14,943 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:15,949 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:16,953 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:17,956 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:18,963 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:19,966 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:20,973 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:21,979 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:22,983 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:23,256 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0007_01_000007
2015-09-24 13:51:23,326 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0006_01_000009
2015-09-24 13:51:23,985 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:24,990 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:25,996 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:27,001 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:28,005 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:29,009 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:30,011 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:31,016 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:32,022 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:33,027 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:34,032 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:35,035 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:36,041 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:37,044 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:38,050 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:39,052 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:40,061 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:41,066 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:42,070 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:43,074 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:44,079 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:45,081 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:46,081 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:47,086 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:48,090 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:49,094 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:50,100 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:51,102 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:52,107 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:53,111 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:54,116 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:55,120 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:56,124 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:57,128 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:58,133 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:59,137 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2015-09-24 13:51:59,348 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0006_01_000008 is : 143
2015-09-24 13:51:59,349 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0007_01_000006 is : 143
2015-09-24 13:51:59,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0006_01_000005 is : 143
2015-09-24 13:51:59,479 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0006_01_000004 is : 143
2015-09-24 13:51:59,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0007_01_000005 is : 143
2015-09-24 13:51:59,768 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0007_01_000003 is : 143
2015-09-24 13:51:59,865 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0006_01_000003 is : 143
2015-09-24 13:51:59,955 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0007_01_000002 is : 143
2015-09-24 13:52:00,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0006_01_000002 is : 143
2015-09-24 13:52:00,062 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0007_01_000004 is : 143
2015-09-24 13:52:00,140 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2015-09-24 13:52:00,140 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2015-09-24 13:52:00,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-09-24 13:52:00,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2015-09-24 13:52:00,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2015-09-24 13:52:02,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2015-09-24 13:52:04,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-09-24 13:52:04,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2015-09-24 13:52:04,219 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (1/3)
2015-09-24 13:52:04,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2015-09-24 13:52:04,219 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...platform/testStop/stopped, predecessor failed: (2/3)
2015-09-24 13:52:04,220 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...platform/testStop/stopped
2015-09-24 13:52:04,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2015-09-24 13:52:04,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:03.264
2015-09-24 13:52:04,258 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testStop/stopped
2015-09-24 13:52:04,280 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:52:04,280 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:52:04,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2015-09-24 13:52:04,381 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 13:52:04,381 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:52:04,446 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-09-24 13:52:04,449 WARN  flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@34347cda threw throwable
java.lang.RuntimeException: intentionally failed on: STARTING
	at cascading.flow.FailingFlowListener.onStarting(FailingFlowListener.java:45)
	at cascading.flow.BaseFlow$SafeFlowListener.onStarting(BaseFlow.java:1608)
	at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1400)
	at cascading.flow.BaseFlow.run(BaseFlow.java:1161)
	at cascading.flow.BaseFlow.access$100(BaseFlow.java:81)
	at cascading.flow.BaseFlow$1.run(BaseFlow.java:870)
	at java.lang.Thread.run(Thread.java:745)
2015-09-24 13:52:04,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-09-24 13:52:04,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Starting/STARTING/stopped
2015-09-24 13:52:04,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2015-09-24 13:52:04,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2015-09-24 13:52:04,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-09-24 13:52:04,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 13:52:04,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 13:52:04,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 13:52:04,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2015-09-24 13:52:04,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 13:52:04,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 13:52:04,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 13:52:04,455 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:00.001
2015-09-24 13:52:04,456 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStarting/STARTING/stopped
2015-09-24 13:52:04,478 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:52:04,479 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:52:04,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-09-24 13:52:04,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:52:04,522 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:52:04,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping all jobs
2015-09-24 13:52:04,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2015-09-24 13:52:04,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] stopped all jobs
2015-09-24 13:52:04,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 16702:17:52:04.534
2015-09-24 13:52:04,535 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testStartStopRace/startstop
2015-09-24 13:52:04,560 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:52:04,560 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:52:04,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.089
2015-09-24 13:52:04,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 13:52:04,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:52:04,689 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-09-24 13:52:04,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 13:52:04,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 13:52:04,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 13:52:04,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2015-09-24 13:52:04,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 13:52:04,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 13:52:04,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 13:52:04,693 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:04,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-09-24 13:52:04,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-09-24 13:52:04,927 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0008
2015-09-24 13:52:04,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0008/
2015-09-24 13:52:05,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443116762376_0009
2015-09-24 13:52:05,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:61038/proxy/application_1443116762376_0009/
2015-09-24 13:52:05,702 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:06,707 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:07,711 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:08,715 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:08,781 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0007_01_000001
2015-09-24 13:52:09,720 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:10,725 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:11,728 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:12,733 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:13,738 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:14,742 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:15,746 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:16,750 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:17,755 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:18,759 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:19,765 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:20,767 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:21,769 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:22,771 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:23,774 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:24,775 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:25,779 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:26,795 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:27,800 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:28,831 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:29,832 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:30,836 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:30,846 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0008_01_000009
2015-09-24 13:52:31,647 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443116762376_0008_01_000010
2015-09-24 13:52:31,838 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:32,842 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:33,843 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:34,847 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:35,851 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:36,854 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:37,858 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:38,860 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:39,866 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:40,871 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:41,875 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:42,879 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:43,884 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:44,888 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:45,893 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:46,895 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:47,896 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:48,901 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:49,905 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:50,910 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:51,912 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:52,917 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:53,921 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:54,924 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:55,925 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:56,926 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:57,932 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:58,936 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:52:59,937 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:00,939 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:01,944 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:02,944 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:03,947 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:04,952 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:05,953 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-09-24 13:53:06,457 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0009_01_000002 is : 143
2015-09-24 13:53:06,500 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0009_01_000004 is : 143
2015-09-24 13:53:06,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0008_01_000003 is : 143
2015-09-24 13:53:06,719 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0008_01_000004 is : 143
2015-09-24 13:53:06,831 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0009_01_000003 is : 143
2015-09-24 13:53:06,938 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0008_01_000006 is : 143
2015-09-24 13:53:06,958 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2015-09-24 13:53:06,958 WARN  flow.Flow (BaseFlow.java:logWarn(1451)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@5322240b threw throwable
java.lang.RuntimeException: intentionally failed on: STOPPING
	at cascading.flow.FailingFlowListener.onStopping(FailingFlowListener.java:53)
	at cascading.flow.BaseFlow$SafeFlowListener.onStopping(BaseFlow.java:1620)
	at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1388)
	at cascading.flow.BaseFlow.stop(BaseFlow.java:890)
	at cascading.flow.hadoop.FlowPlatformTest.failingListenerTest(FlowPlatformTest.java:419)
	at cascading.flow.hadoop.FlowPlatformTest.testFailingListenerStopping(FlowPlatformTest.java:328)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
	at org.junit.rules.RunRules.evaluate(RunRules.java:20)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:301)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:68)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:69)
	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:105)
	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:355)
	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)
2015-09-24 13:53:06,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-09-24 13:53:06,961 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2015-09-24 13:53:06,968 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (2/3)
2015-09-24 13:53:07,037 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0009_01_000005 is : 143
2015-09-24 13:53:07,052 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0009_01_000006 is : 143
2015-09-24 13:53:07,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0008_01_000002 is : 143
2015-09-24 13:53:07,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0008_01_000005 is : 143
2015-09-24 13:53:09,063 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/3)
2015-09-24 13:53:09,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0008_01_000011 is : 143
2015-09-24 13:53:11,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-09-24 13:53:11,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutting down job executor
2015-09-24 13:53:11,089 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (1/3)
2015-09-24 13:53:11,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2015-09-24 13:53:11,090 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] abandoning step: (3/3) ...Stopping/STOPPING/stopped, predecessor failed: (2/3)
2015-09-24 13:53:11,090 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (3/3) ...Stopping/STOPPING/stopped
2015-09-24 13:53:11,132 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] shutdown complete
2015-09-24 13:53:11,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:02.267
2015-09-24 13:53:11,135 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testFailingListenerStopping/STOPPING/stopped
2015-09-24 13:53:11,156 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:53:11,156 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:53:11,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-09-24 13:53:11,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 13:53:11,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:53:11,181 INFO  hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-09-24 13:53:11,197 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:53:11,197 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:53:11,221 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-09-24 13:53:11,222 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 13:53:11,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:53:11,256 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:53:11,257 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:53:11,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-09-24 13:53:11,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:53:11,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:53:11,301 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-09-24 13:53:11,301 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 13:53:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete"]
2015-09-24 13:53:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2015-09-24 13:53:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2015-09-24 13:53:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2015-09-24 13:53:11,304 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2015-09-24 13:53:11,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1443116762376_0010
2015-09-24 13:53:11,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://localhost:61038/proxy/application_1443116762376_0010/
2015-09-24 13:53:17,050 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1081)) - Event EventType: FINISH_APPLICATION sent to absent application application_1443116762376_0008
2015-09-24 13:53:50,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0010_01_000005 is : 143
2015-09-24 13:53:50,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0010_01_000002 is : 143
2015-09-24 13:53:50,411 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0010_01_000006 is : 143
2015-09-24 13:53:50,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0010_01_000004 is : 143
2015-09-24 13:53:50,514 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0010_01_000003 is : 143
2015-09-24 13:54:09,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443116762376_0010_01_000007 is : 143
2015-09-24 13:54:10,244 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2015-09-24 13:54:10,248 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testStartWithoutComplete/withoutcomplete
2015-09-24 13:54:10,248 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 00:58.940
2015-09-24 13:54:10,285 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:54:10,285 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:54:10,309 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-09-24 13:54:10,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 13:54:10,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:54:10,314 INFO  hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-09-24 13:54:10,335 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:54:10,335 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:54:10,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-09-24 13:54:10,359 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 13:54:10,359 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:54:10,372 INFO  hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-09-24 13:54:10,407 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 13:54:10,407 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 13:54:10,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-09-24 13:54:10,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 13:54:10,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 13:54:10,452 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/flowplatform/testFailedSerialization/badserialization

Standard error

Sep 24, 2015 1:46:02 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Sep 24, 2015 1:46:02 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 1:46:02 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 1:46:02 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 1:46:02 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:03 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:03 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Sep 24, 2015 1:46:03 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 1:46:04 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 1:46:04 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Sep 24, 2015 1:46:04 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 1:46:04 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 1:46:04 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:04 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:04 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:04 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 1:46:05 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Sep 24, 2015 1:46:05 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 1:46:05 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 1:46:05 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 1:46:05 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:05 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:05 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:05 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 1:46:06 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Sep 24, 2015 1:46:06 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 1:46:06 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 1:46:06 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 1:46:06 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:06 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:06 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:06 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 1:46:07 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Sep 24, 2015 1:46:07 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 1:46:07 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 1:46:07 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 1:46:07 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:07 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:07 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 1:46:07 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.