2015-09-24 14:01:55,498 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 14:01:55,535 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.pipe.checkpoint.CheckpointPlatformTest, with platform: hadoop2-mr1
2015-09-24 14:01:55,556 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 14:02:07,535 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-09-24 14:02:08,175 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 14:02:12,510 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 14:02:12,848 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-09-24 14:02:13,112 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-09-24 14:02:13,346 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-09-24 14:02:13,583 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-09-24 14:02:30,734 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-09-24 14:02:30,847 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:02:30,848 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:02:30,911 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 31F8AF3D8D394AD0B8B94FA28D0C77F5
2015-09-24 14:02:30,989 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(797)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][7471111/test/]
2015-09-24 14:02:31,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.159
2015-09-24 14:02:31,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2015-09-24 14:02:31,116 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-09-24 14:02:31,287 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 14:02:31,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:02:31,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:02:31,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint"]
2015-09-24 14:02:31,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:02:31,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 3
2015-09-24 14:02:31,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 3
2015-09-24 14:02:31,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/3)
2015-09-24 14:02:32,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443117745205_0001
2015-09-24 14:02:32,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:62838/proxy/application_1443117745205_0001/
2015-09-24 14:03:12,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0001_01_000003 is : 143
2015-09-24 14:03:12,695 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0001_01_000004 is : 143
2015-09-24 14:03:12,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0001_01_000005 is : 143
2015-09-24 14:03:13,003 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0001_01_000002 is : 143
2015-09-24 14:03:14,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/3)
2015-09-24 14:03:14,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443117745205_0002
2015-09-24 14:03:14,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:62838/proxy/application_1443117745205_0002/
2015-09-24 14:03:53,786 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0002_01_000002 is : 143
2015-09-24 14:03:53,906 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0002_01_000003 is : 143
2015-09-24 14:03:53,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0002_01_000004 is : 143
2015-09-24 14:03:54,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0002_01_000005 is : 143
2015-09-24 14:04:11,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0002_01_000006 is : 143
2015-09-24 14:04:12,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (3/3) ...heckpoints/manycheckpoint
2015-09-24 14:04:12,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443117745205_0003
2015-09-24 14:04:12,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:62838/proxy/application_1443117745205_0003/
2015-09-24 14:04:46,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0003_01_000002 is : 143
2015-09-24 14:04:47,304 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint/_temporary
2015-09-24 14:04:47,307 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 02:16.006
2015-09-24 14:04:47,348 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint
2015-09-24 14:04:47,389 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:04:47,390 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:04:47,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2015-09-24 14:04:47,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-09-24 14:04:47,468 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-09-24 14:04:47,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting
2015-09-24 14:04:47,498 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:04:47,498 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2015-09-24 14:04:47,498 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] parallel execution of steps is enabled: true
2015-09-24 14:04:47,498 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executing total steps: 2
2015-09-24 14:04:47,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] allocating management threads: 2
2015-09-24 14:04:47,503 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] at least one sink does not exist
2015-09-24 14:04:47,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Thu Sep 24 14:02:30 EDT 2015
2015-09-24 14:04:47,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (1/2)
2015-09-24 14:04:47,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1443117745205_0004
2015-09-24 14:04:47,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://localhost:62838/proxy/application_1443117745205_0004/
2015-09-24 14:05:27,769 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0004_01_000004 is : 143
2015-09-24 14:05:27,815 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0004_01_000005 is : 143
2015-09-24 14:05:27,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0004_01_000003 is : 143
2015-09-24 14:05:28,209 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0004_01_000002 is : 143
2015-09-24 14:05:29,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2015-09-24 14:05:29,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1443117745205_0005
2015-09-24 14:05:29,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://localhost:62838/proxy/application_1443117745205_0005/
2015-09-24 14:06:09,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000004 is : 143
2015-09-24 14:06:09,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000005 is : 143
2015-09-24 14:06:09,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000002 is : 143
2015-09-24 14:06:09,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000003 is : 143
2015-09-24 14:06:27,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000006 is : 143
2015-09-24 14:06:44,718 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000007 is : 143
2015-09-24 14:07:02,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000008 is : 143
2015-09-24 14:07:20,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0005_01_000009 is : 143
2015-09-24 14:07:21,224 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] hadoop job job_1443117745205_0005 state at FAILED
2015-09-24 14:07:21,225 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] failure info: Task failed task_1443117745205_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2015-09-24 14:07:21,247 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] task completion events identify failed tasks
2015-09-24 14:07:21,247 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] task completion events count: 8
2015-09-24 14:07:21,248 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_m_000002_0, Status : SUCCEEDED
2015-09-24 14:07:21,248 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_m_000003_0, Status : SUCCEEDED
2015-09-24 14:07:21,248 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_m_000000_0, Status : SUCCEEDED
2015-09-24 14:07:21,249 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_m_000001_0, Status : SUCCEEDED
2015-09-24 14:07:21,249 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_r_000000_0, Status : FAILED
2015-09-24 14:07:21,249 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_r_000000_1, Status : FAILED
2015-09-24 14:07:21,249 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_r_000000_2, Status : FAILED
2015-09-24 14:07:21,249 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1443117745205_0005_r_000000_3, Status : TIPFAILED
2015-09-24 14:07:21,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping all jobs
2015-09-24 14:07:21,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping: (2/2) ...ckpoint/restartcheckpoint
2015-09-24 14:07:21,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping: (1/2)
2015-09-24 14:07:24,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopped all jobs
2015-09-24 14:07:24,659 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /tmp/hadoop-ryan/restartable/restartable/test/_temporary
2015-09-24 14:07:24,661 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2015-09-24 14:07:24,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] completed in: 02:37.161
2015-09-24 14:07:24,695 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:07:24,696 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:07:24,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2015-09-24 14:07:24,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-09-24 14:07:24,769 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-09-24 14:07:24,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting
2015-09-24 14:07:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:07:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2015-09-24 14:07:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] parallel execution of steps is enabled: true
2015-09-24 14:07:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executing total steps: 2
2015-09-24 14:07:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] allocating management threads: 2
2015-09-24 14:07:24,802 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] at least one sink is marked for delete
2015-09-24 14:07:24,803 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink oldest modified date: Wed Dec 31 18:59:59 EST 1969
2015-09-24 14:07:24,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Thu Sep 24 14:05:28 EDT 2015
2015-09-24 14:07:24,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink oldest modified date: Thu Sep 24 14:05:28 EDT 2015
2015-09-24 14:07:24,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Thu Sep 24 14:02:30 EDT 2015
2015-09-24 14:07:24,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] skipping step: (1/2)
2015-09-24 14:07:24,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2015-09-24 14:07:24,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1443117745205_0006
2015-09-24 14:07:24,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://localhost:62838/proxy/application_1443117745205_0006/
2015-09-24 14:08:04,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0006_01_000002 is : 143
2015-09-24 14:08:04,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0006_01_000005 is : 143
2015-09-24 14:08:04,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0006_01_000004 is : 143
2015-09-24 14:08:04,799 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0006_01_000003 is : 143
2015-09-24 14:08:22,512 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0006_01_000006 is : 143
2015-09-24 14:08:23,744 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2015-09-24 14:08:23,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] completed in: 00:58.941
2015-09-24 14:08:23,776 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint
2015-09-24 14:08:23,810 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:08:23,811 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:08:23,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.002
2015-09-24 14:08:23,820 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-09-24 14:08:23,820 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/tap
2015-09-24 14:08:23,821 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/sink
2015-09-24 14:08:23,843 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:08:23,844 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:08:23,916 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2015-09-24 14:08:23,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-09-24 14:08:23,920 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-09-24 14:08:23,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:08:23,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:08:23,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint"]
2015-09-24 14:08:23,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:08:23,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2015-09-24 14:08:23,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 2
2015-09-24 14:08:23,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-09-24 14:08:24,123 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443117745205_0007
2015-09-24 14:08:24,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:62838/proxy/application_1443117745205_0007/
2015-09-24 14:09:05,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0007_01_000004 is : 143
2015-09-24 14:09:05,736 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0007_01_000003 is : 143
2015-09-24 14:09:05,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0007_01_000005 is : 143
2015-09-24 14:09:06,089 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0007_01_000002 is : 143
2015-09-24 14:09:07,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...eckpoint/simplecheckpoint
2015-09-24 14:09:07,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443117745205_0008
2015-09-24 14:09:07,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:62838/proxy/application_1443117745205_0008/
2015-09-24 14:09:47,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0008_01_000002 is : 143
2015-09-24 14:09:47,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0008_01_000003 is : 143
2015-09-24 14:09:48,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0008_01_000005 is : 143
2015-09-24 14:09:48,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0008_01_000004 is : 143
2015-09-24 14:10:06,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0008_01_000006 is : 143
2015-09-24 14:10:07,358 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint/_temporary
2015-09-24 14:10:07,361 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 01:43.405
2015-09-24 14:10:07,381 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint
2015-09-24 14:10:07,406 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:10:07,406 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:10:07,417 INFO planner.FlowPlanner (FlowPlanner.java:makeTempTap(767)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap"]
2015-09-24 14:10:07,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-09-24 14:10:07,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-09-24 14:10:07,465 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-09-24 14:10:07,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-09-24 14:10:07,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:10:07,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink"]
2015-09-24 14:10:07,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-09-24 14:10:07,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 2
2015-09-24 14:10:07,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 2
2015-09-24 14:10:07,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...termediate/checkpoint/tap
2015-09-24 14:10:07,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1443117745205_0009
2015-09-24 14:10:07,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:62838/proxy/application_1443117745205_0009/
2015-09-24 14:10:47,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0009_01_000005 is : 143
2015-09-24 14:10:47,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0009_01_000002 is : 143
2015-09-24 14:10:47,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0009_01_000004 is : 143
2015-09-24 14:10:47,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0009_01_000003 is : 143
2015-09-24 14:10:49,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...ermediate/checkpoint/sink
2015-09-24 14:10:49,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1443117745205_0010
2015-09-24 14:10:49,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://localhost:62838/proxy/application_1443117745205_0010/
2015-09-24 14:11:10,888 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443117745205_0010_01_000008
2015-09-24 14:11:11,560 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443117745205_0010_01_000010
2015-09-24 14:11:34,605 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000005 is : 143
2015-09-24 14:11:34,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000006 is : 143
2015-09-24 14:11:34,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000007 is : 143
2015-09-24 14:11:34,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000004 is : 143
2015-09-24 14:11:34,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000002 is : 143
2015-09-24 14:11:35,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000003 is : 143
2015-09-24 14:11:53,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443117745205_0010_01_000011 is : 143
2015-09-24 14:11:55,081 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap/_temporary
2015-09-24 14:11:55,084 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink/_temporary
2015-09-24 14:11:55,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 01:47.586
2015-09-24 14:11:55,145 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink
2015-09-24 14:11:55,153 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap
2015-09-24 14:11:55,191 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:11:55,192 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:11:55,195 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testDuplicateCheckpoint/duplicatecheckpoint
2015-09-24 14:11:55,213 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:11:55,214 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:11:55,217 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/tap
2015-09-24 14:11:55,218 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/sink
2015-09-24 14:11:55,239 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:11:55,239 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:11:55,243 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/sink
2015-09-24 14:11:55,244 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/tap