2015-07-21 12:23:56,811 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 12:23:56,830 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.pipe.checkpoint.CheckpointPlatformTest, with platform: hadoop2-mr1
2015-07-21 12:23:56,853 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-07-21 12:23:57,641 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-21 12:23:58,150 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-21 12:24:02,953 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-21 12:24:03,181 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-21 12:24:03,381 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-21 12:24:03,569 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-21 12:24:20,712 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-07-21 12:24:20,808 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:24:20,809 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:24:20,861 INFO property.AppProps (AppProps.java:getAppID(174)) - using app.id: 5BE0CD082DFF4918B167FDC0E9B566BE
2015-07-21 12:24:20,919 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(797)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][542393811/test/]
2015-07-21 12:24:21,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.114
2015-07-21 12:24:21,008 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2015-07-21 12:24:21,009 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:24:21,148 INFO util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 12:24:21,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:24:21,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:24:21,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint"]
2015-07-21 12:24:21,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-07-21 12:24:21,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 3
2015-07-21 12:24:21,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 3
2015-07-21 12:24:21,152 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/3)
2015-07-21 12:24:22,106 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437506655199_0001
2015-07-21 12:24:22,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0001/
2015-07-21 12:24:37,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0001_01_000003 is : 143
2015-07-21 12:24:37,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0001_01_000002 is : 143
2015-07-21 12:24:37,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0001_01_000005 is : 143
2015-07-21 12:24:37,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0001_01_000004 is : 143
2015-07-21 12:24:38,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/3)
2015-07-21 12:24:39,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437506655199_0002
2015-07-21 12:24:39,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0002/
2015-07-21 12:24:55,081 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0002_01_000002 is : 143
2015-07-21 12:24:55,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0002_01_000004 is : 143
2015-07-21 12:24:55,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0002_01_000005 is : 143
2015-07-21 12:24:55,297 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0002_01_000003 is : 143
2015-07-21 12:25:01,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0002_01_000006 is : 143
2015-07-21 12:25:02,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (3/3) ...heckpoints/manycheckpoint
2015-07-21 12:25:03,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437506655199_0003
2015-07-21 12:25:03,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0003/
2015-07-21 12:25:15,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0003_01_000002 is : 143
2015-07-21 12:25:16,921 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint/_temporary
2015-07-21 12:25:16,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:55.764
2015-07-21 12:25:16,956 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint
2015-07-21 12:25:16,996 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:25:16,997 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:25:17,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-07-21 12:25:17,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 12:25:17,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:25:17,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting
2015-07-21 12:25:17,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:25:17,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2015-07-21 12:25:17,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] parallel execution of steps is enabled: true
2015-07-21 12:25:17,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executing total steps: 2
2015-07-21 12:25:17,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] allocating management threads: 2
2015-07-21 12:25:17,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] at least one sink does not exist
2015-07-21 12:25:17,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Tue Jul 21 12:24:20 PDT 2015
2015-07-21 12:25:17,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (1/2)
2015-07-21 12:25:17,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1437506655199_0004
2015-07-21 12:25:17,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0004/
2015-07-21 12:25:35,291 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0004_01_000003 is : 143
2015-07-21 12:25:35,340 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0004_01_000002 is : 143
2015-07-21 12:25:35,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0004_01_000004 is : 143
2015-07-21 12:25:35,866 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0004_01_000005 is : 143
2015-07-21 12:25:37,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2015-07-21 12:25:37,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1437506655199_0005
2015-07-21 12:25:37,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0005/
2015-07-21 12:25:51,340 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000002 is : 143
2015-07-21 12:25:51,392 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000003 is : 143
2015-07-21 12:25:51,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000004 is : 143
2015-07-21 12:25:51,728 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000005 is : 143
2015-07-21 12:25:57,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000006 is : 143
2015-07-21 12:26:03,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000007 is : 143
2015-07-21 12:26:10,122 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000008 is : 143
2015-07-21 12:26:16,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0005_01_000009 is : 143
2015-07-21 12:26:17,509 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] hadoop job job_1437506655199_0005 state at FAILED
2015-07-21 12:26:17,510 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] failure info: Task failed task_1437506655199_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2015-07-21 12:26:17,534 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] task completion events identify failed tasks
2015-07-21 12:26:17,535 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] task completion events count: 8
2015-07-21 12:26:17,536 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_m_000000_0, Status : SUCCEEDED
2015-07-21 12:26:17,536 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_m_000001_0, Status : SUCCEEDED
2015-07-21 12:26:17,537 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_m_000002_0, Status : SUCCEEDED
2015-07-21 12:26:17,537 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_m_000003_0, Status : SUCCEEDED
2015-07-21 12:26:17,537 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_r_000000_0, Status : FAILED
2015-07-21 12:26:17,537 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_r_000000_1, Status : FAILED
2015-07-21 12:26:17,537 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_r_000000_2, Status : FAILED
2015-07-21 12:26:17,537 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1437506655199_0005_r_000000_3, Status : TIPFAILED
2015-07-21 12:26:17,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping all jobs
2015-07-21 12:26:17,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping: (2/2) ...ckpoint/restartcheckpoint
2015-07-21 12:26:17,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping: (1/2)
2015-07-21 12:26:21,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopped all jobs
2015-07-21 12:26:21,031 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /tmp/hadoop-castillo/restartable/restartable/test/_temporary
2015-07-21 12:26:21,032 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2015-07-21 12:26:21,034 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] completed in: 01:03.942
2015-07-21 12:26:21,057 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:26:21,057 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:26:21,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2015-07-21 12:26:21,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 12:26:21,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:26:21,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting
2015-07-21 12:26:21,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:26:21,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2015-07-21 12:26:21,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] parallel execution of steps is enabled: true
2015-07-21 12:26:21,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executing total steps: 2
2015-07-21 12:26:21,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] allocating management threads: 2
2015-07-21 12:26:21,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] at least one sink is marked for delete
2015-07-21 12:26:21,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-21 12:26:21,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Tue Jul 21 12:25:35 PDT 2015
2015-07-21 12:26:21,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink oldest modified date: Tue Jul 21 12:25:35 PDT 2015
2015-07-21 12:26:21,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Tue Jul 21 12:24:20 PDT 2015
2015-07-21 12:26:21,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] skipping step: (1/2)
2015-07-21 12:26:21,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2015-07-21 12:26:21,321 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1437506655199_0006
2015-07-21 12:26:21,321 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0006/
2015-07-21 12:26:37,942 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0006_01_000004 is : 143
2015-07-21 12:26:38,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0006_01_000005 is : 143
2015-07-21 12:26:38,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0006_01_000003 is : 143
2015-07-21 12:26:38,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0006_01_000002 is : 143
2015-07-21 12:26:44,159 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0006_01_000006 is : 143
2015-07-21 12:26:45,344 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2015-07-21 12:26:45,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] completed in: 00:24.191
2015-07-21 12:26:45,366 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint
2015-07-21 12:26:45,397 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:26:45,398 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:26:45,407 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.003
2015-07-21 12:26:45,407 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-07-21 12:26:45,408 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/sink
2015-07-21 12:26:45,409 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/tap
2015-07-21 12:26:45,428 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:26:45,428 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:26:45,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-07-21 12:26:45,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 12:26:45,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:26:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 12:26:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:26:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint"]
2015-07-21 12:26:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-07-21 12:26:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2015-07-21 12:26:45,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 2
2015-07-21 12:26:45,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-07-21 12:26:45,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437506655199_0007
2015-07-21 12:26:45,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0007/
2015-07-21 12:27:01,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0007_01_000005 is : 143
2015-07-21 12:27:01,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0007_01_000004 is : 143
2015-07-21 12:27:02,087 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0007_01_000002 is : 143
2015-07-21 12:27:02,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0007_01_000003 is : 143
2015-07-21 12:27:03,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...eckpoint/simplecheckpoint
2015-07-21 12:27:03,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437506655199_0008
2015-07-21 12:27:03,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0008/
2015-07-21 12:27:19,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0008_01_000003 is : 143
2015-07-21 12:27:19,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0008_01_000002 is : 143
2015-07-21 12:27:19,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0008_01_000004 is : 143
2015-07-21 12:27:19,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0008_01_000005 is : 143
2015-07-21 12:27:25,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0008_01_000006 is : 143
2015-07-21 12:27:26,366 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint/_temporary
2015-07-21 12:27:26,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:40.854
2015-07-21 12:27:26,389 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint
2015-07-21 12:27:26,426 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:27:26,427 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:27:26,442 INFO planner.FlowPlanner (FlowPlanner.java:makeTempTap(767)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap"]
2015-07-21 12:27:26,483 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-07-21 12:27:26,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 12:27:26,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 12:27:26,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-07-21 12:27:26,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 12:27:26,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink"]
2015-07-21 12:27:26,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-07-21 12:27:26,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 2
2015-07-21 12:27:26,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 2
2015-07-21 12:27:26,525 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...termediate/checkpoint/tap
2015-07-21 12:27:26,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437506655199_0009
2015-07-21 12:27:26,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0009/
2015-07-21 12:27:43,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0009_01_000002 is : 143
2015-07-21 12:27:43,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0009_01_000003 is : 143
2015-07-21 12:27:43,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0009_01_000005 is : 143
2015-07-21 12:27:43,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0009_01_000004 is : 143
2015-07-21 12:27:44,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...ermediate/checkpoint/sink
2015-07-21 12:27:44,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437506655199_0010
2015-07-21 12:27:44,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64293/proxy/application_1437506655199_0010/
2015-07-21 12:28:24,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000002 is : 143
2015-07-21 12:28:24,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000003 is : 143
2015-07-21 12:28:24,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000004 is : 143
2015-07-21 12:28:24,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000005 is : 143
2015-07-21 12:28:24,495 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000006 is : 143
2015-07-21 12:28:24,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000007 is : 143
2015-07-21 12:28:30,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437506655199_0010_01_000008 is : 143
2015-07-21 12:28:31,293 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap/_temporary
2015-07-21 12:28:31,295 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink/_temporary
2015-07-21 12:28:31,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 01:04.769
2015-07-21 12:28:31,354 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink
2015-07-21 12:28:31,360 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap
2015-07-21 12:28:31,398 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:28:31,398 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:28:31,401 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testDuplicateCheckpoint/duplicatecheckpoint
2015-07-21 12:28:31,419 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:28:31,419 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:28:31,425 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/sink
2015-07-21 12:28:31,426 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/tap
2015-07-21 12:28:31,441 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:28:31,441 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:28:31,444 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/tap
2015-07-21 12:28:31,444 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/sink