2016-05-18 11:52:11,915 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 11:52:11,945 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.pipe.checkpoint.CheckpointPlatformTest, with platform: hadoop2-mr1
2016-05-18 11:52:11,978 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 11:52:13,156 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
2016-05-18 11:52:13,854 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 11:52:18,308 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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.
2016-05-18 11:52:18,532 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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.
2016-05-18 11:52:18,747 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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.
2016-05-18 11:52:18,926 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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.
2016-05-18 11:52:36,020 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 11:52:36,116 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:52:36,117 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:52:36,181 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4F0C713948BE44D0878D0CB8FA148AF7
2016-05-18 11:52:36,256 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(798)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][64514543/test/]
2016-05-18 11:52:36,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.132
2016-05-18 11:52:36,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 11:52:36,361 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 11:52:36,518 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 11:52:36,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 11:52:36,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 11:52:36,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint"]
2016-05-18 11:52:36,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 11:52:36,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 3
2016-05-18 11:52:36,522 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 3
2016-05-18 11:52:36,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/3)
2016-05-18 11:52:37,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463572350518_0001
2016-05-18 11:52:37,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0001/
2016-05-18 11:52:55,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0001_01_000003 is : 143
2016-05-18 11:52:55,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0001_01_000002 is : 143
2016-05-18 11:52:56,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0001_01_000005 is : 143
2016-05-18 11:52:56,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0001_01_000004 is : 143
2016-05-18 11:52:57,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/3)
2016-05-18 11:52:57,915 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463572350518_0002
2016-05-18 11:52:57,915 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0002/
2016-05-18 11:53:21,819 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0002_01_000002 is : 143
2016-05-18 11:53:21,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0002_01_000003 is : 143
2016-05-18 11:53:22,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0002_01_000004 is : 143
2016-05-18 11:53:22,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0002_01_000005 is : 143
2016-05-18 11:53:28,423 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0002_01_000006 is : 143
2016-05-18 11:53:29,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (3/3) ...heckpoints/manycheckpoint
2016-05-18 11:53:29,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463572350518_0003
2016-05-18 11:53:29,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0003/
2016-05-18 11:53:46,913 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0003_01_000002 is : 143
2016-05-18 11:53:48,141 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint/_temporary
2016-05-18 11:53:48,144 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 01:11.612, using cpu time: 00:11.740
2016-05-18 11:53:48,180 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint
2016-05-18 11:53:48,220 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:53:48,220 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:53:48,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-18 11:53:48,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 11:53:48,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 11:53:48,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] starting
2016-05-18 11:53:48,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 11:53:48,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2016-05-18 11:53:48,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] parallel execution of steps is enabled: true
2016-05-18 11:53:48,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] executing total steps: 2
2016-05-18 11:53:48,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] allocating management threads: 2
2016-05-18 11:53:48,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] at least one sink does not exist
2016-05-18 11:53:48,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] source modification date at: Wed May 18 11:52:36 UTC 2016
2016-05-18 11:53:48,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] starting step: (1/2)
2016-05-18 11:53:48,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] submitted hadoop job: job_1463572350518_0004
2016-05-18 11:53:48,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0004/
2016-05-18 11:54:11,070 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0004_01_000003 is : 143
2016-05-18 11:54:11,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0004_01_000002 is : 143
2016-05-18 11:54:11,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0004_01_000004 is : 143
2016-05-18 11:54:11,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0004_01_000005 is : 143
2016-05-18 11:54:12,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2016-05-18 11:54:13,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] submitted hadoop job: job_1463572350518_0005
2016-05-18 11:54:13,129 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0005/
2016-05-18 11:54:35,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000002 is : 143
2016-05-18 11:54:36,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000003 is : 143
2016-05-18 11:54:36,508 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000004 is : 143
2016-05-18 11:54:36,582 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000005 is : 143
2016-05-18 11:54:42,863 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000006 is : 143
2016-05-18 11:54:50,190 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000007 is : 143
2016-05-18 11:54:56,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000008 is : 143
2016-05-18 11:55:03,757 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0005_01_000009 is : 143
2016-05-18 11:55:04,885 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] hadoop job job_1463572350518_0005 state at FAILED
2016-05-18 11:55:04,887 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] failure info: Task failed task_1463572350518_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2016-05-18 11:55:04,912 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] task completion events identify failed tasks
2016-05-18 11:55:04,912 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] task completion events count: 8
2016-05-18 11:55:04,913 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_m_000000_0, Status : SUCCEEDED
2016-05-18 11:55:04,913 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_m_000001_0, Status : SUCCEEDED
2016-05-18 11:55:04,913 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_m_000002_0, Status : SUCCEEDED
2016-05-18 11:55:04,913 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_m_000003_0, Status : SUCCEEDED
2016-05-18 11:55:04,914 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_r_000000_0, Status : FAILED
2016-05-18 11:55:04,914 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_r_000000_1, Status : FAILED
2016-05-18 11:55:04,914 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_r_000000_2, Status : FAILED
2016-05-18 11:55:04,914 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [restartable] event = Task Id : attempt_1463572350518_0005_r_000000_3, Status : TIPFAILED
2016-05-18 11:55:04,945 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] stopping all jobs
2016-05-18 11:55:04,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] stopping: (2/2) ...ckpoint/restartcheckpoint
2016-05-18 11:55:04,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] stopping: (1/2)
2016-05-18 11:55:08,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] stopped all jobs
2016-05-18 11:55:08,306 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /tmp/hadoop-teamcity/restartable/restartable/test/_temporary
2016-05-18 11:55:08,308 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2016-05-18 11:55:08,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] completed in: 01:19.984, using cpu time: 00:08.800
2016-05-18 11:55:08,331 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:55:08,331 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:55:08,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-05-18 11:55:08,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 11:55:08,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 11:55:08,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] starting
2016-05-18 11:55:08,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 11:55:08,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2016-05-18 11:55:08,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] parallel execution of steps is enabled: true
2016-05-18 11:55:08,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] executing total steps: 2
2016-05-18 11:55:08,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] allocating management threads: 2
2016-05-18 11:55:08,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] at least one sink is marked for delete
2016-05-18 11:55:08,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 11:55:08,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] source modification date at: Wed May 18 11:54:11 UTC 2016
2016-05-18 11:55:08,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] sink oldest modified date: Wed May 18 11:54:11 UTC 2016
2016-05-18 11:55:08,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] source modification date at: Wed May 18 11:52:36 UTC 2016
2016-05-18 11:55:08,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] skipping step: (1/2)
2016-05-18 11:55:08,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2016-05-18 11:55:08,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] submitted hadoop job: job_1463572350518_0006
2016-05-18 11:55:08,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0006/
2016-05-18 11:55:27,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0006_01_000003 is : 143
2016-05-18 11:55:27,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0006_01_000002 is : 143
2016-05-18 11:55:27,779 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0006_01_000004 is : 143
2016-05-18 11:55:28,316 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0006_01_000005 is : 143
2016-05-18 11:55:34,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0006_01_000006 is : 143
2016-05-18 11:55:35,523 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2016-05-18 11:55:35,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [restartable] completed in: 00:27.084, using cpu time: 00:05.710
2016-05-18 11:55:35,545 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint
2016-05-18 11:55:35,577 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:55:35,577 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:55:35,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.002
2016-05-18 11:55:35,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 11:55:35,589 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/tap
2016-05-18 11:55:35,590 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/sink
2016-05-18 11:55:35,613 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:55:35,614 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:55:35,704 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-05-18 11:55:35,707 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 11:55:35,707 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 11:55:35,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 11:55:35,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 11:55:35,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint"]
2016-05-18 11:55:35,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: true
2016-05-18 11:55:35,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-18 11:55:35,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 2
2016-05-18 11:55:35,741 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-18 11:55:36,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463572350518_0007
2016-05-18 11:55:36,062 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0007/
2016-05-18 11:55:41,585 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463572350518_0006_01_000001
2016-05-18 11:55:58,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0007_01_000003 is : 143
2016-05-18 11:55:59,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0007_01_000004 is : 143
2016-05-18 11:55:59,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0007_01_000005 is : 143
2016-05-18 11:55:59,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0007_01_000002 is : 143
2016-05-18 11:56:00,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...eckpoint/simplecheckpoint
2016-05-18 11:56:00,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_1463572350518_0008
2016-05-18 11:56:00,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0008/
2016-05-18 11:56:23,549 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0008_01_000004 is : 143
2016-05-18 11:56:23,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0008_01_000003 is : 143
2016-05-18 11:56:24,286 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0008_01_000002 is : 143
2016-05-18 11:56:24,574 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0008_01_000005 is : 143
2016-05-18 11:56:30,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0008_01_000006 is : 143
2016-05-18 11:56:31,882 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint/_temporary
2016-05-18 11:56:31,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:56.142, using cpu time: 00:10.940
2016-05-18 11:56:31,901 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint
2016-05-18 11:56:31,924 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:56:31,925 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:56:31,937 INFO planner.FlowPlanner (FlowPlanner.java:makeTempTap(768)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap"]
2016-05-18 11:56:31,980 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-05-18 11:56:31,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 11:56:31,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 11:56:32,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 11:56:32,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 11:56:32,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink"]
2016-05-18 11:56:32,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] parallel execution of steps is enabled: true
2016-05-18 11:56:32,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] executing total steps: 2
2016-05-18 11:56:32,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] allocating management threads: 2
2016-05-18 11:56:32,017 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/2) ...termediate/checkpoint/tap
2016-05-18 11:56:32,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463572350518_0009
2016-05-18 11:56:32,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0009/
2016-05-18 11:56:54,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0009_01_000002 is : 143
2016-05-18 11:56:55,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0009_01_000003 is : 143
2016-05-18 11:56:55,291 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0009_01_000004 is : 143
2016-05-18 11:56:55,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0009_01_000005 is : 143
2016-05-18 11:56:56,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/2) ...ermediate/checkpoint/sink
2016-05-18 11:56:56,642 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463572350518_0010
2016-05-18 11:56:56,642 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:60648/proxy/application_1463572350518_0010/
2016-05-18 11:57:24,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000002 is : 143
2016-05-18 11:57:24,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000003 is : 143
2016-05-18 11:57:24,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000007 is : 143
2016-05-18 11:57:24,494 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000006 is : 143
2016-05-18 11:57:24,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000005 is : 143
2016-05-18 11:57:24,959 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000004 is : 143
2016-05-18 11:57:31,245 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463572350518_0010_01_000008 is : 143
2016-05-18 11:57:32,431 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap/_temporary
2016-05-18 11:57:32,433 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink/_temporary
2016-05-18 11:57:32,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [] completed in: 01:00.415, using cpu time: 00:12.320
2016-05-18 11:57:32,479 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap
2016-05-18 11:57:32,491 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink
2016-05-18 11:57:32,511 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:57:32,511 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:57:32,515 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testDuplicateCheckpoint/duplicatecheckpoint
2016-05-18 11:57:32,531 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:57:32,531 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:57:32,535 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/tap
2016-05-18 11:57:32,536 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/sink
2016-05-18 11:57:32,554 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 11:57:32,554 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 11:57:32,562 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/tap
2016-05-18 11:57:32,562 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/sink