Class cascading.flow.hadoop.FlowPlatformTest

13

tests

0

failures

0

ignored

4m1.17s

duration

100%

successful

Tests

Test Duration Result
testCopyConfig 22.546s passed
testFailedSerialization 0.025s passed
testFailingListenerCompleted 1m8.30s passed
testFailingListenerStarting 0.056s passed
testFailingListenerStopping 34.362s passed
testFailingListenerThrowable 58.538s passed
testFlowID 0.036s passed
testLocalModeSink 0.030s passed
testLocalModeSource 0.045s passed
testNotLocalMode 0.028s passed
testStartStopRace 0.032s passed
testStartWithoutComplete 25.767s passed
testStop 31.400s passed

Standard output

2015-07-17 15:18:28,182 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:18:28,197 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:18:28,197 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.flow.hadoop.FlowPlatformTest
2015-07-17 15:18:28,218 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 15:18:29,007 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-07-17 15:18:29,484 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 15:18:32,946 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-07-17 15:18:33,142 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-07-17 15:18:33,315 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-07-17 15:18:33,487 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-07-17 15:18:50,631 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 15:18:50,651 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 24159CF6E8B74A568E005104F081611E
2015-07-17 15:18:50,674 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:18:50,675 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:18:50,725 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-07-17 15:18:50,778 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:18:50,779 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:18:50,785 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-07-17 15:18:50,803 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-07-17 15:18:50,884 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:18:50,885 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:18:50,944 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-07-17 15:18:50,961 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:18:50,962 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 15:18:50,963 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 15:18:50,963 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 15:18:50,963 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped"]
2015-07-17 15:18:50,963 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 15:18:50,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-07-17 15:18:50,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-07-17 15:18:50,965 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-07-17 15:18:50,965 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-07-17 15:18:51,870 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0002
2015-07-17 15:18:51,871 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0002/
2015-07-17 15:18:51,953 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0001
2015-07-17 15:18:51,953 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0001/
2015-07-17 15:19:20,607 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0002_01_000003 is : 143
2015-07-17 15:19:20,758 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0002_01_000002 is : 143
2015-07-17 15:19:20,864 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0002_01_000005 is : 143
2015-07-17 15:19:20,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0002_01_000006 is : 143
2015-07-17 15:19:21,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0001_01_000006 is : 143
2015-07-17 15:19:21,191 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0002_01_000004 is : 143
2015-07-17 15:19:21,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0001_01_000005 is : 143
2015-07-17 15:19:21,299 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0001_01_000004 is : 143
2015-07-17 15:19:21,360 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0001_01_000002 is : 143
2015-07-17 15:19:21,422 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0001_01_000003 is : 143
2015-07-17 15:19:27,883 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0002_01_000007 is : 143
2015-07-17 15:19:28,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0001_01_000007 is : 143
2015-07-17 15:19:29,303 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...latform/COMPLETED/stopped
2015-07-17 15:19:29,475 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0003
2015-07-17 15:19:29,476 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0003/
2015-07-17 15:19:45,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0003_01_000002 is : 143
2015-07-17 15:19:45,528 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0003_01_000003 is : 143
2015-07-17 15:19:51,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0003_01_000004 is : 143
2015-07-17 15:19:52,481 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped/_temporary
2015-07-17 15:19:52,482 WARN  flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@3dfbbf26 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:1548)
	at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1303)
	at cascading.flow.BaseFlow.run(BaseFlow.java:1187)
	at cascading.flow.BaseFlow.access$100(BaseFlow.java:78)
	at cascading.flow.BaseFlow$1.run(BaseFlow.java:834)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:19:52,485 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-07-17 15:19:52,485 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/COMPLETED/stopped
