2015-05-20 17:42:50,687 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 17:42:50,726 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 17:42:50,726 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.flow.hadoop.FlowPlatformTest
2015-05-20 17:42:50,743 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 17:42:51,467 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-05-20 17:42:51,988 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 17:42:55,307 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-05-20 17:42:55,522 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-05-20 17:42:55,713 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-05-20 17:42:55,897 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-05-20 17:43:13,022 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 76A81C0A9B3A4B47B0E2F19A064CA5BE
2015-05-20 17:43:13,042 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:43:13,043 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:43:13,087 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-05-20 17:43:13,139 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:43:13,139 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:43:13,146 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-05-20 17:43:13,163 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-05-20 17:43:13,254 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:43:13,254 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:43:13,316 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-05-20 17:43:13,332 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 17:43:13,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 17:43:13,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 17:43:13,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 17:43:13,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped"]
2015-05-20 17:43:13,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 17:43:13,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-05-20 17:43:13,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-05-20 17:43:13,336 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-05-20 17:43:13,336 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-05-20 17:43:14,203 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0002
2015-05-20 17:43:14,203 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0001
2015-05-20 17:43:14,203 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0001/
2015-05-20 17:43:14,203 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0002/
2015-05-20 17:43:43,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0002_01_000004 is : 143
2015-05-20 17:43:43,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0001_01_000005 is : 143
2015-05-20 17:43:44,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0001_01_000003 is : 143
2015-05-20 17:43:44,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0002_01_000002 is : 143
2015-05-20 17:43:44,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0001_01_000002 is : 143
2015-05-20 17:43:44,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0001_01_000006 is : 143
2015-05-20 17:43:44,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0002_01_000006 is : 143
2015-05-20 17:43:44,650 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0001_01_000004 is : 143
2015-05-20 17:43:44,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0002_01_000005 is : 143
2015-05-20 17:43:44,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0002_01_000003 is : 143
2015-05-20 17:43:51,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0001_01_000007 is : 143
2015-05-20 17:43:51,528 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0002_01_000007 is : 143
2015-05-20 17:43:52,714 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...latform/COMPLETED/stopped
2015-05-20 17:43:52,913 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0003
2015-05-20 17:43:52,914 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0003/
2015-05-20 17:44:07,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0003_01_000002 is : 143
2015-05-20 17:44:08,094 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0003_01_000003 is : 143
2015-05-20 17:44:13,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0003_01_000004 is : 143
2015-05-20 17:44:14,644 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/COMPLETED/stopped/_temporary
2015-05-20 17:44:14,645 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@74a8a0bd 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-05-20 17:44:14,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-05-20 17:44:14,649 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/COMPLETED/stopped
2015-05-20 17:44:14,651 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-05-20 17:44:18,080 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-05-20 17:44:21,280 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-05-20 17:44:21,281 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/COMPLETED/stopped
2015-05-20 17:44:21,315 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:44:21,315 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:44:21,355 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-05-20 17:44:21,357 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 17:44:21,357 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 17:44:21,357 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 17:44:21,358 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/THROWABLE/stopped"]
2015-05-20 17:44:21,358 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 17:44:21,358 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-05-20 17:44:21,358 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-05-20 17:44:21,359 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-05-20 17:44:21,359 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-05-20 17:44:21,530 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0004
2015-05-20 17:44:21,530 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0004/
2015-05-20 17:44:21,546 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0005
2015-05-20 17:44:21,546 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0005/
2015-05-20 17:44:51,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000005 is : 143
2015-05-20 17:44:51,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000002 is : 143
2015-05-20 17:44:52,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000003 is : 143
2015-05-20 17:44:52,095 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0005_01_000006 is : 143
2015-05-20 17:44:52,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0005_01_000003 is : 143
2015-05-20 17:44:52,245 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0005_01_000004 is : 143
2015-05-20 17:44:52,299 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000006 is : 143
2015-05-20 17:44:52,365 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0005_01_000002 is : 143
2015-05-20 17:44:52,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000004 is : 143
2015-05-20 17:44:52,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0005_01_000005 is : 143
2015-05-20 17:44:55,395 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000012
2015-05-20 17:44:55,395 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000011
2015-05-20 17:44:56,353 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000013
2015-05-20 17:44:56,395 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000014
2015-05-20 17:45:03,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000007 is : 143
2015-05-20 17:45:03,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000008 is : 143
2015-05-20 17:45:05,145 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000009 is : 143
2015-05-20 17:45:05,244 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000010 is : 143
2015-05-20 17:45:06,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0005_01_000007 is : 143
2015-05-20 17:45:08,135 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000020
2015-05-20 17:45:08,515 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000021
2015-05-20 17:45:09,439 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000022
2015-05-20 17:45:12,380 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000016 is : 143
2015-05-20 17:45:13,318 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000017 is : 143
2015-05-20 17:45:13,408 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000018 is : 143
2015-05-20 17:45:13,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000019 is : 143
2015-05-20 17:45:16,753 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000027
2015-05-20 17:45:17,469 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000028
2015-05-20 17:45:17,545 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000029
2015-05-20 17:45:17,755 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0004_01_000030
2015-05-20 17:45:20,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000023 is : 143
2015-05-20 17:45:20,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000026 is : 143
2015-05-20 17:45:20,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000025 is : 143
2015-05-20 17:45:20,239 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000015 is : 143
2015-05-20 17:45:20,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0004_01_000024 is : 143
2015-05-20 17:45:21,406 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] hadoop job job_1432168987484_0004 state at FAILED
2015-05-20 17:45:21,407 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] failure info: Task failed task_1432168987484_0004_m_000003
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-05-20 17:45:21,433 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events identify failed tasks
2015-05-20 17:45:21,433 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events count: 10
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000003_0, Status : FAILED
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000000_0, Status : FAILED
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000001_0, Status : FAILED
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000004_0, Status : SUCCEEDED
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000002_0, Status : FAILED
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000003_1, Status : FAILED
2015-05-20 17:45:21,434 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000000_1, Status : FAILED
2015-05-20 17:45:21,435 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000001_1, Status : FAILED
2015-05-20 17:45:21,435 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000002_1, Status : FAILED
2015-05-20 17:45:21,435 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] event = Task Id : attempt_1432168987484_0004_m_000003_2, Status : FAILED
2015-05-20 17:45:21,474 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-05-20 17:45:21,474 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...latform/THROWABLE/stopped, predecessor failed: (2/3)
2015-05-20 17:45:21,475 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-05-20 17:45:21,476 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-05-20 17:45:21,476 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-05-20 17:45:21,478 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-05-20 17:45:24,651 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-05-20 17:45:24,651 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@325e4043 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-05-20 17:45:24,652 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-05-20 17:45:24,652 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...latform/THROWABLE/stopped
2015-05-20 17:45:24,652 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-05-20 17:45:24,653 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-05-20 17:45:24,656 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-05-20 17:45:24,656 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/THROWABLE/stopped
2015-05-20 17:45:24,674 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:45:24,675 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:45:24,703 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(198)) - calling start
2015-05-20 17:45:24,705 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 17:45:24,705 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:24,705 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 17:45:24,706 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 17:45:24,706 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/stopped"]
2015-05-20 17:45:24,706 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 17:45:24,706 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-05-20 17:45:24,706 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-05-20 17:45:24,708 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-05-20 17:45:24,708 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-05-20 17:45:24,895 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0006
2015-05-20 17:45:24,895 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0006/
2015-05-20 17:45:24,908 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0007
2015-05-20 17:45:24,908 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0007/
2015-05-20 17:45:25,711 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:26,716 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:27,719 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:28,723 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:29,728 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:30,731 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:31,736 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:32,740 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:33,746 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:34,748 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:35,752 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:36,754 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:37,757 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:38,762 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:39,765 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:40,767 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:41,770 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:42,775 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:43,777 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:44,779 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:45,785 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:46,788 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:47,791 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:48,796 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:49,798 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:50,801 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:51,807 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:52,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0006_01_000006 is : 143
2015-05-20 17:45:52,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0006_01_000003 is : 143
2015-05-20 17:45:52,639 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0006_01_000002 is : 143
2015-05-20 17:45:52,814 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(205)) - testing if running
2015-05-20 17:45:52,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0006_01_000005 is : 143
2015-05-20 17:45:52,991 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0006_01_000004 is : 143
2015-05-20 17:45:53,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0007_01_000002 is : 143
2015-05-20 17:45:53,821 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2015-05-20 17:45:53,821 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2015-05-20 17:45:53,822 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-05-20 17:45:53,823 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-05-20 17:45:53,823 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-05-20 17:45:53,863 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0007_01_000003 is : 143
2015-05-20 17:45:54,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0007_01_000004 is : 143
2015-05-20 17:45:54,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0007_01_000006 is : 143
2015-05-20 17:45:54,194 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0007_01_000005 is : 143
2015-05-20 17:45:55,865 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-05-20 17:45:57,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-05-20 17:45:57,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-05-20 17:45:57,914 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (1/3)
2015-05-20 17:45:57,915 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-05-20 17:45:57,915 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...-mr1/flowplatform/stopped, predecessor failed: (2/3)
2015-05-20 17:45:57,915 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...-mr1/flowplatform/stopped
2015-05-20 17:45:57,916 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-05-20 17:45:57,916 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/stopped
2015-05-20 17:45:57,933 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:45:57,934 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:45:57,960 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-05-20 17:45:57,962 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@1e6faf02 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-05-20 17:45:57,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-05-20 17:45:57,963 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STARTING/stopped
2015-05-20 17:45:57,964 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-05-20 17:45:57,964 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-05-20 17:45:57,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-05-20 17:45:57,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 17:45:57,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 17:45:57,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 17:45:57,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/STARTING/stopped"]
2015-05-20 17:45:57,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 17:45:57,966 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-05-20 17:45:57,966 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-05-20 17:45:57,966 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/STARTING/stopped
2015-05-20 17:45:57,980 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:45:57,981 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:45:57,991 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopping all jobs
2015-05-20 17:45:57,992 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] stopping: (1/1) ...r1/flowplatform/startstop
2015-05-20 17:45:57,992 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] stopped all jobs
2015-05-20 17:45:57,992 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/startstop
2015-05-20 17:45:58,010 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:45:58,011 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:45:58,038 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2015-05-20 17:45:58,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 17:45:58,040 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:45:58,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 17:45:58,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 17:45:58,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/STOPPING/stopped"]
2015-05-20 17:45:58,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 17:45:58,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-05-20 17:45:58,041 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-05-20 17:45:58,042 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-05-20 17:45:58,043 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-05-20 17:45:58,195 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0008
2015-05-20 17:45:58,195 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0008/
2015-05-20 17:45:58,409 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432168987484_0009
2015-05-20 17:45:58,409 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0009/
2015-05-20 17:45:59,045 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:00,047 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:01,051 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:02,053 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:03,054 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:04,060 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:05,063 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:06,073 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:07,078 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:08,080 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:09,082 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:10,087 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:11,088 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:12,090 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:13,095 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:14,101 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:15,103 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:16,108 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:17,113 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:18,117 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:19,117 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:20,118 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:21,123 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:22,126 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:23,129 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:24,135 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2015-05-20 17:46:24,924 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0008_01_000002 is : 143
2015-05-20 17:46:25,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0008_01_000003 is : 143
2015-05-20 17:46:25,136 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(416)) - calling stop
2015-05-20 17:46:25,136 WARN flow.Flow (BaseFlow.java:logWarn(1380)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@3801ffe4 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: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-05-20 17:46:25,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-05-20 17:46:25,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-05-20 17:46:25,139 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (2/3)
2015-05-20 17:46:25,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0009_01_000004 is : 143
2015-05-20 17:46:25,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0009_01_000006 is : 143
2015-05-20 17:46:25,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0009_01_000002 is : 143
2015-05-20 17:46:25,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0009_01_000005 is : 143
2015-05-20 17:46:25,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0009_01_000003 is : 143
2015-05-20 17:46:26,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0008_01_000005 is : 143
2015-05-20 17:46:26,424 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0008_01_000006 is : 143
2015-05-20 17:46:26,546 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0008_01_000004 is : 143
2015-05-20 17:46:27,162 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/3)
2015-05-20 17:46:29,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-05-20 17:46:29,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutting down job executor
2015-05-20 17:46:29,207 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (1/3)
2015-05-20 17:46:29,207 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-05-20 17:46:29,207 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] abandoning step: (3/3) ...platform/STOPPING/stopped, predecessor failed: (2/3)
2015-05-20 17:46:29,207 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (3/3) ...platform/STOPPING/stopped
2015-05-20 17:46:29,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] shutdown complete
2015-05-20 17:46:29,208 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/STOPPING/stopped
2015-05-20 17:46:29,221 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:46:29,221 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:46:29,225 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-05-20 17:46:29,236 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via sink: Lfs["TextLine[['offset', 'line']->[ALL]]"]["output/path"]
2015-05-20 17:46:29,258 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:46:29,258 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:46:29,286 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:46:29,287 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:46:29,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-05-20 17:46:29,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 17:46:29,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete"]
2015-05-20 17:46:29,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-05-20 17:46:29,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-05-20 17:46:29,296 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-05-20 17:46:29,297 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...wplatform/withoutcomplete
2015-05-20 17:46:29,402 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1432168987484_0010
2015-05-20 17:46:29,402 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://Edinburgh.local:49941/proxy/application_1432168987484_0010/
2015-05-20 17:46:34,538 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1432168987484_0008_01_000007
2015-05-20 17:46:47,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0010_01_000002 is : 143
2015-05-20 17:46:47,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0010_01_000003 is : 143
2015-05-20 17:46:47,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0010_01_000004 is : 143
2015-05-20 17:46:48,039 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0010_01_000005 is : 143
2015-05-20 17:46:48,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0010_01_000006 is : 143
2015-05-20 17:46:52,905 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168987484_0010_01_000007 is : 143
2015-05-20 17:46:54,066 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/flowplatform/withoutcomplete/_temporary
2015-05-20 17:46:54,068 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/withoutcomplete
2015-05-20 17:46:54,087 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:46:54,087 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:46:54,091 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-05-20 17:46:54,105 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:46:54,106 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:46:54,111 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["input/path"]
2015-05-20 17:46:54,129 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:46:54,130 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:46:54,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/flowplatform/badserialization