2016-01-14 19:31:31,105 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 19:31:31,131 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.tap.hadoop.HadoopMR1TapPlatformTest, with platform: hadoop2-mr1
2016-01-14 19:31:31,164 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-14 19:31:31,980 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 19:31:32,463 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 19:31:33,024 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 19:31:36,035 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 19:31:36,178 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 19:31:36,294 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 19:31:36,410 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 19:31:53,488 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 19:31:53,739 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:31:53,740 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 19:31:53,814 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 28E39FA68BE24D92B7BD7BA3607DA4F8
2016-01-14 19:31:53,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 19:31:53,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:31:53,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:31:54,026 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 19:31:54,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] starting
2016-01-14 19:31:54,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 19:31:54,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@57ddbfac"]
2016-01-14 19:31:54,029 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] parallel execution of steps is enabled: true
2016-01-14 19:31:54,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] executing total steps: 1
2016-01-14 19:31:54,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] allocating management threads: 1
2016-01-14 19:31:54,031 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] starting step: (1/1) ...inedpartition/partitioned
2016-01-14 19:31:54,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] submitted hadoop job: job_1452799907985_0001
2016-01-14 19:31:54,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] tracking url: http://ip-10-167-78-165.ec2.internal:55981/proxy/application_1452799907985_0001/
2016-01-14 19:32:12,781 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452799907985_0001_01_000003 is : 143
2016-01-14 19:32:12,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452799907985_0001_01_000002 is : 143
2016-01-14 19:32:13,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452799907985_0001_01_000006 is : 143
2016-01-14 19:32:13,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452799907985_0001_01_000004 is : 143
2016-01-14 19:32:13,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452799907985_0001_01_000005 is : 143
2016-01-14 19:32:14,806 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned/_temporary
2016-01-14 19:32:14,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [partition] completed in: 00:20.769, using cpu time: 00:05.160
2016-01-14 19:32:14,826 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 19:32:14,827 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 19:32:14,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 19:32:14,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 19:32:14,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 19:32:14,893 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] starting
2016-01-14 19:32:14,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@57ddbfac"]
2016-01-14 19:32:14,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final"]
2016-01-14 19:32:14,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] parallel execution of steps is enabled: true
2016-01-14 19:32:14,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] executing total steps: 1
2016-01-14 19:32:14,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] allocating management threads: 1
2016-01-14 19:32:14,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] starting step: (1/1) ...p/combinedpartition/final
2016-01-14 19:32:15,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] submitted hadoop job: job_1452799907985_0002
2016-01-14 19:32:15,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] tracking url: http://ip-10-167-78-165.ec2.internal:55981/proxy/application_1452799907985_0002/
2016-01-14 19:32:26,097 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452799907985_0002_01_000002 is : 143
2016-01-14 19:32:27,362 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final/_temporary
2016-01-14 19:32:27,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [copy] completed in: 00:12.467, using cpu time: 00:00.790
2016-01-14 19:32:27,397 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final
2016-01-14 19:32:27,404 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned