2015-05-20 14:32:15,088 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 14:32:15,118 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 14:32:15,118 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.FieldedPipesPlatformTest
2015-05-20 14:32:15,138 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 14:32:15,729 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 14:32:16,258 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 14:32:19,994 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 14:32:20,352 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 14:32:20,676 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 14:32:20,891 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 14:32:21,162 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 14:32:38,359 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:32:38,360 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 14:32:38,366 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 53C741F38F654AF7B3CF28CA09662F83
2015-05-20 14:32:38,488 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 14:32:38,489 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:32:38,490 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:32:38,490 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex"]
2015-05-20 14:32:38,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:32:38,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:32:38,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:32:38,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/filtercomplex
2015-05-20 14:32:39,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0001
2015-05-20 14:32:39,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0001/
2015-05-20 14:32:54,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000003 is : 143
2015-05-20 14:32:55,095 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000004 is : 143
2015-05-20 14:32:55,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000005 is : 143
2015-05-20 14:32:55,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000002 is : 143
2015-05-20 14:33:00,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0001_01_000006 is : 143
2015-05-20 14:33:02,133 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex/_temporary
2015-05-20 14:33:02,166 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/filtercomplex
2015-05-20 14:33:02,200 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:33:02,201 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 14:33:02,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:33:02,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:33:02,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain"]
2015-05-20 14:33:02,239 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:33:02,239 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:33:02,239 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:33:02,240 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/simplechain
2015-05-20 14:33:02,415 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0002
2015-05-20 14:33:02,415 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0002/
2015-05-20 14:33:17,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000002 is : 143
2015-05-20 14:33:17,724 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000003 is : 143
2015-05-20 14:33:17,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000005 is : 143
2015-05-20 14:33:17,993 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000004 is : 143
2015-05-20 14:33:22,797 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0002_01_000006 is : 143
2015-05-20 14:33:24,004 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain/_temporary
2015-05-20 14:33:24,026 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplechain
2015-05-20 14:33:24,048 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:33:24,048 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 14:33:24,067 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:33:24,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:33:24,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple"]
2015-05-20 14:33:24,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:33:24,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:33:24,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:33:24,069 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/simple
2015-05-20 14:33:24,221 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0003
2015-05-20 14:33:24,221 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0003/
2015-05-20 14:33:38,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000003 is : 143
2015-05-20 14:33:38,793 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000005 is : 143
2015-05-20 14:33:38,841 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000002 is : 143
2015-05-20 14:33:39,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000004 is : 143
2015-05-20 14:33:44,142 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0003_01_000006 is : 143
2015-05-20 14:33:45,330 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple/_temporary
2015-05-20 14:33:45,363 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simple
2015-05-20 14:33:45,416 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:33:45,417 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 14:33:45,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 14:33:45,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 14:33:45,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:33:45,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge"]
2015-05-20 14:33:45,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-05-20 14:33:45,440 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-05-20 14:33:45,440 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-05-20 14:33:45,441 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-05-20 14:33:45,576 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432157552760_0004
2015-05-20 14:33:45,576 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0004/
2015-05-20 14:33:54,871 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0004_01_000008
2015-05-20 14:34:05,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000002 is : 143
2015-05-20 14:34:05,864 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000006 is : 143
2015-05-20 14:34:05,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000007 is : 143
2015-05-20 14:34:06,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000004 is : 143
2015-05-20 14:34:06,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000005 is : 143
2015-05-20 14:34:06,232 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000003 is : 143
2015-05-20 14:34:11,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0004_01_000009 is : 143
2015-05-20 14:34:12,457 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge/_temporary
2015-05-20 14:34:12,498 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemerge
2015-05-20 14:34:12,592 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:34:12,592 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 14:34:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:34:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:34:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach"]
2015-05-20 14:34:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:34:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:34:12,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:34:12,612 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/chaineach
2015-05-20 14:34:12,868 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0005
2015-05-20 14:34:12,868 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0005/
2015-05-20 14:34:33,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000002 is : 143
2015-05-20 14:34:34,012 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000003 is : 143
2015-05-20 14:34:34,086 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000004 is : 143
2015-05-20 14:34:34,087 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000005 is : 143
2015-05-20 14:34:39,646 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0005_01_000006 is : 143
2015-05-20 14:34:40,913 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach/_temporary
2015-05-20 14:34:40,934 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chaineach
2015-05-20 14:34:40,960 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:34:40,960 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 14:34:40,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:34:40,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:34:40,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator"]
2015-05-20 14:34:40,976 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:34:40,977 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:34:40,977 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:34:40,978 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/generatoraggregator
2015-05-20 14:34:41,102 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0006
2015-05-20 14:34:41,102 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0006/
2015-05-20 14:34:58,360 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000005 is : 143
2015-05-20 14:34:58,601 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000003 is : 143
2015-05-20 14:34:58,633 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000004 is : 143
2015-05-20 14:34:58,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000002 is : 143
2015-05-20 14:35:04,183 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0006_01_000006 is : 143
2015-05-20 14:35:05,431 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator/_temporary
2015-05-20 14:35:05,450 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/generatoraggregator
2015-05-20 14:35:05,486 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:35:05,487 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 14:35:05,513 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-05-20 14:35:05,513 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 14:35:05,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:35:05,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-05-20 14:35:05,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree"]
2015-05-20 14:35:05,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-05-20 14:35:05,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-05-20 14:35:05,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-05-20 14:35:05,515 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-05-20 14:35:05,658 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1432157552760_0007
2015-05-20 14:35:05,658 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0007/
2015-05-20 14:35:15,663 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0007_01_000011
2015-05-20 14:35:16,209 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0007_01_000013
2015-05-20 14:35:16,650 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0007_01_000014
2015-05-20 14:35:33,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000004 is : 143
2015-05-20 14:35:34,226 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000003 is : 143
2015-05-20 14:35:34,226 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000005 is : 143
2015-05-20 14:35:34,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000002 is : 143
2015-05-20 14:35:34,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000006 is : 143
2015-05-20 14:35:34,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000009 is : 143
2015-05-20 14:35:34,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000008 is : 143
2015-05-20 14:35:34,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000007 is : 143
2015-05-20 14:35:34,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000010 is : 143
2015-05-20 14:35:39,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0007_01_000015 is : 143
2015-05-20 14:35:40,862 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree/_temporary
2015-05-20 14:35:40,877 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemergethree
2015-05-20 14:35:40,897 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:35:40,897 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 14:35:40,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-05-20 14:35:40,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:35:40,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1"]
2015-05-20 14:35:40,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2"]
2015-05-20 14:35:40,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-05-20 14:35:40,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 3
2015-05-20 14:35:40,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 3
2015-05-20 14:35:40,934 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-05-20 14:35:41,060 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0008
2015-05-20 14:35:41,060 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0008/
2015-05-20 14:35:58,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000002 is : 143
2015-05-20 14:35:58,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000005 is : 143
2015-05-20 14:35:58,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000003 is : 143
2015-05-20 14:35:58,627 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0008_01_000004 is : 143
2015-05-20 14:35:59,951 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...pesplatform/nonsafesplit2
2015-05-20 14:35:59,952 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...pesplatform/nonsafesplit1
2015-05-20 14:36:00,217 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0010
2015-05-20 14:36:00,217 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0010/
2015-05-20 14:36:00,230 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0009
2015-05-20 14:36:00,230 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0009/
2015-05-20 14:36:02,226 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-05-20 14:36:12,086 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0010_01_000006
2015-05-20 14:36:12,656 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0009_01_000008
2015-05-20 14:36:13,088 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0009_01_000009
2015-05-20 14:36:28,566 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000003 is : 143
2015-05-20 14:36:28,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000005 is : 143
2015-05-20 14:36:28,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000002 is : 143
2015-05-20 14:36:29,189 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0010_01_000004 is : 143
2015-05-20 14:36:29,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000005 is : 143
2015-05-20 14:36:29,584 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000003 is : 143
2015-05-20 14:36:29,684 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000002 is : 143
2015-05-20 14:36:29,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0009_01_000004 is : 143
2015-05-20 14:36:31,016 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2/_temporary
2015-05-20 14:36:31,018 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1/_temporary
2015-05-20 14:36:31,058 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit2
2015-05-20 14:36:31,069 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit1
2015-05-20 14:36:31,111 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:36:31,112 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 14:36:31,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting
2015-05-20 14:36:31,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:36:31,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2"]
2015-05-20 14:36:31,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1"]
2015-05-20 14:36:31,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] parallel execution is enabled: true
2015-05-20 14:36:31,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting jobs: 3
2015-05-20 14:36:31,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] allocating threads: 3
2015-05-20 14:36:31,133 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (1/3)
2015-05-20 14:36:31,248 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1432157552760_0011
2015-05-20 14:36:31,248 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0011/
2015-05-20 14:36:37,194 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1061)) - Event EventType: FINISH_APPLICATION sent to absent application application_1432157552760_0009
2015-05-20 14:36:46,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000002 is : 143
2015-05-20 14:36:47,155 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000003 is : 143
2015-05-20 14:36:47,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000005 is : 143
2015-05-20 14:36:47,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000004 is : 143
2015-05-20 14:36:52,752 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0011_01_000006 is : 143
2015-05-20 14:36:53,940 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (3/3) ...edpipesplatform/splitout2
2015-05-20 14:36:53,940 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (2/3) ...edpipesplatform/splitout1
2015-05-20 14:36:54,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1432157552760_0012
2015-05-20 14:36:54,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0012/
2015-05-20 14:36:54,105 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1432157552760_0013
2015-05-20 14:36:54,105 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0013/
2015-05-20 14:37:08,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0012_01_000002 is : 143
2015-05-20 14:37:08,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0013_01_000002 is : 143
2015-05-20 14:37:15,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0012_01_000003 is : 143
2015-05-20 14:37:16,863 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1/_temporary
2015-05-20 14:37:16,865 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2/_temporary
2015-05-20 14:37:16,993 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout1
2015-05-20 14:37:17,021 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout2
2015-05-20 14:37:17,098 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:37:17,098 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 14:37:17,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-05-20 14:37:17,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:37:17,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1"]
2015-05-20 14:37:17,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2"]
2015-05-20 14:37:17,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-05-20 14:37:17,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 2
2015-05-20 14:37:17,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 2
2015-05-20 14:37:17,121 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/2) ...eldedpipesplatform/split2
2015-05-20 14:37:17,121 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/2) ...eldedpipesplatform/split1
2015-05-20 14:37:17,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0014
2015-05-20 14:37:17,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0014/
2015-05-20 14:37:17,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0015
2015-05-20 14:37:17,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0015/
2015-05-20 14:37:32,271 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0014_01_000006
2015-05-20 14:37:32,361 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0015_01_000006
2015-05-20 14:37:49,271 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000003 is : 143
2015-05-20 14:37:49,724 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000005 is : 143
2015-05-20 14:37:49,858 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000002 is : 143
2015-05-20 14:37:49,904 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000003 is : 143
2015-05-20 14:37:50,070 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000004 is : 143
2015-05-20 14:37:50,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000004 is : 143
2015-05-20 14:37:50,229 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0015_01_000002 is : 143
2015-05-20 14:37:50,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0014_01_000005 is : 143
2015-05-20 14:37:51,558 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1/_temporary
2015-05-20 14:37:51,560 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2/_temporary
2015-05-20 14:37:51,595 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/split2
2015-05-20 14:37:51,607 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/split1
2015-05-20 14:37:51,631 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:37:51,632 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 14:37:51,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 14:37:51,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:37:51,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged"]
2015-05-20 14:37:51,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-05-20 14:37:51,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 2
2015-05-20 14:37:51,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 2
2015-05-20 14:37:51,649 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-05-20 14:37:51,765 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0016
2015-05-20 14:37:51,765 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0016/
2015-05-20 14:38:07,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000002 is : 143
2015-05-20 14:38:07,502 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000003 is : 143
2015-05-20 14:38:07,713 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000005 is : 143
2015-05-20 14:38:07,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0016_01_000004 is : 143
2015-05-20 14:38:09,026 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...latform/splitsourcemerged
2015-05-20 14:38:09,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0017
2015-05-20 14:38:09,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0017/
2015-05-20 14:38:26,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000005 is : 143
2015-05-20 14:38:26,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000004 is : 143
2015-05-20 14:38:26,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000002 is : 143
2015-05-20 14:38:26,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000003 is : 143
2015-05-20 14:38:31,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0017_01_000006 is : 143
2015-05-20 14:38:32,899 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged/_temporary
2015-05-20 14:38:32,914 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemerged
2015-05-20 14:38:32,930 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:38:32,930 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 14:38:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:38:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:38:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy"]
2015-05-20 14:38:32,941 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:38:32,941 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:38:32,941 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:38:32,943 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/copy
2015-05-20 14:38:33,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0018
2015-05-20 14:38:33,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0018/
2015-05-20 14:38:48,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000002 is : 143
2015-05-20 14:38:48,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000003 is : 143
2015-05-20 14:38:48,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000004 is : 143
2015-05-20 14:38:48,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0018_01_000005 is : 143
2015-05-20 14:38:49,735 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy/_temporary
2015-05-20 14:38:49,760 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/copy
2015-05-20 14:38:49,794 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:38:49,795 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 14:38:49,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:38:49,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:38:49,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/none"]
2015-05-20 14:38:49,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:38:49,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:38:49,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:38:49,814 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/none
2015-05-20 14:38:49,954 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0019
2015-05-20 14:38:49,955 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0019/
2015-05-20 14:39:06,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000003 is : 143
2015-05-20 14:39:06,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000002 is : 143
2015-05-20 14:39:06,251 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000005 is : 143
2015-05-20 14:39:06,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000004 is : 143
2015-05-20 14:39:11,827 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0019_01_000006 is : 143
2015-05-20 14:39:13,032 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/none/_temporary
2015-05-20 14:39:13,056 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/none
2015-05-20 14:39:13,076 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:39:13,076 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 14:39:13,088 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:39:13,088 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:39:13,088 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap"]
2015-05-20 14:39:13,089 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:39:13,089 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:39:13,089 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:39:13,092 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/swap
2015-05-20 14:39:13,211 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0020
2015-05-20 14:39:13,211 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0020/
2015-05-20 14:39:28,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000002 is : 143
2015-05-20 14:39:28,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000003 is : 143
2015-05-20 14:39:28,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000004 is : 143
2015-05-20 14:39:28,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000005 is : 143
2015-05-20 14:39:34,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0020_01_000006 is : 143
2015-05-20 14:39:35,942 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap/_temporary
2015-05-20 14:39:35,957 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/swap
2015-05-20 14:39:35,973 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:39:35,974 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 14:39:35,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:39:35,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:39:35,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter"]
2015-05-20 14:39:35,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:39:35,985 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:39:35,985 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:39:35,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/logicfilter
2015-05-20 14:39:36,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0021
2015-05-20 14:39:36,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0021/
2015-05-20 14:39:53,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000005 is : 143
2015-05-20 14:39:53,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000002 is : 143
2015-05-20 14:39:53,842 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000004 is : 143
2015-05-20 14:39:53,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0021_01_000003 is : 143
2015-05-20 14:39:55,216 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter/_temporary
2015-05-20 14:39:55,239 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/logicfilter
2015-05-20 14:39:55,288 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:39:55,288 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 14:39:55,298 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:39:55,298 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower+upper.txt"]
2015-05-20 14:39:55,298 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped"]
2015-05-20 14:39:55,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:39:55,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:39:55,299 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:39:55,300 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/ungrouped
2015-05-20 14:39:55,407 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0022
2015-05-20 14:39:55,407 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0022/
2015-05-20 14:40:14,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000002 is : 143
2015-05-20 14:40:14,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000006 is : 143
2015-05-20 14:40:14,825 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000003 is : 143
2015-05-20 14:40:14,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000005 is : 143
2015-05-20 14:40:14,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0022_01_000004 is : 143
2015-05-20 14:40:16,128 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped/_temporary
2015-05-20 14:40:16,153 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped
2015-05-20 14:40:16,192 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:40:16,192 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 14:40:16,235 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second"]
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third"]
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first"]
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 3
2015-05-20 14:40:16,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 3
2015-05-20 14:40:16,239 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/3) ...latform/chainedtaps/first
2015-05-20 14:40:16,356 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432157552760_0023
2015-05-20 14:40:16,356 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0023/
2015-05-20 14:40:32,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000002 is : 143
2015-05-20 14:40:32,557 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000004 is : 143
2015-05-20 14:40:32,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000005 is : 143
2015-05-20 14:40:32,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000003 is : 143
2015-05-20 14:40:38,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0023_01_000006 is : 143
2015-05-20 14:40:39,522 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (2/3) ...atform/chainedtaps/second
2015-05-20 14:40:39,672 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432157552760_0024
2015-05-20 14:40:39,672 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0024/
2015-05-20 14:40:55,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000004 is : 143
2015-05-20 14:40:55,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000002 is : 143
2015-05-20 14:40:55,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000005 is : 143
2015-05-20 14:40:55,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000003 is : 143
2015-05-20 14:41:01,245 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0024_01_000006 is : 143
2015-05-20 14:41:02,466 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (3/3) ...latform/chainedtaps/third
2015-05-20 14:41:02,589 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432157552760_0025
2015-05-20 14:41:02,590 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0025/
2015-05-20 14:41:19,515 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000004 is : 143
2015-05-20 14:41:19,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000003 is : 143
2015-05-20 14:41:19,760 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000005 is : 143
2015-05-20 14:41:19,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000002 is : 143
2015-05-20 14:41:25,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0025_01_000006 is : 143
2015-05-20 14:41:26,301 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first/_temporary
2015-05-20 14:41:26,303 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second/_temporary
2015-05-20 14:41:26,304 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third/_temporary
2015-05-20 14:41:26,319 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/third
2015-05-20 14:41:26,323 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/second
2015-05-20 14:41:26,330 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/first
2015-05-20 14:41:26,349 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:41:26,350 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 14:41:26,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:41:26,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:41:26,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall"]
2015-05-20 14:41:26,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:41:26,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-05-20 14:41:26,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-05-20 14:41:26,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-05-20 14:41:26,500 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0026
2015-05-20 14:41:26,501 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0026/
2015-05-20 14:41:43,786 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000004 is : 143
2015-05-20 14:41:43,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000003 is : 143
2015-05-20 14:41:43,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000005 is : 143
2015-05-20 14:41:43,959 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000002 is : 143
2015-05-20 14:41:48,974 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0026_01_000006 is : 143
2015-05-20 14:41:50,179 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...edpipesplatform/filterall
2015-05-20 14:41:50,300 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0027
2015-05-20 14:41:50,300 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0027/
2015-05-20 14:42:00,392 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0027_01_000002 is : 143
2015-05-20 14:42:06,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0027_01_000003 is : 143
2015-05-20 14:42:07,476 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall/_temporary
2015-05-20 14:42:07,489 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/filterall
2015-05-20 14:42:07,504 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:42:07,504 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 14:42:07,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-05-20 14:42:07,519 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:42:07,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename"]
2015-05-20 14:42:07,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-05-20 14:42:07,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 2
2015-05-20 14:42:07,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 2
2015-05-20 14:42:07,523 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-05-20 14:42:07,643 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0028
2015-05-20 14:42:07,643 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0028/
2015-05-20 14:42:23,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000004 is : 143
2015-05-20 14:42:23,786 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000002 is : 143
2015-05-20 14:42:23,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000003 is : 143
2015-05-20 14:42:23,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0028_01_000005 is : 143
2015-05-20 14:42:25,040 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...splitsourcemergedsamename
2015-05-20 14:42:25,166 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1432157552760_0029
2015-05-20 14:42:25,166 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0029/
2015-05-20 14:42:41,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000002 is : 143
2015-05-20 14:42:42,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000005 is : 143
2015-05-20 14:42:42,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000004 is : 143
2015-05-20 14:42:42,199 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000003 is : 143
2015-05-20 14:42:47,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0029_01_000006 is : 143
2015-05-20 14:42:49,158 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename/_temporary
2015-05-20 14:42:49,174 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename
2015-05-20 14:42:49,195 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:42:49,195 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 14:42:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting
2015-05-20 14:42:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] source: Hfs["TextDelimited[['num', 'char']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 14:42:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] source: Hfs["TextDelimited[['num', 'char']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:42:49,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic"]
2015-05-20 14:42:49,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] parallel execution is enabled: true
2015-05-20 14:42:49,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting jobs: 1
2015-05-20 14:42:49,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] allocating threads: 1
2015-05-20 14:42:49,215 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] starting step: (1/1) ...grouping-nondeterministic
2015-05-20 14:42:49,346 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] submitted hadoop job: job_1432157552760_0030
2015-05-20 14:42:49,347 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0030/
2015-05-20 14:42:59,072 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0030_01_000008
2015-05-20 14:42:59,181 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0030_01_000009
2015-05-20 14:43:09,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000005 is : 143
2015-05-20 14:43:09,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000003 is : 143
2015-05-20 14:43:09,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000002 is : 143
2015-05-20 14:43:09,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000004 is : 143
2015-05-20 14:43:10,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000006 is : 143
2015-05-20 14:43:10,106 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000007 is : 143
2015-05-20 14:43:16,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0030_01_000010 is : 143
2015-05-20 14:43:17,391 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic/_temporary
2015-05-20 14:43:17,405 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic
2015-05-20 14:43:17,422 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:43:17,422 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 14:43:17,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:43:17,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower+upper.txt"]
2015-05-20 14:43:17,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon"]
2015-05-20 14:43:17,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:43:17,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:43:17,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:43:17,440 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/ungroupedanon
2015-05-20 14:43:17,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0031
2015-05-20 14:43:17,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0031/
2015-05-20 14:43:29,039 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0031_01_000008
2015-05-20 14:43:37,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000002 is : 143
2015-05-20 14:43:38,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000005 is : 143
2015-05-20 14:43:38,244 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000003 is : 143
2015-05-20 14:43:38,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000006 is : 143
2015-05-20 14:43:38,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0031_01_000004 is : 143
2015-05-20 14:43:39,559 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon/_temporary
2015-05-20 14:43:39,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungroupedanon
2015-05-20 14:43:39,606 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:43:39,607 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 14:43:39,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:43:39,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:43:39,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup"]
2015-05-20 14:43:39,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:43:39,624 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-05-20 14:43:39,624 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-05-20 14:43:39,625 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-05-20 14:43:39,744 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0032
2015-05-20 14:43:39,744 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0032/
2015-05-20 14:43:57,760 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000005 is : 143
2015-05-20 14:43:57,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000004 is : 143
2015-05-20 14:43:57,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000002 is : 143
2015-05-20 14:43:58,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000003 is : 143
2015-05-20 14:44:04,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0032_01_000006 is : 143
2015-05-20 14:44:05,695 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...dpipesplatform/groupgroup
2015-05-20 14:44:05,805 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0033
2015-05-20 14:44:05,805 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0033/
2015-05-20 14:44:15,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0033_01_000002 is : 143
2015-05-20 14:44:22,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0033_01_000003 is : 143
2015-05-20 14:44:23,420 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup/_temporary
2015-05-20 14:44:23,437 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/groupgroup
2015-05-20 14:44:23,453 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:44:23,453 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 14:44:23,472 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting
2015-05-20 14:44:23,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 14:44:23,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup"]
2015-05-20 14:44:23,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] parallel execution is enabled: true
2015-05-20 14:44:23,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting jobs: 2
2015-05-20 14:44:23,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] allocating threads: 2
2015-05-20 14:44:23,475 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (2/2)
2015-05-20 14:44:23,626 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1432157552760_0034
2015-05-20 14:44:23,627 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0034/
2015-05-20 14:44:43,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000006 is : 143
2015-05-20 14:44:43,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000003 is : 143
2015-05-20 14:44:43,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000005 is : 143
2015-05-20 14:44:43,307 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000004 is : 143
2015-05-20 14:44:43,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000002 is : 143
2015-05-20 14:44:49,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0034_01_000007 is : 143
2015-05-20 14:44:51,005 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (1/2) .../samemergethreechaingroup
2015-05-20 14:44:51,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1432157552760_0035
2015-05-20 14:44:51,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0035/
2015-05-20 14:45:00,800 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0035_01_000008
2015-05-20 14:45:12,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000005 is : 143
2015-05-20 14:45:13,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000003 is : 143
2015-05-20 14:45:13,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000007 is : 143
2015-05-20 14:45:13,561 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000002 is : 143
2015-05-20 14:45:13,715 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000004 is : 143
2015-05-20 14:45:13,739 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000006 is : 143
2015-05-20 14:45:19,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0035_01_000009 is : 143
2015-05-20 14:45:20,768 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup/_temporary
2015-05-20 14:45:20,790 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup
2015-05-20 14:45:20,808 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:45:20,809 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 14:45:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:45:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:45:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace"]
2015-05-20 14:45:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:45:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:45:20,818 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:45:20,820 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/replace
2015-05-20 14:45:20,924 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0036
2015-05-20 14:45:20,924 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0036/
2015-05-20 14:45:37,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000005 is : 143
2015-05-20 14:45:37,591 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000003 is : 143
2015-05-20 14:45:37,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000004 is : 143
2015-05-20 14:45:37,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0036_01_000002 is : 143
2015-05-20 14:45:38,956 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace/_temporary
2015-05-20 14:45:38,988 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/replace
2015-05-20 14:45:39,027 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:45:39,027 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 14:45:39,036 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:45:39,036 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/extra+lower+upper.txt"]
2015-05-20 14:45:39,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size"]
2015-05-20 14:45:39,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:45:39,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:45:39,037 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:45:39,039 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/ungrouped_size
2015-05-20 14:45:39,094 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-05-20 14:45:39,149 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0037
2015-05-20 14:45:39,149 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0037/
2015-05-20 14:45:56,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000004 is : 143
2015-05-20 14:45:56,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000003 is : 143
2015-05-20 14:45:56,540 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000002 is : 143
2015-05-20 14:45:56,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0037_01_000005 is : 143
2015-05-20 14:45:57,745 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size/_temporary
2015-05-20 14:45:57,766 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped_size
2015-05-20 14:45:57,789 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:45:57,789 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 14:45:57,796 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:45:57,797 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:45:57,797 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter"]
2015-05-20 14:45:57,797 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:45:57,797 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:45:57,797 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:45:57,799 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/filter
2015-05-20 14:45:57,916 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0038
2015-05-20 14:45:57,916 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0038/
2015-05-20 14:46:14,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000002 is : 143
2015-05-20 14:46:14,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000004 is : 143
2015-05-20 14:46:14,644 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000005 is : 143
2015-05-20 14:46:14,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0038_01_000003 is : 143
2015-05-20 14:46:15,954 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter/_temporary
2015-05-20 14:46:15,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/filter
2015-05-20 14:46:16,005 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:46:16,005 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 14:46:16,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting
2015-05-20 14:46:16,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]]]
2015-05-20 14:46:16,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat"]
2015-05-20 14:46:16,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] parallel execution is enabled: true
2015-05-20 14:46:16,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting jobs: 1
2015-05-20 14:46:16,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] allocating threads: 1
2015-05-20 14:46:16,018 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] starting step: (1/1) ...pesplatform/complexconcat
2015-05-20 14:46:16,135 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] submitted hadoop job: job_1432157552760_0039
2015-05-20 14:46:16,135 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0039/
2015-05-20 14:46:25,463 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432157552760_0039_01_000008
2015-05-20 14:46:35,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000006 is : 143
2015-05-20 14:46:35,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000002 is : 143
2015-05-20 14:46:36,154 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000003 is : 143
2015-05-20 14:46:36,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000005 is : 143
2015-05-20 14:46:36,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000007 is : 143
2015-05-20 14:46:36,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000004 is : 143
2015-05-20 14:46:41,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0039_01_000009 is : 143
2015-05-20 14:46:42,960 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat/_temporary
2015-05-20 14:46:42,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/complexconcat
2015-05-20 14:46:42,994 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:46:42,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 14:46:43,018 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-05-20 14:46:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:46:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1"]
2015-05-20 14:46:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2"]
2015-05-20 14:46:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-05-20 14:46:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 3
2015-05-20 14:46:43,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 3
2015-05-20 14:46:43,023 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-05-20 14:46:43,154 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0040
2015-05-20 14:46:43,154 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0040/
2015-05-20 14:47:00,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000002 is : 143
2015-05-20 14:47:01,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000005 is : 143
2015-05-20 14:47:01,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000004 is : 143
2015-05-20 14:47:01,440 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000003 is : 143
2015-05-20 14:47:06,688 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0040_01_000006 is : 143
2015-05-20 14:47:07,909 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...dpipesplatform/splitcomp2
2015-05-20 14:47:07,909 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...dpipesplatform/splitcomp1
2015-05-20 14:47:08,176 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0041
2015-05-20 14:47:08,176 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0041/
2015-05-20 14:47:08,240 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1432157552760_0042
2015-05-20 14:47:08,241 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0042/
2015-05-20 14:47:23,397 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0041_01_000002 is : 143
2015-05-20 14:47:23,917 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0042_01_000002 is : 143
2015-05-20 14:47:25,145 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2/_temporary
2015-05-20 14:47:25,146 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1/_temporary
2015-05-20 14:47:25,211 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp1
2015-05-20 14:47:25,216 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp2
2015-05-20 14:47:25,257 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 14:47:25,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 14:47:25,269 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 14:47:25,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 14:47:25,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup"]
2015-05-20 14:47:25,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 14:47:25,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-05-20 14:47:25,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-05-20 14:47:25,271 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/nogroup
2015-05-20 14:47:25,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432157552760_0043
2015-05-20 14:47:25,396 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:53994/proxy/application_1432157552760_0043/
2015-05-20 14:47:40,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000005 is : 143
2015-05-20 14:47:41,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000004 is : 143
2015-05-20 14:47:41,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000002 is : 143
2015-05-20 14:47:41,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432157552760_0043_01_000003 is : 143
2015-05-20 14:47:42,652 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup/_temporary
2015-05-20 14:47:42,700 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/nogroup