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