2016-05-18 08:59:59,376 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 08:59:59,397 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.tap.hadoop.HadoopMR1TapPlatformTest, with platform: hadoop2-mr1
2016-05-18 08:59:59,434 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 09:00:00,416 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 09:00:01,133 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 09:00:05,419 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-05-18 09:00:05,649 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-05-18 09:00:05,823 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-05-18 09:00:06,000 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-05-18 09:00:23,113 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 09:00:23,391 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:00:23,392 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 09:00:23,460 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 0ACB2CD5548A473386EFA9F9C04DF32F
2016-05-18 09:00:23,618 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 09:00:23,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:00:23,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:00:23,739 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 09:00:23,740 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-18 09:00:23,741 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-05-18 09:00:23,741 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@6fa68d6c"]["[]"]
2016-05-18 09:00:23,741 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-18 09:00:23,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-18 09:00:23,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-18 09:00:23,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...eredpartition/partitioned
2016-05-18 09:00:24,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463562017612_0001
2016-05-18 09:00:24,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:50395/proxy/application_1463562017612_0001/
2016-05-18 09:00:43,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0001_01_000006 is : 143
2016-05-18 09:00:44,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0001_01_000005 is : 143
2016-05-18 09:00:44,561 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0001_01_000002 is : 143
2016-05-18 09:00:44,648 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0001_01_000003 is : 143
2016-05-18 09:00:44,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0001_01_000004 is : 143
2016-05-18 09:00:46,000 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned/_temporary
2016-05-18 09:00:46,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:22.254, using cpu time: 00:05.870
2016-05-18 09:00:46,023 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:00:46,023 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 09:00:46,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 09:00:46,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:00:46,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:00:46,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-18 09:00:46,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@6fa68d6c"]["[]"]
2016-05-18 09:00:46,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final"]
2016-05-18 09:00:46,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-18 09:00:46,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-18 09:00:46,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-18 09:00:46,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...s/filteredpartition/final
2016-05-18 09:00:46,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463562017612_0002
2016-05-18 09:00:46,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:50395/proxy/application_1463562017612_0002/
2016-05-18 09:00:51,157 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463562017612_0001_01_000001
2016-05-18 09:01:09,884 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0002_01_000003 is : 143
2016-05-18 09:01:10,251 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0002_01_000006 is : 143
2016-05-18 09:01:10,294 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0002_01_000002 is : 143
2016-05-18 09:01:10,636 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0002_01_000004 is : 143
2016-05-18 09:01:10,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0002_01_000005 is : 143
2016-05-18 09:01:12,040 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final/_temporary
2016-05-18 09:01:12,043 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:25.936, using cpu time: 00:05.610
2016-05-18 09:01:12,086 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final
2016-05-18 09:01:12,102 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned
2016-05-18 09:01:12,144 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:01:12,145 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 09:01:12,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 09:01:12,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:01:12,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:01:12,195 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-18 09:01:12,195 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-05-18 09:01:12,196 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@3f8875c2"]["[]"]
2016-05-18 09:01:12,196 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-18 09:01:12,196 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-18 09:01:12,196 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-18 09:01:12,197 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...inedpartition/partitioned
2016-05-18 09:01:12,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463562017612_0003
2016-05-18 09:01:12,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:50395/proxy/application_1463562017612_0003/
2016-05-18 09:01:35,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0003_01_000003 is : 143
2016-05-18 09:01:36,174 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0003_01_000004 is : 143
2016-05-18 09:01:36,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0003_01_000005 is : 143
2016-05-18 09:01:36,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0003_01_000006 is : 143
2016-05-18 09:01:37,993 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned/_temporary
2016-05-18 09:01:37,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:25.794, using cpu time: 00:05.570
2016-05-18 09:01:38,015 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:01:38,015 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 09:01:38,052 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 09:01:38,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:01:38,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:01:38,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-18 09:01:38,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@3f8875c2"]["[]"]
2016-05-18 09:01:38,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final"]
2016-05-18 09:01:38,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-18 09:01:38,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-18 09:01:38,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-18 09:01:38,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...p/combinedpartition/final
2016-05-18 09:01:38,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463562017612_0004
2016-05-18 09:01:38,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:50395/proxy/application_1463562017612_0004/
2016-05-18 09:01:55,865 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final/_temporary
2016-05-18 09:01:55,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:17.795, using cpu time: 00:00.880
2016-05-18 09:01:55,887 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final
2016-05-18 09:01:55,893 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned
2016-05-18 09:01:55,931 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:01:55,932 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 09:01:55,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 09:01:55,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:01:55,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:01:55,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-18 09:01:55,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-05-18 09:01:55,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@14a5e7d1"]["[]"]
2016-05-18 09:01:55,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-18 09:01:55,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-18 09:01:55,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-18 09:01:55,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...eredpartition/partitioned
2016-05-18 09:01:56,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463562017612_0005
2016-05-18 09:01:56,142 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:50395/proxy/application_1463562017612_0005/
2016-05-18 09:02:20,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0005_01_000003 is : 143
2016-05-18 09:02:20,754 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0005_01_000002 is : 143
2016-05-18 09:02:20,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0005_01_000004 is : 143
2016-05-18 09:02:21,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0005_01_000005 is : 143
2016-05-18 09:02:21,062 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0005_01_000006 is : 143
2016-05-18 09:02:22,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned/_temporary
2016-05-18 09:02:22,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:26.242, using cpu time: 00:05.700
2016-05-18 09:02:22,235 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:02:22,235 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 09:02:22,270 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 09:02:22,273 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:02:22,273 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:02:22,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-18 09:02:22,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@14a5e7d1"]["[cascading.tap.partition.PartitionTapFilter@4d7e8d70]"]
2016-05-18 09:02:22,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final"]
2016-05-18 09:02:22,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-18 09:02:22,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-18 09:02:22,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-18 09:02:22,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...l/filteredpartition/final
2016-05-18 09:02:22,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463562017612_0006
2016-05-18 09:02:22,437 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:50395/proxy/application_1463562017612_0006/
2016-05-18 09:02:46,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0006_01_000003 is : 143
2016-05-18 09:02:47,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0006_01_000002 is : 143
2016-05-18 09:02:48,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0006_01_000006 is : 143
2016-05-18 09:02:49,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0006_01_000005 is : 143
2016-05-18 09:02:49,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0006_01_000004 is : 143
2016-05-18 09:02:49,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562017612_0006_01_000007 is : 143
2016-05-18 09:02:51,150 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final/_temporary
2016-05-18 09:02:51,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:28.855, using cpu time: 00:06.680
2016-05-18 09:02:51,176 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final
2016-05-18 09:02:51,189 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned