2015-05-20 20:13:46,873 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 20:13:46,903 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 20:13:46,903 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.pipe.checkpoint.CheckpointPlatformTest
2015-05-20 20:13:46,918 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 20:13:47,498 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 20:13:47,945 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 20:13:51,950 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 20:13:53,135 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 20:13:54,285 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 20:13:55,428 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 20:13:58,031 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:13:58,032 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 20:13:58,038 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 9E019C1C58014C03975CC642F1532774
2015-05-20 20:13:58,062 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][6118850280/test/]
2015-05-20 20:13:58,157 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 20:13:58,158 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 20:13:58,159 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:13:58,159 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/manycheckpoint"]
2015-05-20 20:13:58,160 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 20:13:58,160 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 3
2015-05-20 20:13:58,160 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 3
2015-05-20 20:13:58,162 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/3)
2015-05-20 20:13:58,636 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432178030145_0001
2015-05-20 20:13:58,636 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0001/
2015-05-20 20:14:12,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0001_01_000005 is : 143
2015-05-20 20:14:12,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0001_01_000003 is : 143
2015-05-20 20:14:12,444 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0001_01_000002 is : 143
2015-05-20 20:14:12,584 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0001_01_000004 is : 143
2015-05-20 20:14:13,846 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/3)
2015-05-20 20:14:14,001 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432178030145_0002
2015-05-20 20:14:14,002 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0002/
2015-05-20 20:14:27,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0002_01_000005 is : 143
2015-05-20 20:14:27,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0002_01_000003 is : 143
2015-05-20 20:14:27,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0002_01_000004 is : 143
2015-05-20 20:14:28,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0002_01_000002 is : 143
2015-05-20 20:14:32,777 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0002_01_000006 is : 143
2015-05-20 20:14:33,950 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (3/3) ...ntplatform/manycheckpoint
2015-05-20 20:14:34,106 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432178030145_0003
2015-05-20 20:14:34,106 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0003/
2015-05-20 20:14:42,915 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0003_01_000002 is : 143
2015-05-20 20:14:44,083 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/manycheckpoint/_temporary
2015-05-20 20:14:44,109 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/manycheckpoint
2015-05-20 20:14:44,130 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:14:44,131 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 20:14:44,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting
2015-05-20 20:14:44,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:14:44,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint"]
2015-05-20 20:14:44,152 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] parallel execution is enabled: true
2015-05-20 20:14:44,152 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting jobs: 2
2015-05-20 20:14:44,152 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] allocating threads: 2
2015-05-20 20:14:44,155 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] at least one sink does not exist
2015-05-20 20:14:44,157 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Wed May 20 20:13:57 PDT 2015
2015-05-20 20:14:44,158 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (1/2)
2015-05-20 20:14:44,272 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1432178030145_0004
2015-05-20 20:14:44,272 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0004/
2015-05-20 20:14:57,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0004_01_000003 is : 143
2015-05-20 20:14:57,372 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0004_01_000002 is : 143
2015-05-20 20:14:57,806 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0004_01_000004 is : 143
2015-05-20 20:14:57,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0004_01_000005 is : 143
2015-05-20 20:14:59,113 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (2/2) ...latform/restartcheckpoint
2015-05-20 20:14:59,250 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1432178030145_0005
2015-05-20 20:14:59,250 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0005/
2015-05-20 20:15:12,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000005 is : 143
2015-05-20 20:15:12,759 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000002 is : 143
2015-05-20 20:15:12,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000003 is : 143
2015-05-20 20:15:12,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000004 is : 143
2015-05-20 20:15:18,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000006 is : 143
2015-05-20 20:15:23,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000007 is : 143
2015-05-20 20:15:28,621 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000008 is : 143
2015-05-20 20:15:33,499 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0005_01_000009 is : 143
2015-05-20 20:15:34,627 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] hadoop job job_1432178030145_0005 state at FAILED
2015-05-20 20:15:34,628 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] failure info: Task failed task_1432178030145_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2015-05-20 20:15:34,646 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] task completion events identify failed tasks
2015-05-20 20:15:34,646 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] task completion events count: 8
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_m_000003_0, Status : SUCCEEDED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_m_000000_0, Status : SUCCEEDED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_m_000001_0, Status : SUCCEEDED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_m_000002_0, Status : SUCCEEDED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_r_000000_0, Status : FAILED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_r_000000_1, Status : FAILED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_r_000000_2, Status : FAILED
2015-05-20 20:15:34,647 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432178030145_0005_r_000000_3, Status : TIPFAILED
2015-05-20 20:15:34,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] stopping all jobs
2015-05-20 20:15:34,673 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] stopping: (2/2) ...latform/restartcheckpoint
2015-05-20 20:15:34,674 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] stopping: (1/2)
2015-05-20 20:15:38,059 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] stopped all jobs
2015-05-20 20:15:38,060 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /tmp/hadoop-soberoi/restartable/restartable/test/_temporary
2015-05-20 20:15:38,062 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint/_temporary
2015-05-20 20:15:38,076 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:15:38,077 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 20:15:38,096 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting
2015-05-20 20:15:38,096 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:15:38,096 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint"]
2015-05-20 20:15:38,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] parallel execution is enabled: true
2015-05-20 20:15:38,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting jobs: 2
2015-05-20 20:15:38,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] allocating threads: 2
2015-05-20 20:15:38,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] at least one sink is marked for delete
2015-05-20 20:15:38,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 20:15:38,101 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Wed May 20 20:14:57 PDT 2015
2015-05-20 20:15:38,101 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] sink oldest modified date: Wed May 20 20:14:57 PDT 2015
2015-05-20 20:15:38,103 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Wed May 20 20:13:57 PDT 2015
2015-05-20 20:15:38,104 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] skipping step: (1/2)
2015-05-20 20:15:38,104 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (2/2) ...latform/restartcheckpoint
2015-05-20 20:15:38,211 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1432178030145_0006
2015-05-20 20:15:38,211 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0006/
2015-05-20 20:15:51,191 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0006_01_000003 is : 143
2015-05-20 20:15:51,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0006_01_000002 is : 143
2015-05-20 20:15:51,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0006_01_000004 is : 143
2015-05-20 20:15:51,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0006_01_000005 is : 143
2015-05-20 20:15:56,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0006_01_000006 is : 143
2015-05-20 20:15:57,784 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint/_temporary
2015-05-20 20:15:57,804 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/restartcheckpoint
2015-05-20 20:15:57,827 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:15:57,828 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 20:15:57,832 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointevery/sink
2015-05-20 20:15:57,832 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointevery/tap
2015-05-20 20:15:57,845 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:15:57,846 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 20:15:57,866 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 20:15:57,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:15:57,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/simplecheckpoint"]
2015-05-20 20:15:57,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 20:15:57,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-05-20 20:15:57,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-05-20 20:15:57,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-05-20 20:15:58,001 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432178030145_0007
2015-05-20 20:15:58,001 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0007/
2015-05-20 20:16:11,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0007_01_000003 is : 143
2015-05-20 20:16:11,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0007_01_000002 is : 143
2015-05-20 20:16:11,501 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0007_01_000005 is : 143
2015-05-20 20:16:11,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0007_01_000004 is : 143
2015-05-20 20:16:12,800 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...platform/simplecheckpoint
2015-05-20 20:16:12,915 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432178030145_0008
2015-05-20 20:16:12,915 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0008/
2015-05-20 20:16:26,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0008_01_000005 is : 143
2015-05-20 20:16:26,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0008_01_000002 is : 143
2015-05-20 20:16:26,534 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0008_01_000004 is : 143
2015-05-20 20:16:26,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0008_01_000003 is : 143
2015-05-20 20:16:31,633 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0008_01_000006 is : 143
2015-05-20 20:16:32,802 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/simplecheckpoint/_temporary
2015-05-20 20:16:32,816 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/simplecheckpoint
2015-05-20 20:16:32,834 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:16:32,834 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 20:16:32,838 INFO planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/tap"]
2015-05-20 20:16:32,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-05-20 20:16:32,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/classes/test/data/apache.10.txt"]
2015-05-20 20:16:32,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/sink"]
2015-05-20 20:16:32,856 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-05-20 20:16:32,856 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-05-20 20:16:32,856 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-05-20 20:16:32,857 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...ntplatform/checkpoint/tap
2015-05-20 20:16:32,989 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432178030145_0009
2015-05-20 20:16:32,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0009/
2015-05-20 20:16:46,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0009_01_000004 is : 143
2015-05-20 20:16:46,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0009_01_000003 is : 143
2015-05-20 20:16:46,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0009_01_000005 is : 143
2015-05-20 20:16:46,942 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0009_01_000002 is : 143
2015-05-20 20:16:48,123 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...tplatform/checkpoint/sink
2015-05-20 20:16:48,235 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432178030145_0010
2015-05-20 20:16:48,235 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:52689/proxy/application_1432178030145_0010/
2015-05-20 20:17:05,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000003 is : 143
2015-05-20 20:17:05,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000004 is : 143
2015-05-20 20:17:05,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000007 is : 143
2015-05-20 20:17:05,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000002 is : 143
2015-05-20 20:17:05,417 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000006 is : 143
2015-05-20 20:17:05,448 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000005 is : 143
2015-05-20 20:17:10,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1432178030145_0010_01_000008 is : 143
2015-05-20 20:17:11,611 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/tap/_temporary
2015-05-20 20:17:11,612 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/sink/_temporary
2015-05-20 20:17:11,648 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/checkpoint/tap
2015-05-20 20:17:11,658 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/checkpoint/sink
2015-05-20 20:17:11,673 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:17:11,674 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 20:17:11,677 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/duplicatecheckpoint
2015-05-20 20:17:11,693 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:17:11,694 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 20:17:11,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpoint/tap
2015-05-20 20:17:11,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpoint/sink
2015-05-20 20:17:11,708 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 20:17:11,708 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 20:17:11,710 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointdeclared/tap
2015-05-20 20:17:11,711 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/pivotal/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointdeclared/sink