2015-07-17 15:19:52,487 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-07-17 15:19:55,892 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-07-17 15:19:59,094 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-07-17 15:19:59,095 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/COMPLETED/stopped
2015-07-17 15:19:59,133 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:19:59,134 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:19:59,171 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-07-17 15:19:59,173 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 15:19:59,174 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 15:19:59,174 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 15:19:59,174 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/THROWABLE/stopped"]
2015-07-17 15:19:59,174 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 15:19:59,174 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-07-17 15:19:59,174 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-07-17 15:19:59,176 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-07-17 15:19:59,176 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-07-17 15:19:59,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0004
2015-07-17 15:19:59,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0004/
2015-07-17 15:19:59,379 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0005
2015-07-17 15:19:59,379 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0005/
2015-07-17 15:20:27,175 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0004_01_000002 is : 143
2015-07-17 15:20:27,411 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0004_01_000004 is : 143
2015-07-17 15:20:27,501 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0004_01_000006 is : 143
2015-07-17 15:20:27,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0004_01_000005 is : 143
2015-07-17 15:20:27,793 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0004_01_000003 is : 143
2015-07-17 15:20:27,895 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000003 is : 143
2015-07-17 15:20:28,167 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000002 is : 143
2015-07-17 15:20:28,284 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000005 is : 143
2015-07-17 15:20:28,361 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000004 is : 143
2015-07-17 15:20:28,397 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000006 is : 143
2015-07-17 15:20:31,786 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437171525123_0005_01_000011
2015-07-17 15:20:32,160 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437171525123_0005_01_000012
2015-07-17 15:20:32,341 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437171525123_0005_01_000013
2015-07-17 15:20:32,501 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437171525123_0005_01_000014
2015-07-17 15:20:39,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000007 is : 143
2015-07-17 15:20:41,601 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0004_01_000007 is : 143
2015-07-17 15:20:42,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000008 is : 143
2015-07-17 15:20:42,285 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000009 is : 143
2015-07-17 15:20:42,420 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000010 is : 143
2015-07-17 15:20:46,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000016 is : 143
2015-07-17 15:20:50,997 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000017 is : 143
2015-07-17 15:20:51,106 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000018 is : 143
2015-07-17 15:20:51,284 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000019 is : 143
2015-07-17 15:20:53,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000020 is : 143
2015-07-17 15:20:53,256 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000021 is : 143
2015-07-17 15:20:53,260 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0005_01_000015 is : 143
2015-07-17 15:20:54,402 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] hadoop job job_1437171525123_0005 state at FAILED
2015-07-17 15:20:54,403 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] failure info: Task failed task_1437171525123_0005_m_000001
Job failed as tasks failed. failedMaps:1 failedReduces:0

2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events identify failed tasks
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events count: 10
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000001_0, Status : FAILED
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000000_0, Status : FAILED
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000003_0, Status : FAILED
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000004_0, Status : SUCCEEDED
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000002_0, Status : FAILED
2015-07-17 15:20:54,423 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000001_1, Status : FAILED
2015-07-17 15:20:54,424 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000000_1, Status : FAILED
2015-07-17 15:20:54,424 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000003_1, Status : FAILED
2015-07-17 15:20:54,424 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000002_1, Status : FAILED
2015-07-17 15:20:54,424 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1437171525123_0005_m_000001_2, Status : FAILED
2015-07-17 15:20:54,449 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...latform/THROWABLE/stopped, predecessor failed: (2/3)
2015-07-17 15:20:54,449 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-07-17 15:20:54,449 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-07-17 15:20:54,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-07-17 15:20:54,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-07-17 15:20:54,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-07-17 15:20:57,641 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-07-17 15:20:57,641 WARN  flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@1e9350b9 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:1560)
	at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1323)
	at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1221)
	at cascading.flow.BaseFlow.run(BaseFlow.java:1176)
	at cascading.flow.BaseFlow.access$100(BaseFlow.java:78)
	at cascading.flow.BaseFlow$1.run(BaseFlow.java:834)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:20:57,642 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-07-17 15:20:57,642 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-07-17 15:20:57,642 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-07-17 15:20:57,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-07-17 15:20:57,645 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-07-17 15:20:57,645 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/THROWABLE/stopped
