2015-05-20 18:05:11,704 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 18:05:11,736 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 18:05:11,736 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tap.hadoop.HadoopTapPlatformTest
2015-05-20 18:05:11,758 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 18:05:12,471 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 18:05:13,006 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 18:05:16,410 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 18:05:16,614 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 18:05:16,789 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 18:05:16,957 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 18:05:34,157 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:05:34,158 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 18:05:34,168 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: E24BAE36B4764D75931366ED0F2F5ADE
2015-05-20 18:05:34,362 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 18:05:34,364 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:05:34,364 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["CommentScheme[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/comments+lower.txt"]
2015-05-20 18:05:34,365 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/testnulls"]
2015-05-20 18:05:34,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:05:34,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:05:34,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:05:34,367 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...dooptapplatform/testnulls
2015-05-20 18:05:35,725 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432170328539_0001
2015-05-20 18:05:35,725 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0001/
2015-05-20 18:05:49,003 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0001_01_000002 is : 143
2015-05-20 18:05:50,368 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/testnulls/_temporary
2015-05-20 18:05:50,474 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/testnulls
2015-05-20 18:05:50,548 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:05:50,548 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 18:05:50,566 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/missinginputformat
2015-05-20 18:05:50,877 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 18:05:50,942 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:05:51,012 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:05:51,045 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 18:05:51,088 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:05:51,089 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 18:05:51,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:05:51,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:05:51,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["ResolvedScheme[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/resolvedfields"]
2015-05-20 18:05:51,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:05:51,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:05:51,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:05:51,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...applatform/resolvedfields
2015-05-20 18:05:51,306 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432170328539_0002
2015-05-20 18:05:51,306 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0002/
2015-05-20 18:06:09,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0002_01_000005 is : 143
2015-05-20 18:06:09,594 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0002_01_000006 is : 143
2015-05-20 18:06:09,819 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0002_01_000002 is : 143
2015-05-20 18:06:09,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0002_01_000004 is : 143
2015-05-20 18:06:10,007 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0002_01_000003 is : 143
2015-05-20 18:06:11,227 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/resolvedfields/_temporary
2015-05-20 18:06:11,275 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/resolvedfields
2015-05-20 18:06:11,337 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:06:11,338 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 18:06:11,342 INFO hadoop.Hfs (Hfs.java:makeLocal(507)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:06:11,363 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:06:11,363 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 18:06:11,400 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting
2015-05-20 18:06:11,403 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] parallel execution is enabled: true
2015-05-20 18:06:11,403 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting flows: 2
2015-05-20 18:06:11,403 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] allocating threads: 2
2015-05-20 18:06:11,403 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting flow: first
2015-05-20 18:06:11,404 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 18:06:11,404 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 18:06:11,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 18:06:11,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: GlobHfs[/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/?{ppe[_r],owe?}.txt]
2015-05-20 18:06:11,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob"]
2015-05-20 18:06:11,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 18:06:11,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 18:06:11,409 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 18:06:11,409 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...r1/hadooptapplatform/glob
2015-05-20 18:06:11,669 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_local34669026_0001
2015-05-20 18:06:11,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://localhost:8080/
2015-05-20 18:06:11,702 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt
2015-05-20 18:06:11,713 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 18:06:11,713 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx512m
2015-05-20 18:06:11,741 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: GlobHfs[/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/?{ppe[_r],owe?}.txt]
2015-05-20 18:06:11,741 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob"]
2015-05-20 18:06:11,775 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt
2015-05-20 18:06:11,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 18:06:11,780 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx512m
2015-05-20 18:06:11,784 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: GlobHfs[/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/?{ppe[_r],owe?}.txt]
2015-05-20 18:06:11,785 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob"]
2015-05-20 18:06:11,861 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob/_temporary
2015-05-20 18:06:11,862 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] completed flow: first
2015-05-20 18:06:11,862 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting flow: second
2015-05-20 18:06:11,863 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 18:06:11,863 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 18:06:11,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 18:06:11,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob"]
2015-05-20 18:06:11,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob2"]
2015-05-20 18:06:11,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 18:06:11,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 18:06:11,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 18:06:11,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...1/hadooptapplatform/glob2
2015-05-20 18:06:12,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432170328539_0003
2015-05-20 18:06:12,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0003/
2015-05-20 18:06:26,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0003_01_000002 is : 143
2015-05-20 18:06:26,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0003_01_000003 is : 143
2015-05-20 18:06:26,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0003_01_000005 is : 143
2015-05-20 18:06:26,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0003_01_000004 is : 143
2015-05-20 18:06:27,788 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/glob2/_temporary
2015-05-20 18:06:27,789 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] completed flow: second
2015-05-20 18:06:27,808 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/glob2
2015-05-20 18:06:27,823 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/glob
2015-05-20 18:06:27,847 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:06:27,848 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 18:06:27,893 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:06:27,893 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: ["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 18:06:27,893 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/preparetap"]
2015-05-20 18:06:27,893 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:06:27,893 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:06:27,894 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:06:27,894 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ooptapplatform/preparetap
2015-05-20 18:06:28,026 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432170328539_0004
2015-05-20 18:06:28,026 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0004/
2015-05-20 18:06:42,008 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0004_01_000003 is : 143
2015-05-20 18:06:42,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0004_01_000002 is : 143
2015-05-20 18:06:42,161 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0004_01_000004 is : 143
2015-05-20 18:06:42,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0004_01_000005 is : 143
2015-05-20 18:06:48,121 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0004_01_000006 is : 143
2015-05-20 18:06:49,306 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/preparetap/_temporary
2015-05-20 18:06:49,324 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/preparetap
2015-05-20 18:06:49,345 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:06:49,345 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 18:06:49,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 18:06:49,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["DupeConfigScheme[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 18:06:49,367 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 18:06:49,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/dupeconfig"]
2015-05-20 18:06:49,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 18:06:49,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-05-20 18:06:49,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-05-20 18:06:49,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ooptapplatform/dupeconfig
2015-05-20 18:06:49,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432170328539_0005
2015-05-20 18:06:49,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0005/
2015-05-20 18:07:06,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0005_01_000002 is : 143
2015-05-20 18:07:06,223 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0005_01_000003 is : 143
2015-05-20 18:07:06,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0005_01_000004 is : 143
2015-05-20 18:07:06,498 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0005_01_000006 is : 143
2015-05-20 18:07:06,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0005_01_000005 is : 143
2015-05-20 18:07:07,912 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/dupeconfig/_temporary
2015-05-20 18:07:07,962 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/dupeconfig
2015-05-20 18:07:07,993 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:07:07,994 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 18:07:08,021 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:07:08,022 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 18:07:08,065 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting
2015-05-20 18:07:08,067 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] parallel execution is enabled: true
2015-05-20 18:07:08,067 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting flows: 2
2015-05-20 18:07:08,067 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] allocating threads: 2
2015-05-20 18:07:08,068 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting flow: first
2015-05-20 18:07:08,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 18:07:08,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 18:07:08,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 18:07:08,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: MultiSourceTap[2:[GlobHfs[/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/?{ppe[_r]}.txt], GlobHfs[/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/?{owe?}.txt]]]
2015-05-20 18:07:08,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/globmultisource"]
2015-05-20 18:07:08,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 18:07:08,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 18:07:08,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 18:07:08,075 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...pplatform/globmultisource
2015-05-20 18:07:08,195 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432170328539_0006
2015-05-20 18:07:08,195 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0006/
2015-05-20 18:07:25,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0006_01_000006 is : 143
2015-05-20 18:07:25,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0006_01_000007 is : 143
2015-05-20 18:07:26,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0006_01_000002 is : 143
2015-05-20 18:07:26,192 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0006_01_000005 is : 143
2015-05-20 18:07:26,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0006_01_000004 is : 143
2015-05-20 18:07:26,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0006_01_000003 is : 143
2015-05-20 18:07:27,693 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/globmultisource/_temporary
2015-05-20 18:07:27,695 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] completed flow: first
2015-05-20 18:07:27,695 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] starting flow: second
2015-05-20 18:07:27,695 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 18:07:27,695 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 18:07:27,699 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 18:07:27,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/globmultisource"]
2015-05-20 18:07:27,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/globmultiource2"]
2015-05-20 18:07:27,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 18:07:27,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 18:07:27,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 18:07:27,701 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...pplatform/globmultiource2
2015-05-20 18:07:27,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432170328539_0007
2015-05-20 18:07:27,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0007/
2015-05-20 18:07:49,343 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000007 is : 143
2015-05-20 18:07:49,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000002 is : 143
2015-05-20 18:07:49,733 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000006 is : 143
2015-05-20 18:07:49,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000003 is : 143
2015-05-20 18:07:50,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000009 is : 143
2015-05-20 18:07:50,091 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000004 is : 143
2015-05-20 18:07:50,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000008 is : 143
2015-05-20 18:07:50,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0007_01_000005 is : 143
2015-05-20 18:07:51,509 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/globmultiource2/_temporary
2015-05-20 18:07:51,510 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second] completed flow: second
2015-05-20 18:07:51,534 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/globmultiource2
2015-05-20 18:07:51,553 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/globmultisource
2015-05-20 18:07:51,622 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:07:51,623 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 18:07:51,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:07:51,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 18:07:51,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/preparewritetapfail"]
2015-05-20 18:07:51,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:07:51,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:07:51,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:07:51,637 ERROR flow.FlowStep (BaseFlowStep.java:logError(910)) - [test] unable to prepare tap for write: hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/preparewritetapfail
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$7.prepareResourceForWrite(HadoopTapPlatformTest.java:849)
at cascading.tap.hadoop.HadoopTapPlatformTest$7.prepareResourceForWrite(HadoopTapPlatformTest.java:845)
at cascading.flow.planner.BaseFlowStep.prepareResource(BaseFlowStep.java:456)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:438)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:424)
at cascading.flow.planner.FlowStepJob.prepareResources(FlowStepJob.java:188)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:158)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:124)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:43)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
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 18:07:51,639 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-05-20 18:07:51,641 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tform/preparewritetapfail
2015-05-20 18:07:51,641 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-05-20 18:07:51,642 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/preparewritetapfail
2015-05-20 18:07:51,657 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:07:51,657 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 18:07:51,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:07:51,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: ["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 18:07:51,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[['ip', 'count']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/preparereadtapfail"]
2015-05-20 18:07:51,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:07:51,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:07:51,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:07:51,673 ERROR flow.FlowStep (BaseFlowStep.java:logError(910)) - [test] unable to prepare tap for read: hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$6.prepareResourceForRead(HadoopTapPlatformTest.java:801)
at cascading.tap.hadoop.HadoopTapPlatformTest$6.prepareResourceForRead(HadoopTapPlatformTest.java:797)
at cascading.flow.planner.BaseFlowStep.prepareResource(BaseFlowStep.java:458)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:438)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:421)
at cascading.flow.planner.FlowStepJob.prepareResources(FlowStepJob.java:188)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:158)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:124)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:43)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
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 18:07:51,673 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-05-20 18:07:51,674 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...atform/preparereadtapfail
2015-05-20 18:07:51,674 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-05-20 18:07:51,675 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/preparereadtapfail
2015-05-20 18:07:51,689 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:07:51,690 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 18:07:51,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:07:51,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 18:07:51,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/committapfail"]
2015-05-20 18:07:51,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:07:51,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:07:51,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:07:51,705 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tapplatform/committapfail
2015-05-20 18:07:51,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432170328539_0008
2015-05-20 18:07:51,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0008/
2015-05-20 18:08:06,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0008_01_000002 is : 143
2015-05-20 18:08:06,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0008_01_000004 is : 143
2015-05-20 18:08:06,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0008_01_000005 is : 143
2015-05-20 18:08:06,327 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0008_01_000003 is : 143
2015-05-20 18:08:12,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0008_01_000006 is : 143
2015-05-20 18:08:13,525 ERROR flow.FlowStep (BaseFlowStep.java:logError(910)) - [test] unable to commit sink: hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/committapfail
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$2.commitResource(HadoopTapPlatformTest.java:406)
at cascading.tap.hadoop.HadoopTapPlatformTest$2.commitResource(HadoopTapPlatformTest.java:402)
at cascading.flow.planner.BaseFlowStep.commitResource(BaseFlowStep.java:502)
at cascading.flow.planner.BaseFlowStep.commitSinks(BaseFlowStep.java:490)
at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:267)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:162)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:124)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:43)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
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 18:08:13,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-05-20 18:08:13,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...tapplatform/committapfail
2015-05-20 18:08:13,555 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-05-20 18:08:13,557 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/committapfail/_temporary
2015-05-20 18:08:13,562 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/committapfail
2015-05-20 18:08:13,585 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:08:13,586 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 18:08:13,598 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 18:08:13,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 18:08:13,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/committap"]
2015-05-20 18:08:13,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 18:08:13,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 18:08:13,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 18:08:13,601 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...dooptapplatform/committap
2015-05-20 18:08:13,733 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432170328539_0009
2015-05-20 18:08:13,733 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0009/
2015-05-20 18:08:28,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0009_01_000002 is : 143
2015-05-20 18:08:28,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0009_01_000003 is : 143
2015-05-20 18:08:28,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0009_01_000005 is : 143
2015-05-20 18:08:28,380 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0009_01_000004 is : 143
2015-05-20 18:08:34,007 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0009_01_000006 is : 143
2015-05-20 18:08:35,182 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/committap/_temporary
2015-05-20 18:08:35,198 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/committap
2015-05-20 18:08:35,226 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,226 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 18:08:35,229 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/A/part-00000
2015-05-20 18:08:35,244 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,249 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/A
2015-05-20 18:08:35,250 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/A/_temporary
2015-05-20 18:08:35,254 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,255 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 18:08:35,258 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/B/part-00000
2015-05-20 18:08:35,273 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,281 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/B
2015-05-20 18:08:35,283 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/multifiles/B/_temporary
2015-05-20 18:08:35,323 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,323 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 18:08:35,326 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/A/part-00000
2015-05-20 18:08:35,341 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,346 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/A
2015-05-20 18:08:35,347 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/A/_temporary
2015-05-20 18:08:35,351 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,352 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 18:08:35,354 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/B/part-00000
2015-05-20 18:08:35,369 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,377 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/B
2015-05-20 18:08:35,378 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/B/_temporary
2015-05-20 18:08:35,384 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/.hidden/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,384 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 18:08:35,386 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/.hidden/part-00000
2015-05-20 18:08:35,397 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/.hidden/_temporary/_attempt_002147483647_0000_m_000000_0
2015-05-20 18:08:35,402 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/.hidden
2015-05-20 18:08:35,403 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path hdfs://localhost:56343/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/hiddenfiles/.hidden/_temporary
2015-05-20 18:08:35,424 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/hiddenfiles/B
2015-05-20 18:08:35,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/hiddenfiles/A
2015-05-20 18:08:35,437 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/hiddenfiles
2015-05-20 18:08:35,445 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/multifiles
2015-05-20 18:08:35,453 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/hiddenfiles/.hidden
2015-05-20 18:08:35,460 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/multifiles/B
2015-05-20 18:08:35,466 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/multifiles/A
2015-05-20 18:08:35,495 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:08:35,496 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 18:08:35,516 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [partition] starting
2015-05-20 18:08:35,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:08:35,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@4e9471ab"]
2015-05-20 18:08:35,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [partition] parallel execution is enabled: true
2015-05-20 18:08:35,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [partition] starting jobs: 1
2015-05-20 18:08:35,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [partition] allocating threads: 1
2015-05-20 18:08:35,518 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [partition] starting step: (1/1) ...inedpartition/partitioned
2015-05-20 18:08:35,638 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [partition] submitted hadoop job: job_1432170328539_0010
2015-05-20 18:08:35,638 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [partition] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0010/
2015-05-20 18:08:51,831 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0010_01_000003 is : 143
2015-05-20 18:08:51,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0010_01_000006 is : 143
2015-05-20 18:08:51,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0010_01_000002 is : 143
2015-05-20 18:08:52,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0010_01_000004 is : 143
2015-05-20 18:08:52,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0010_01_000005 is : 143
2015-05-20 18:08:53,429 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/combinedpartition/partitioned/_temporary
2015-05-20 18:08:53,441 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:08:53,441 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 18:08:53,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [copy] starting
2015-05-20 18:08:53,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@4e9471ab"]
2015-05-20 18:08:53,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/combinedpartition/final"]
2015-05-20 18:08:53,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [copy] parallel execution is enabled: true
2015-05-20 18:08:53,454 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [copy] starting jobs: 1
2015-05-20 18:08:53,454 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [copy] allocating threads: 1
2015-05-20 18:08:53,455 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [copy] starting step: (1/1) ...m/combinedpartition/final
2015-05-20 18:08:53,586 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [copy] submitted hadoop job: job_1432170328539_0011
2015-05-20 18:08:53,586 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [copy] tracking url: http://Edinburgh.local:56453/proxy/application_1432170328539_0011/
2015-05-20 18:09:02,854 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170328539_0011_01_000002 is : 143
2015-05-20 18:09:04,032 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/hadooptapplatform/combinedpartition/final/_temporary
2015-05-20 18:09:04,049 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/combinedpartition/partitioned
2015-05-20 18:09:04,070 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/hadooptapplatform/combinedpartition/final