2015-05-20 15:49:19,146 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 15:49:19,179 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 15:49:19,179 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.pipe.checkpoint.CheckpointPlatformTest
2015-05-20 15:49:19,195 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 15:49:19,789 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 15:49:20,309 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 15:49:23,503 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 15:49:23,774 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 15:49:24,023 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 15:49:24,218 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 15:49:24,412 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 15:49:41,577 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:49:41,578 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 15:49:41,584 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: C042DF8445B14A71845A3B0DA9EEEB14
2015-05-20 15:49:41,608 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][7103822193/test/]
2015-05-20 15:49:41,711 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 15:49:41,712 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 15:49:41,713 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 15:49:41,713 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/checkpointplatform/manycheckpoint"]
2015-05-20 15:49:41,713 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 15:49:41,713 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 3
2015-05-20 15:49:41,714 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 3
2015-05-20 15:49:41,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/3)
2015-05-20 15:49:42,440 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432162175981_0001
2015-05-20 15:49:42,441 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0001/
2015-05-20 15:49:57,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0001_01_000005 is : 143
2015-05-20 15:49:58,039 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0001_01_000004 is : 143
2015-05-20 15:49:58,085 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0001_01_000002 is : 143
2015-05-20 15:49:58,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0001_01_000003 is : 143
2015-05-20 15:49:59,372 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/3)
2015-05-20 15:49:59,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432162175981_0002
2015-05-20 15:49:59,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0002/
2015-05-20 15:50:13,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0002_01_000002 is : 143
2015-05-20 15:50:14,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0002_01_000003 is : 143
2015-05-20 15:50:14,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0002_01_000005 is : 143
2015-05-20 15:50:14,316 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0002_01_000004 is : 143
2015-05-20 15:50:19,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0002_01_000006 is : 143
2015-05-20 15:50:21,082 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (3/3) ...ntplatform/manycheckpoint
2015-05-20 15:50:21,278 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432162175981_0003
2015-05-20 15:50:21,279 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0003/
2015-05-20 15:50:30,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0003_01_000002 is : 143
2015-05-20 15:50:31,545 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/manycheckpoint/_temporary
2015-05-20 15:50:31,575 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/manycheckpoint
2015-05-20 15:50:31,599 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:50:31,599 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 15:50:31,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting
2015-05-20 15:50:31,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:50:31,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint"]
2015-05-20 15:50:31,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] parallel execution is enabled: true
2015-05-20 15:50:31,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting jobs: 2
2015-05-20 15:50:31,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] allocating threads: 2
2015-05-20 15:50:31,626 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] at least one sink does not exist
2015-05-20 15:50:31,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Wed May 20 15:49:41 PDT 2015
2015-05-20 15:50:31,630 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (1/2)
2015-05-20 15:50:31,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1432162175981_0004
2015-05-20 15:50:31,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0004/
2015-05-20 15:50:45,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0004_01_000002 is : 143
2015-05-20 15:50:46,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0004_01_000003 is : 143
2015-05-20 15:50:46,340 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0004_01_000005 is : 143
2015-05-20 15:50:46,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0004_01_000004 is : 143
2015-05-20 15:50:47,598 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (2/2) ...latform/restartcheckpoint
2015-05-20 15:50:47,770 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1432162175981_0005
2015-05-20 15:50:47,770 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0005/
2015-05-20 15:51:01,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000002 is : 143
2015-05-20 15:51:01,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000003 is : 143
2015-05-20 15:51:01,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000004 is : 143
2015-05-20 15:51:01,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000005 is : 143
2015-05-20 15:51:06,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000006 is : 143
2015-05-20 15:51:12,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000007 is : 143
2015-05-20 15:51:19,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000008 is : 143
2015-05-20 15:51:24,796 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0005_01_000009 is : 143
2015-05-20 15:51:25,914 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] hadoop job job_1432162175981_0005 state at FAILED
2015-05-20 15:51:25,914 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] failure info: Task failed task_1432162175981_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2015-05-20 15:51:25,934 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] task completion events identify failed tasks
2015-05-20 15:51:25,934 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] task completion events count: 8
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_m_000000_0, Status : SUCCEEDED
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_m_000001_0, Status : SUCCEEDED
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_m_000002_0, Status : SUCCEEDED
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_m_000003_0, Status : SUCCEEDED
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_r_000000_0, Status : FAILED
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_r_000000_1, Status : FAILED
2015-05-20 15:51:25,935 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_r_000000_2, Status : FAILED
2015-05-20 15:51:25,936 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1432162175981_0005_r_000000_3, Status : TIPFAILED
2015-05-20 15:51:25,959 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] stopping all jobs
2015-05-20 15:51:25,959 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] stopping: (2/2) ...latform/restartcheckpoint
2015-05-20 15:51:25,961 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] stopping: (1/2)
2015-05-20 15:51:29,391 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] stopped all jobs
2015-05-20 15:51:29,392 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /tmp/hadoop-soberoi/restartable/restartable/test/_temporary
2015-05-20 15:51:29,394 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint/_temporary
2015-05-20 15:51:29,411 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:51:29,411 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 15:51:29,434 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting
2015-05-20 15:51:29,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:51:29,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint"]
2015-05-20 15:51:29,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] parallel execution is enabled: true
2015-05-20 15:51:29,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting jobs: 2
2015-05-20 15:51:29,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] allocating threads: 2
2015-05-20 15:51:29,437 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] at least one sink is marked for delete
2015-05-20 15:51:29,437 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:51:29,439 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Wed May 20 15:50:46 PDT 2015
2015-05-20 15:51:29,440 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] sink oldest modified date: Wed May 20 15:50:46 PDT 2015
2015-05-20 15:51:29,442 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Wed May 20 15:49:41 PDT 2015
2015-05-20 15:51:29,443 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] skipping step: (1/2)
2015-05-20 15:51:29,443 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (2/2) ...latform/restartcheckpoint
2015-05-20 15:51:29,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1432162175981_0006
2015-05-20 15:51:29,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0006/
2015-05-20 15:51:43,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0006_01_000002 is : 143
2015-05-20 15:51:43,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0006_01_000005 is : 143
2015-05-20 15:51:43,775 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0006_01_000004 is : 143
2015-05-20 15:51:43,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0006_01_000003 is : 143
2015-05-20 15:51:48,435 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0006_01_000006 is : 143
2015-05-20 15:51:49,617 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint/_temporary
2015-05-20 15:51:49,635 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/restartcheckpoint
2015-05-20 15:51:49,658 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:51:49,659 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 15:51:49,663 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointevery/sink
2015-05-20 15:51:49,664 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointevery/tap
2015-05-20 15:51:49,679 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:51:49,679 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 15:51:49,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-05-20 15:51:49,700 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 15:51:49,700 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/checkpointplatform/simplecheckpoint"]
2015-05-20 15:51:49,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-05-20 15:51:49,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-05-20 15:51:49,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-05-20 15:51:49,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-05-20 15:51:49,849 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432162175981_0007
2015-05-20 15:51:49,849 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0007/
2015-05-20 15:52:04,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0007_01_000002 is : 143
2015-05-20 15:52:04,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0007_01_000005 is : 143
2015-05-20 15:52:05,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0007_01_000004 is : 143
2015-05-20 15:52:05,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0007_01_000003 is : 143
2015-05-20 15:52:06,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...platform/simplecheckpoint
2015-05-20 15:52:06,447 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1432162175981_0008
2015-05-20 15:52:06,448 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0008/
2015-05-20 15:52:20,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0008_01_000002 is : 143
2015-05-20 15:52:20,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0008_01_000003 is : 143
2015-05-20 15:52:20,585 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0008_01_000005 is : 143
2015-05-20 15:52:20,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0008_01_000004 is : 143
2015-05-20 15:52:25,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0008_01_000006 is : 143
2015-05-20 15:52:26,496 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/simplecheckpoint/_temporary
2015-05-20 15:52:26,512 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/simplecheckpoint
2015-05-20 15:52:26,535 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:52:26,535 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 15:52:26,539 INFO planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/tap"]
2015-05-20 15:52:26,556 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-05-20 15:52:26,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:52:26,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/sink"]
2015-05-20 15:52:26,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-05-20 15:52:26,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-05-20 15:52:26,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-05-20 15:52:26,558 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...ntplatform/checkpoint/tap
2015-05-20 15:52:26,707 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432162175981_0009
2015-05-20 15:52:26,708 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0009/
2015-05-20 15:52:41,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0009_01_000002 is : 143
2015-05-20 15:52:41,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0009_01_000005 is : 143
2015-05-20 15:52:41,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0009_01_000004 is : 143
2015-05-20 15:52:41,382 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0009_01_000003 is : 143
2015-05-20 15:52:42,557 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...tplatform/checkpoint/sink
2015-05-20 15:52:42,682 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1432162175981_0010
2015-05-20 15:52:42,682 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Edinburgh.local:51329/proxy/application_1432162175981_0010/
2015-05-20 15:53:00,647 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000004 is : 143
2015-05-20 15:53:00,714 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000003 is : 143
2015-05-20 15:53:00,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000006 is : 143
2015-05-20 15:53:00,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000002 is : 143
2015-05-20 15:53:01,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000005 is : 143
2015-05-20 15:53:01,062 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000007 is : 143
2015-05-20 15:53:05,712 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162175981_0010_01_000008 is : 143
2015-05-20 15:53:06,914 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/tap/_temporary
2015-05-20 15:53:06,916 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/sink/_temporary
2015-05-20 15:53:06,953 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/checkpoint/tap
2015-05-20 15:53:06,965 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/checkpoint/sink
2015-05-20 15:53:06,983 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:53:06,984 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 15:53:06,986 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/duplicatecheckpoint
2015-05-20 15:53:07,000 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:53:07,001 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 15:53:07,002 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpoint/tap
2015-05-20 15:53:07,003 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpoint/sink
2015-05-20 15:53:07,015 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:53:07,016 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 15:53:07,018 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointdeclared/tap
2015-05-20 15:53:07,018 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointdeclared/sink