2015-07-17 15:20:57,661 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:20:57,662 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:20:57,688 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(198)) - calling start
2015-07-17 15:20:57,690 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 15:20:57,690 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:20:57,690 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 15:20:57,691 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 15:20:57,691 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/stopped"]
2015-07-17 15:20:57,691 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 15:20:57,691 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-07-17 15:20:57,691 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-07-17 15:20:57,693 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-07-17 15:20:57,693 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-07-17 15:20:57,851 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0006
2015-07-17 15:20:57,851 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0006/
2015-07-17 15:20:57,855 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0007
2015-07-17 15:20:57,855 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0007/
2015-07-17 15:20:58,697 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:20:59,703 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:00,277 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437171525123_0005_01_000024
2015-07-17 15:21:00,706 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:01,709 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:02,720 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:03,726 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:04,735 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:05,747 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:06,749 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:07,758 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:08,766 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:09,778 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:10,785 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:11,796 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:12,804 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:13,808 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:14,815 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:15,825 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:16,830 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:17,835 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:18,846 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:19,853 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:20,864 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:21,873 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:22,880 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:23,889 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-07-17 15:21:23,923 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0006_01_000003 is : 143
2015-07-17 15:21:24,005 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0006_01_000004 is : 143
2015-07-17 15:21:24,083 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0006_01_000005 is : 143
2015-07-17 15:21:24,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0006_01_000006 is : 143
2015-07-17 15:21:24,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0006_01_000007 is : 143
2015-07-17 15:21:24,896 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2015-07-17 15:21:24,896 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2015-07-17 15:21:24,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-07-17 15:21:24,898 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-07-17 15:21:24,899 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-07-17 15:21:25,015 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0007_01_000006 is : 143
2015-07-17 15:21:25,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0007_01_000005 is : 143
2015-07-17 15:21:25,059 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0007_01_000004 is : 143
2015-07-17 15:21:25,095 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0007_01_000003 is : 143
2015-07-17 15:21:25,139 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0007_01_000002 is : 143
2015-07-17 15:21:26,993 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-07-17 15:21:27,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0006_01_000008 is : 143
2015-07-17 15:21:29,011 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-07-17 15:21:29,011 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-07-17 15:21:29,041 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (1/3)
2015-07-17 15:21:29,042 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-07-17 15:21:29,042 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (2/3)
2015-07-17 15:21:29,042 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-07-17 15:21:29,043 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-07-17 15:21:29,044 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/stopped
2015-07-17 15:21:29,064 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:21:29,064 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:21:29,096 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-07-17 15:21:29,098 WARN  flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@2eb33cee 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:1524)
	at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1350)
	at cascading.flow.BaseFlow.run(BaseFlow.java:1125)
	at cascading.flow.BaseFlow.access$100(BaseFlow.java:78)
	at cascading.flow.BaseFlow$1.run(BaseFlow.java:834)
	at java.lang.Thread.run(Thread.java:745)
2015-07-17 15:21:29,099 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-07-17 15:21:29,099 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STARTING/stopped
2015-07-17 15:21:29,100 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-07-17 15:21:29,100 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-07-17 15:21:29,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-07-17 15:21:29,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 15:21:29,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 15:21:29,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 15:21:29,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/STARTING/stopped"]
2015-07-17 15:21:29,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 15:21:29,102 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-07-17 15:21:29,102 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-07-17 15:21:29,102 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/STARTING/stopped
2015-07-17 15:21:29,118 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:21:29,118 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:21:29,133 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopping all jobs
2015-07-17 15:21:29,134 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] stopping: (1/1) ...r1/flowplatform/startstop
2015-07-17 15:21:29,134 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopped all jobs
2015-07-17 15:21:29,135 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/startstop
2015-07-17 15:21:29,161 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:21:29,161 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:21:29,193 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-07-17 15:21:29,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 15:21:29,196 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:29,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 15:21:29,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 15:21:29,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/STOPPING/stopped"]
2015-07-17 15:21:29,196 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 15:21:29,197 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-07-17 15:21:29,197 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-07-17 15:21:29,198 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-07-17 15:21:29,199 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-07-17 15:21:29,337 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0008
2015-07-17 15:21:29,337 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0008/
2015-07-17 15:21:29,563 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437171525123_0009
2015-07-17 15:21:29,563 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0009/
2015-07-17 15:21:30,201 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:31,208 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:32,217 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:33,228 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:34,238 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:35,248 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:36,259 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:37,267 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:38,274 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:39,285 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:40,301 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:41,308 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:42,311 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:43,320 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:44,324 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:45,328 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:46,332 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:47,333 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:48,339 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:49,348 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:50,350 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:51,356 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:52,360 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:53,364 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:54,366 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:55,374 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:56,380 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:57,385 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:58,390 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-07-17 15:21:59,066 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0008_01_000003 is : 143
2015-07-17 15:21:59,160 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0008_01_000004 is : 143
2015-07-17 15:21:59,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0008_01_000002 is : 143
2015-07-17 15:21:59,396 INFO  hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(416)) - calling stop
2015-07-17 15:21:59,396 WARN  flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@70c71644 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:1536)
	at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1338)
	at cascading.flow.BaseFlow.stop(BaseFlow.java:854)
	at cascading.flow.hadoop.FlowPlatformTest.failingListenerTest(FlowPlatformTest.java:418)
	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:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	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:271)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:295)
	at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:61)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
	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:48)
	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-07-17 15:21:59,397 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-07-17 15:21:59,400 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-07-17 15:21:59,401 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-07-17 15:21:59,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0008_01_000006 is : 143
