2016-01-14 23:55:57,331 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 23:55:57,362 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.pipe.checkpoint.CheckpointPlatformTest, with platform: hadoop2-mr1
2016-01-14 23:55:57,396 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-14 23:55:58,302 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-01-14 23:55:58,993 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 23:55:59,651 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 23:56:02,822 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.
2016-01-14 23:56:02,981 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.
2016-01-14 23:56:03,101 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.
2016-01-14 23:56:03,214 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.
2016-01-14 23:56:15,045 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 23:56:16,112 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 23:56:16,113 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 23:56:20,300 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 23:56:20,399 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:56:20,401 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:56:20,468 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: F113E860786742FDA655A4EDA35FB96E
2016-01-14 23:56:20,534 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(797)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][719846431/test/]
2016-01-14 23:56:20,637 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.133
2016-01-14 23:56:20,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-01-14 23:56:20,641 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'
2016-01-14 23:56:20,794 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 23:56:20,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:56:20,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:56:20,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint"]
2016-01-14 23:56:20,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-14 23:56:20,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 3
2016-01-14 23:56:20,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 3
2016-01-14 23:56:20,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/3)
2016-01-14 23:56:21,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452815774798_0001
2016-01-14 23:56:21,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0001/
2016-01-14 23:56:38,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0001_01_000005 is : 143
2016-01-14 23:56:38,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0001_01_000002 is : 143
2016-01-14 23:56:38,916 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0001_01_000003 is : 143
2016-01-14 23:56:39,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0001_01_000004 is : 143
2016-01-14 23:56:40,569 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/3)
2016-01-14 23:56:40,766 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452815774798_0002
2016-01-14 23:56:40,766 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0002/
2016-01-14 23:56:57,159 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0002_01_000003 is : 143
2016-01-14 23:56:57,397 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0002_01_000002 is : 143
2016-01-14 23:56:57,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0002_01_000005 is : 143
2016-01-14 23:56:57,751 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0002_01_000004 is : 143
2016-01-14 23:57:03,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0002_01_000006 is : 143
2016-01-14 23:57:04,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (3/3) ...heckpoints/manycheckpoint
2016-01-14 23:57:04,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452815774798_0003
2016-01-14 23:57:04,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0003/
2016-01-14 23:57:15,818 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0003_01_000002 is : 143
2016-01-14 23:57:17,068 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint/_temporary
2016-01-14 23:57:17,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:56.264, using cpu time: 00:10.760
2016-01-14 23:57:17,116 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testManyCheckpoints/manycheckpoint
2016-01-14 23:57:17,149 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:57:17,150 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:57:17,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 23:57:17,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 23:57:17,228 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'
2016-01-14 23:57:17,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting
2016-01-14 23:57:17,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:57:17,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2016-01-14 23:57:17,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] parallel execution of steps is enabled: true
2016-01-14 23:57:17,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executing total steps: 2
2016-01-14 23:57:17,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] allocating management threads: 2
2016-01-14 23:57:17,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] at least one sink does not exist
2016-01-14 23:57:17,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Thu Jan 14 23:56:20 UTC 2016
2016-01-14 23:57:17,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (1/2)
2016-01-14 23:57:17,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1452815774798_0004
2016-01-14 23:57:17,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0004/
2016-01-14 23:57:33,688 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0004_01_000002 is : 143
2016-01-14 23:57:33,920 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0004_01_000003 is : 143
2016-01-14 23:57:34,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0004_01_000004 is : 143
2016-01-14 23:57:34,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0004_01_000005 is : 143
2016-01-14 23:57:35,354 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2016-01-14 23:57:35,550 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1452815774798_0005
2016-01-14 23:57:35,551 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0005/
2016-01-14 23:57:51,757 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000002 is : 143
2016-01-14 23:57:51,819 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000004 is : 143
2016-01-14 23:57:51,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000003 is : 143
2016-01-14 23:57:51,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000005 is : 143
2016-01-14 23:57:58,094 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000006 is : 143
2016-01-14 23:58:04,086 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000007 is : 143
2016-01-14 23:58:10,376 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000008 is : 143
2016-01-14 23:58:17,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0005_01_000009 is : 143
2016-01-14 23:58:18,299 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] hadoop job job_1452815774798_0005 state at FAILED
2016-01-14 23:58:18,303 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] failure info: Task failed task_1452815774798_0005_r_000000
Job failed as tasks failed. failedMaps:0 failedReduces:1
2016-01-14 23:58:18,328 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] task completion events identify failed tasks
2016-01-14 23:58:18,328 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] task completion events count: 8
2016-01-14 23:58:18,329 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_m_000000_0, Status : SUCCEEDED
2016-01-14 23:58:18,329 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_m_000002_0, Status : SUCCEEDED
2016-01-14 23:58:18,329 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_m_000001_0, Status : SUCCEEDED
2016-01-14 23:58:18,329 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_m_000003_0, Status : SUCCEEDED
2016-01-14 23:58:18,330 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_r_000000_0, Status : FAILED
2016-01-14 23:58:18,330 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_r_000000_1, Status : FAILED
2016-01-14 23:58:18,330 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_r_000000_2, Status : FAILED
2016-01-14 23:58:18,330 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [restartable] event = Task Id : attempt_1452815774798_0005_r_000000_3, Status : TIPFAILED
2016-01-14 23:58:18,362 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping all jobs
2016-01-14 23:58:18,363 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping: (2/2) ...ckpoint/restartcheckpoint
2016-01-14 23:58:18,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopping: (1/2)
2016-01-14 23:58:21,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] stopped all jobs
2016-01-14 23:58:21,861 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /tmp/hadoop-teamcity/restartable/restartable/test/_temporary
2016-01-14 23:58:21,862 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2016-01-14 23:58:21,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] completed in: 01:04.594, using cpu time: 00:08.590
2016-01-14 23:58:21,883 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:58:21,883 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:58:21,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-14 23:58:21,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 23:58:21,954 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'
2016-01-14 23:58:21,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting
2016-01-14 23:58:21,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:58:21,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint"]
2016-01-14 23:58:21,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] parallel execution of steps is enabled: true
2016-01-14 23:58:21,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] executing total steps: 2
2016-01-14 23:58:21,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] allocating management threads: 2
2016-01-14 23:58:21,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] at least one sink is marked for delete
2016-01-14 23:58:21,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 23:58:21,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Thu Jan 14 23:57:34 UTC 2016
2016-01-14 23:58:21,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] sink oldest modified date: Thu Jan 14 23:57:34 UTC 2016
2016-01-14 23:58:21,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] source modification date at: Thu Jan 14 23:56:20 UTC 2016
2016-01-14 23:58:21,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] skipping step: (1/2)
2016-01-14 23:58:21,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] starting step: (2/2) ...ckpoint/restartcheckpoint
2016-01-14 23:58:22,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] submitted hadoop job: job_1452815774798_0006
2016-01-14 23:58:22,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0006/
2016-01-14 23:58:38,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0006_01_000005 is : 143
2016-01-14 23:58:38,190 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0006_01_000003 is : 143
2016-01-14 23:58:38,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0006_01_000004 is : 143
2016-01-14 23:58:38,585 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0006_01_000002 is : 143
2016-01-14 23:58:45,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0006_01_000006 is : 143
2016-01-14 23:58:46,407 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint/_temporary
2016-01-14 23:58:46,408 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [restartable] completed in: 00:24.415, using cpu time: 00:05.570
2016-01-14 23:58:46,428 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testRestartCheckpoint/restartcheckpoint
2016-01-14 23:58:46,454 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:58:46,455 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:58:46,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.002
2016-01-14 23:58:46,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:58:46,464 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/sink
2016-01-14 23:58:46,465 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointBeforeEvery/failcheckpointevery/tap
2016-01-14 23:58:46,484 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:58:46,484 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:58:46,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-01-14 23:58:46,547 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 23:58:46,547 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'
2016-01-14 23:58:46,572 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:58:46,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:58:46,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint"]
2016-01-14 23:58:46,574 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2016-01-14 23:58:46,574 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2016-01-14 23:58:46,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 2
2016-01-14 23:58:46,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 23:58:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452815774798_0007
2016-01-14 23:58:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0007/
2016-01-14 23:59:02,913 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0007_01_000003 is : 143
2016-01-14 23:59:02,981 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0007_01_000002 is : 143
2016-01-14 23:59:03,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0007_01_000005 is : 143
2016-01-14 23:59:03,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0007_01_000004 is : 143
2016-01-14 23:59:04,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...eckpoint/simplecheckpoint
2016-01-14 23:59:04,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1452815774798_0008
2016-01-14 23:59:04,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0008/
2016-01-14 23:59:20,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0008_01_000002 is : 143
2016-01-14 23:59:20,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0008_01_000003 is : 143
2016-01-14 23:59:21,034 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0008_01_000005 is : 143
2016-01-14 23:59:21,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0008_01_000004 is : 143
2016-01-14 23:59:26,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0008_01_000006 is : 143
2016-01-14 23:59:28,082 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint/_temporary
2016-01-14 23:59:28,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:41.505, using cpu time: 00:09.800
2016-01-14 23:59:28,102 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpoint/simplecheckpoint
2016-01-14 23:59:28,126 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:59:28,126 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:59:28,139 INFO planner.FlowPlanner (FlowPlanner.java:makeTempTap(767)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap"]
2016-01-14 23:59:28,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-14 23:59:28,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 23:59:28,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:59:28,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 23:59:28,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:59:28,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink"]
2016-01-14 23:59:28,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2016-01-14 23:59:28,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 2
2016-01-14 23:59:28,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 2
2016-01-14 23:59:28,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...termediate/checkpoint/tap
2016-01-14 23:59:28,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452815774798_0009
2016-01-14 23:59:28,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0009/
2016-01-14 23:59:44,772 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0009_01_000005 is : 143
2016-01-14 23:59:44,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0009_01_000002 is : 143
2016-01-14 23:59:44,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0009_01_000004 is : 143
2016-01-14 23:59:45,085 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0009_01_000003 is : 143
2016-01-14 23:59:46,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...ermediate/checkpoint/sink
2016-01-14 23:59:46,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452815774798_0010
2016-01-14 23:59:46,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165:47650/proxy/application_1452815774798_0010/
2016-01-15 00:00:06,861 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000006 is : 143
2016-01-15 00:00:06,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000004 is : 143
2016-01-15 00:00:07,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000007 is : 143
2016-01-15 00:00:07,241 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000003 is : 143
2016-01-15 00:00:07,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000005 is : 143
2016-01-15 00:00:07,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000002 is : 143
2016-01-15 00:00:13,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452815774798_0010_01_000008 is : 143
2016-01-15 00:00:14,460 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap/_temporary
2016-01-15 00:00:14,462 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink/_temporary
2016-01-15 00:00:14,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:46.214, using cpu time: 00:12.070
2016-01-15 00:00:14,510 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/sink
2016-01-15 00:00:14,515 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testSimpleCheckpointTextIntermediate/checkpoint/tap
2016-01-15 00:00:14,541 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:00:14,541 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:00:14,545 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testDuplicateCheckpoint/duplicatecheckpoint
2016-01-15 00:00:14,560 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:00:14,561 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:00:14,563 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/tap
2016-01-15 00:00:14,564 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpoint/failcheckpoint/sink
2016-01-15 00:00:14,579 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:00:14,579 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:00:14,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/sink
2016-01-15 00:00:14,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/checkpointplatform/testFailCheckpointDeclaredFields/failcheckpointdeclared/tap