2016-01-15 02:13:19,851 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 02:13:19,869 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.scheme.hadoop.WritableSequenceFilePlatformTest, with platform: hadoop2-mr1
2016-01-15 02:13:19,891 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-15 02:13:20,799 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-15 02:13:21,526 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-15 02:13:25,934 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-15 02:13:26,154 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-15 02:13:26,332 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-15 02:13:26,512 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-15 02:13:43,629 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 02:13:43,817 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:13:43,819 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 02:13:43,886 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: FDDAA6B45B0E4F67A176A20BF30D874C
2016-01-15 02:13:44,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2016-01-15 02:13:44,006 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:13:44,007 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:13:44,134 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:13:44,134 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 02:13:44,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-15 02:13:44,187 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:13:44,187 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:13:44,219 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:13:44,220 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 02:13:44,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-15 02:13:44,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:13:44,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:13:44,296 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 02:13:44,297 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] starting
2016-01-15 02:13:44,302 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] parallel execution of flows is enabled: true
2016-01-15 02:13:44,302 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] executing total flows: 3
2016-01-15 02:13:44,303 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] allocating management threads: 3
2016-01-15 02:13:44,304 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] starting flow: keyvalue
2016-01-15 02:13:44,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] at least one sink is marked for delete
2016-01-15 02:13:44,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 02:13:44,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] starting
2016-01-15 02:13:44,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 02:13:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] sink: Hfs["WritableSequenceFile[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/keyvalue"]
2016-01-15 02:13:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] parallel execution of steps is enabled: true
2016-01-15 02:13:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] executing total steps: 1
2016-01-15 02:13:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] allocating management threads: 1
2016-01-15 02:13:44,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] starting step: (1/1) ...orm/testWritable/keyvalue
2016-01-15 02:13:45,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] submitted hadoop job: job_1452824018128_0001
2016-01-15 02:13:45,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] tracking url: http://ip-10-167-78-165:40159/proxy/application_1452824018128_0001/
2016-01-15 02:14:03,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0001_01_000003 is : 143
2016-01-15 02:14:03,519 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0001_01_000005 is : 143
2016-01-15 02:14:03,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0001_01_000002 is : 143
2016-01-15 02:14:04,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0001_01_000004 is : 143
2016-01-15 02:14:05,777 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/keyvalue/_temporary
2016-01-15 02:14:05,779 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [keyvalue] completed in: 00:21.445, using cpu time: 00:06.640
2016-01-15 02:14:05,779 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] completed flow: keyvalue
2016-01-15 02:14:05,780 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] starting flow: value
2016-01-15 02:14:05,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] at least one sink is marked for delete
2016-01-15 02:14:05,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 02:14:05,780 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] starting flow: key
2016-01-15 02:14:05,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] at least one sink is marked for delete
2016-01-15 02:14:05,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-15 02:14:05,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] starting
2016-01-15 02:14:05,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] source: Hfs["WritableSequenceFile[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/keyvalue"]
2016-01-15 02:14:05,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] sink: Hfs["WritableSequenceFile[['line']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/value"]
2016-01-15 02:14:05,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] parallel execution of steps is enabled: true
2016-01-15 02:14:05,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] executing total steps: 1
2016-01-15 02:14:05,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] allocating management threads: 1
2016-01-15 02:14:05,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] starting
2016-01-15 02:14:05,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] starting step: (1/1) ...atform/testWritable/value
2016-01-15 02:14:05,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] source: Hfs["WritableSequenceFile[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/keyvalue"]
2016-01-15 02:14:05,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] sink: Hfs["WritableSequenceFile[['offset']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/key"]
2016-01-15 02:14:05,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] parallel execution of steps is enabled: true
2016-01-15 02:14:05,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] executing total steps: 1
2016-01-15 02:14:05,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] allocating management threads: 1
2016-01-15 02:14:05,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] starting step: (1/1) ...platform/testWritable/key
2016-01-15 02:14:06,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] submitted hadoop job: job_1452824018128_0002
2016-01-15 02:14:06,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] tracking url: http://ip-10-167-78-165:40159/proxy/application_1452824018128_0002/
2016-01-15 02:14:06,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] submitted hadoop job: job_1452824018128_0003
2016-01-15 02:14:06,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] tracking url: http://ip-10-167-78-165:40159/proxy/application_1452824018128_0003/
2016-01-15 02:14:26,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0002_01_000005 is : 143
2016-01-15 02:14:27,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0002_01_000003 is : 143
2016-01-15 02:14:27,571 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0002_01_000004 is : 143
2016-01-15 02:14:27,974 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0002_01_000002 is : 143
2016-01-15 02:14:29,626 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/value/_temporary
2016-01-15 02:14:29,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [value] completed in: 00:23.814, using cpu time: 00:04.690
2016-01-15 02:14:29,629 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] completed flow: value
2016-01-15 02:14:36,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0003_01_000005 is : 143
2016-01-15 02:14:37,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0003_01_000003 is : 143
2016-01-15 02:14:37,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0003_01_000002 is : 143
2016-01-15 02:14:38,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452824018128_0003_01_000004 is : 143
2016-01-15 02:14:39,242 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/writablesequencefileplatform/testWritable/key/_temporary
2016-01-15 02:14:39,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [key] completed in: 00:33.449, using cpu time: 00:04.680
2016-01-15 02:14:39,244 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [keyvalues] completed flow: key
2016-01-15 02:14:39,362 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/writablesequencefileplatform/testWritable/key
2016-01-15 02:14:39,376 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/writablesequencefileplatform/testWritable/keyvalue
2016-01-15 02:14:39,388 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/writablesequencefileplatform/testWritable/value