2015-07-17 15:21:59,460 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0009_01_000002 is : 143
2015-07-17 15:21:59,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0009_01_000005 is : 143
2015-07-17 15:21:59,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0009_01_000003 is : 143
2015-07-17 15:21:59,557 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0009_01_000004 is : 143
2015-07-17 15:21:59,604 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0009_01_000006 is : 143
2015-07-17 15:21:59,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0008_01_000005 is : 143
2015-07-17 15:22:01,448 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-07-17 15:22:03,467 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-07-17 15:22:03,467 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-07-17 15:22:03,495 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (1/3)
2015-07-17 15:22:03,495 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-07-17 15:22:03,495 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (2/3)
2015-07-17 15:22:03,496 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-07-17 15:22:03,496 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-07-17 15:22:03,496 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/STOPPING/stopped
2015-07-17 15:22:03,510 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:22:03,511 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:22:03,514 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-07-17 15:22:03,526 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-07-17 15:22:03,539 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:22:03,539 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:22:03,568 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:22:03,569 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:22:03,577 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-07-17 15:22:03,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 15:22:03,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete"]
2015-07-17 15:22:03,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-07-17 15:22:03,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-07-17 15:22:03,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-07-17 15:22:03,579 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...wplatform/withoutcomplete
2015-07-17 15:22:03,695 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1437171525123_0010
2015-07-17 15:22:03,695 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://Marks-MacBook.local:59220/proxy/application_1437171525123_0010/
2015-07-17 15:22:22,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0010_01_000002 is : 143
2015-07-17 15:22:22,683 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0010_01_000003 is : 143
2015-07-17 15:22:22,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0010_01_000004 is : 143
2015-07-17 15:22:22,794 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0010_01_000006 is : 143
2015-07-17 15:22:22,826 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0010_01_000005 is : 143
2015-07-17 15:22:28,141 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171525123_0010_01_000007 is : 143
2015-07-17 15:22:29,314 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete/_temporary
2015-07-17 15:22:29,316 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/withoutcomplete
2015-07-17 15:22:29,336 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:22:29,336 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:22:29,340 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-07-17 15:22:29,352 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:22:29,353 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:22:29,356 INFO  hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-07-17 15:22:29,372 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:22:29,372 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:22:29,383 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/flowplatform/badserialization

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
Jul 17, 2015 3:18:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jul 17, 2015 3:18:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 3:18:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 3:18:45 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 3:18:45 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"
Jul 17, 2015 3:18:45 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 3:18:46 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"
Jul 17, 2015 3:18:46 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.
Jul 17, 2015 3:18:46 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 3:18:46 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jul 17, 2015 3:18:46 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 3:18:46 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 3:18:46 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"
Jul 17, 2015 3:18:46 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 3:18:47 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"
Jul 17, 2015 3:18:47 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.
Jul 17, 2015 3:18:47 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 17, 2015 3:18:47 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 3:18:47 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 3:18:47 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 3:18:47 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"
Jul 17, 2015 3:18:47 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 3:18:47 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"
Jul 17, 2015 3:18:47 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.
Jul 17, 2015 3:18:48 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 17, 2015 3:18:48 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 3:18:48 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 3:18:48 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 3:18:48 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"
Jul 17, 2015 3:18:48 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 3:18:48 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"
Jul 17, 2015 3:18:48 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.
Jul 17, 2015 3:18:49 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 17, 2015 3:18:49 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 17, 2015 3:18:49 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 17, 2015 3:18:49 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 17, 2015 3:18:49 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"
Jul 17, 2015 3:18:49 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 17, 2015 3:18:49 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"
Jul 17, 2015 3:18:49 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.