2015-07-17 15:25:23,662 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:25:23,680 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:25:23,681 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.pipe.checkpoint.CheckpointPlatformTest
2015-07-17 15:25:23,702 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 15:25:24,505 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-07-17 15:25:24,956 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 15:25:28,619 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-07-17 15:25:28,823 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-07-17 15:25:28,999 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-07-17 15:25:29,172 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-07-17 15:25:46,347 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-07-17 15:25:46,428 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:25:46,429 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:25:46,435 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 166AB3BB00724C818CB6D306C7C611A4
2015-07-17 15:25:46,461 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][1021858893/test/]
2015-07-17 15:25:46,562 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:25:46,564 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:25:46,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:25:46,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/manycheckpoint"]
2015-07-17 15:25:46,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-07-17 15:25:46,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 3
2015-07-17 15:25:46,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 3
2015-07-17 15:25:46,567 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/3)
2015-07-17 15:25:47,377 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437171940825_0001
2015-07-17 15:25:47,377 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0001/
2015-07-17 15:26:02,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0001_01_000004 is : 143
2015-07-17 15:26:02,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0001_01_000003 is : 143
2015-07-17 15:26:02,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0001_01_000005 is : 143
2015-07-17 15:26:02,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0001_01_000002 is : 143
2015-07-17 15:26:03,552 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/3)
2015-07-17 15:26:03,712 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437171940825_0002
2015-07-17 15:26:03,713 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0002/
2015-07-17 15:26:17,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0002_01_000003 is : 143
2015-07-17 15:26:17,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0002_01_000002 is : 143
2015-07-17 15:26:17,582 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0002_01_000005 is : 143
2015-07-17 15:26:17,610 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0002_01_000004 is : 143
2015-07-17 15:26:22,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0002_01_000006 is : 143
2015-07-17 15:26:24,180 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (3/3) ...ntplatform/manycheckpoint
2015-07-17 15:26:24,363 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437171940825_0003
2015-07-17 15:26:24,364 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0003/
2015-07-17 15:26:33,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0003_01_000002 is : 143
2015-07-17 15:26:34,748 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/manycheckpoint/_temporary
2015-07-17 15:26:34,778 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/manycheckpoint
2015-07-17 15:26:34,808 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:26:34,808 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:26:34,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting
2015-07-17 15:26:34,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:26:34,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint"]
2015-07-17 15:26:34,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] parallel execution is enabled: true
2015-07-17 15:26:34,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting jobs: 2
2015-07-17 15:26:34,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] allocating threads: 2
2015-07-17 15:26:34,835 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] at least one sink does not exist
2015-07-17 15:26:34,838 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Fri Jul 17 15:25:46 PDT 2015
2015-07-17 15:26:34,839 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (1/2)
2015-07-17 15:26:34,981 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1437171940825_0004
2015-07-17 15:26:34,981 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0004/
2015-07-17 15:26:48,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0004_01_000005 is : 143
2015-07-17 15:26:48,797 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0004_01_000003 is : 143
2015-07-17 15:26:48,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0004_01_000002 is : 143
2015-07-17 15:26:49,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0004_01_000004 is : 143
2015-07-17 15:26:50,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (2/2) ...latform/restartcheckpoint
2015-07-17 15:26:50,360 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1437171940825_0005
2015-07-17 15:26:50,360 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0005/
2015-07-17 15:27:04,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000003 is : 143
2015-07-17 15:27:04,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000002 is : 143
2015-07-17 15:27:04,543 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000005 is : 143
2015-07-17 15:27:04,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000004 is : 143
2015-07-17 15:27:09,561 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000006 is : 143
2015-07-17 15:27:15,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000007 is : 143
2015-07-17 15:27:20,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000008 is : 143
2015-07-17 15:27:26,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0005_01_000009 is : 143
2015-07-17 15:27:27,971 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] hadoop job job_1437171940825_0005 state at FAILED
2015-07-17 15:27:27,972 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] failure info: Task failed task_1437171940825_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2015-07-17 15:27:27,996 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] task completion events identify failed tasks
2015-07-17 15:27:27,996 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] task completion events count: 8
2015-07-17 15:27:27,997 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_m_000001_0, Status : SUCCEEDED
2015-07-17 15:27:27,997 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_m_000000_0, Status : SUCCEEDED
2015-07-17 15:27:27,998 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_m_000003_0, Status : SUCCEEDED
2015-07-17 15:27:27,998 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_m_000002_0, Status : SUCCEEDED
2015-07-17 15:27:27,998 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_r_000000_0, Status : FAILED
2015-07-17 15:27:27,998 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_r_000000_1, Status : FAILED
2015-07-17 15:27:27,998 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_r_000000_2, Status : FAILED
2015-07-17 15:27:27,998 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [restartable] event = Task Id : attempt_1437171940825_0005_r_000000_3, Status : TIPFAILED
2015-07-17 15:27:28,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] stopping all jobs
2015-07-17 15:27:28,027 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] stopping: (2/2) ...latform/restartcheckpoint
2015-07-17 15:27:28,029 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] stopping: (1/2)
2015-07-17 15:27:31,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] stopped all jobs
2015-07-17 15:27:31,467 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /tmp/hadoop-castillo/restartable/restartable/test/_temporary
2015-07-17 15:27:31,469 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint/_temporary
2015-07-17 15:27:31,489 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:27:31,489 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:27:31,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting
2015-07-17 15:27:31,520 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:27:31,521 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint"]
2015-07-17 15:27:31,521 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] parallel execution is enabled: true
2015-07-17 15:27:31,521 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] starting jobs: 2
2015-07-17 15:27:31,521 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [restartable] allocating threads: 2
2015-07-17 15:27:31,523 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] at least one sink is marked for delete
2015-07-17 15:27:31,523 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:27:31,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Fri Jul 17 15:26:49 PDT 2015
2015-07-17 15:27:31,528 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] sink oldest modified date: Fri Jul 17 15:26:49 PDT 2015
2015-07-17 15:27:31,531 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] source modification date at: Fri Jul 17 15:25:46 PDT 2015
2015-07-17 15:27:31,531 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] skipping step: (1/2)
2015-07-17 15:27:31,532 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] starting step: (2/2) ...latform/restartcheckpoint
2015-07-17 15:27:31,680 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] submitted hadoop job: job_1437171940825_0006
2015-07-17 15:27:31,680 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [restartable] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0006/
2015-07-17 15:27:45,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0006_01_000003 is : 143
2015-07-17 15:27:45,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0006_01_000002 is : 143
2015-07-17 15:27:45,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0006_01_000004 is : 143
2015-07-17 15:27:45,905 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0006_01_000005 is : 143
2015-07-17 15:27:50,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0006_01_000006 is : 143
2015-07-17 15:27:52,202 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/restartcheckpoint/_temporary
2015-07-17 15:27:52,220 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/restartcheckpoint
2015-07-17 15:27:52,246 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:27:52,247 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:27:52,251 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointevery/tap
2015-07-17 15:27:52,252 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointevery/sink
2015-07-17 15:27:52,268 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:27:52,268 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:27:52,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-07-17 15:27:52,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:27:52,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/simplecheckpoint"]
2015-07-17 15:27:52,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-07-17 15:27:52,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-07-17 15:27:52,293 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-07-17 15:27:52,295 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-07-17 15:27:52,442 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437171940825_0007
2015-07-17 15:27:52,442 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0007/
2015-07-17 15:28:06,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0007_01_000003 is : 143
2015-07-17 15:28:06,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0007_01_000005 is : 143
2015-07-17 15:28:06,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0007_01_000004 is : 143
2015-07-17 15:28:07,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0007_01_000002 is : 143
2015-07-17 15:28:08,247 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...platform/simplecheckpoint
2015-07-17 15:28:08,389 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1437171940825_0008
2015-07-17 15:28:08,389 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0008/
2015-07-17 15:28:22,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0008_01_000002 is : 143
2015-07-17 15:28:22,189 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0008_01_000003 is : 143
2015-07-17 15:28:22,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0008_01_000005 is : 143
2015-07-17 15:28:22,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0008_01_000004 is : 143
2015-07-17 15:28:28,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0008_01_000006 is : 143
2015-07-17 15:28:29,245 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/simplecheckpoint/_temporary
2015-07-17 15:28:29,263 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/simplecheckpoint
2015-07-17 15:28:29,302 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:28:29,302 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:28:29,307 INFO planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/tap"]
2015-07-17 15:28:29,324 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-07-17 15:28:29,324 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:28:29,324 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/sink"]
2015-07-17 15:28:29,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-07-17 15:28:29,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-07-17 15:28:29,325 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-07-17 15:28:29,326 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...ntplatform/checkpoint/tap
2015-07-17 15:28:29,471 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1437171940825_0009
2015-07-17 15:28:29,471 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0009/
2015-07-17 15:28:43,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0009_01_000003 is : 143
2015-07-17 15:28:43,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0009_01_000002 is : 143
2015-07-17 15:28:43,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0009_01_000004 is : 143
2015-07-17 15:28:43,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0009_01_000005 is : 143
2015-07-17 15:28:44,860 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...tplatform/checkpoint/sink
2015-07-17 15:28:44,970 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1437171940825_0010
2015-07-17 15:28:44,970 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Marks-MacBook.local:61145/proxy/application_1437171940825_0010/
2015-07-17 15:29:02,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000007 is : 143
2015-07-17 15:29:02,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000003 is : 143
2015-07-17 15:29:03,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000006 is : 143
2015-07-17 15:29:03,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000004 is : 143
2015-07-17 15:29:03,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000002 is : 143
2015-07-17 15:29:03,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000005 is : 143
2015-07-17 15:29:08,716 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437171940825_0010_01_000008 is : 143
2015-07-17 15:29:09,887 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/tap/_temporary
2015-07-17 15:29:09,889 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/checkpoint/sink/_temporary
2015-07-17 15:29:09,939 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/checkpoint/tap
2015-07-17 15:29:09,960 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/checkpoint/sink
2015-07-17 15:29:09,982 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:29:09,983 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:29:09,986 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/duplicatecheckpoint
2015-07-17 15:29:10,012 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:29:10,012 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:29:10,016 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpoint/sink
2015-07-17 15:29:10,017 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpoint/tap
2015-07-17 15:29:10,032 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:29:10,032 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:29:10,034 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointdeclared/sink
2015-07-17 15:29:10,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/failcheckpointdeclared/tap