2016-05-18 12:09:20,001 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 12:09:20,018 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.tap.hadoop.HadoopMR1TapPlatformTest, with platform: hadoop2-mr1
2016-05-18 12:09:20,044 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 12:09:21,076 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 12:09:21,694 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 12:09:26,217 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 12:09:26,466 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 12:09:26,639 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 12:09:26,813 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 12:09:43,908 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 12:09:44,184 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:09:44,185 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 12:09:44,254 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: F32A8C1C0DF640C89F698A5832F82A5D
2016-05-18 12:09:44,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 12:09:44,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:09:44,365 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 12:09:44,479 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 12:09:44,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-18 12:09:44,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 12:09:44,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@3d3efc92"]["[]"]
2016-05-18 12:09:44,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-18 12:09:44,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-18 12:09:44,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-18 12:09:44,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...eredpartition/partitioned
2016-05-18 12:09:45,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463573378405_0001
2016-05-18 12:09:45,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:47253/proxy/application_1463573378405_0001/
2016-05-18 12:10:05,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0001_01_000003 is : 143
2016-05-18 12:10:06,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0001_01_000006 is : 143
2016-05-18 12:10:06,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0001_01_000004 is : 143
2016-05-18 12:10:06,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0001_01_000005 is : 143
2016-05-18 12:10:08,229 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/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned/_temporary
2016-05-18 12:10:08,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:23.742, using cpu time: 00:05.280
2016-05-18 12:10:08,251 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:10:08,251 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 12:10:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 12:10:08,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:10:08,293 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 12:10:08,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-18 12:10:08,326 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@3d3efc92"]["[]"]
2016-05-18 12:10:08,326 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final"]
2016-05-18 12:10:08,327 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-18 12:10:08,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-18 12:10:08,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-18 12:10:08,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...s/filteredpartition/final
2016-05-18 12:10:08,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463573378405_0002
2016-05-18 12:10:08,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:47253/proxy/application_1463573378405_0002/
2016-05-18 12:10:33,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0002_01_000002 is : 143
2016-05-18 12:10:33,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0002_01_000004 is : 143
2016-05-18 12:10:33,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0002_01_000003 is : 143
2016-05-18 12:10:34,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0002_01_000005 is : 143
2016-05-18 12:10:34,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0002_01_000006 is : 143
2016-05-18 12:10:35,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/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final/_temporary
2016-05-18 12:10:35,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:27.554, using cpu time: 00:05.290
2016-05-18 12:10:35,924 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/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final
2016-05-18 12:10:35,943 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/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned
2016-05-18 12:10:35,990 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:10:35,990 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 12:10:36,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 12:10:36,028 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:10:36,028 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 12:10:36,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-18 12:10:36,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 12:10:36,043 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@5d08cc4b"]["[]"]
2016-05-18 12:10:36,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-18 12:10:36,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-18 12:10:36,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-18 12:10:36,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...inedpartition/partitioned
2016-05-18 12:10:36,233 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463573378405_0003
2016-05-18 12:10:36,234 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:47253/proxy/application_1463573378405_0003/
2016-05-18 12:11:00,704 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0003_01_000006 is : 143
2016-05-18 12:11:01,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0003_01_000005 is : 143
2016-05-18 12:11:01,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0003_01_000002 is : 143
2016-05-18 12:11:02,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0003_01_000004 is : 143
2016-05-18 12:11:02,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0003_01_000003 is : 143
2016-05-18 12:11:03,459 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/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned/_temporary
2016-05-18 12:11:03,462 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:27.411, using cpu time: 00:05.330
2016-05-18 12:11:03,479 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:11:03,480 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 12:11:03,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 12:11:03,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:11:03,513 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 12:11:03,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-18 12:11:03,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@5d08cc4b"]["[]"]
2016-05-18 12:11:03,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final"]
2016-05-18 12:11:03,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-18 12:11:03,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-18 12:11:03,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-18 12:11:03,530 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...p/combinedpartition/final
2016-05-18 12:11:03,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463573378405_0004
2016-05-18 12:11:03,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:47253/proxy/application_1463573378405_0004/
2016-05-18 12:11:21,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0004_01_000002 is : 143
2016-05-18 12:11:22,274 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/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final/_temporary
2016-05-18 12:11:22,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:18.745, using cpu time: 00:00.820
2016-05-18 12:11:22,297 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/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final
2016-05-18 12:11:22,303 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/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned
2016-05-18 12:11:22,343 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:11:22,343 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 12:11:22,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 12:11:22,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:11:22,383 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 12:11:22,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-18 12:11:22,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 12:11:22,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@532b5d0"]["[]"]
2016-05-18 12:11:22,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-18 12:11:22,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-18 12:11:22,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-18 12:11:22,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...eredpartition/partitioned
2016-05-18 12:11:22,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463573378405_0005
2016-05-18 12:11:22,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:47253/proxy/application_1463573378405_0005/
2016-05-18 12:11:27,675 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463573378405_0004_01_000001
2016-05-18 12:11:46,800 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0005_01_000002 is : 143
2016-05-18 12:11:47,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0005_01_000003 is : 143
2016-05-18 12:11:47,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0005_01_000006 is : 143
2016-05-18 12:11:47,912 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0005_01_000005 is : 143
2016-05-18 12:11:48,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0005_01_000004 is : 143
2016-05-18 12:11:49,369 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/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned/_temporary
2016-05-18 12:11:49,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:26.968, using cpu time: 00:05.460
2016-05-18 12:11:49,387 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:11:49,387 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 12:11:49,419 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 12:11:49,420 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:11:49,421 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 12:11:49,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-18 12:11:49,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@532b5d0"]["[cascading.tap.partition.PartitionTapFilter@439740e3]"]
2016-05-18 12:11:49,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final"]
2016-05-18 12:11:49,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-18 12:11:49,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-18 12:11:49,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-18 12:11:49,447 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...l/filteredpartition/final
2016-05-18 12:11:49,569 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463573378405_0006
2016-05-18 12:11:49,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:47253/proxy/application_1463573378405_0006/
2016-05-18 12:12:17,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0006_01_000005 is : 143
2016-05-18 12:12:18,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0006_01_000006 is : 143
2016-05-18 12:12:18,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0006_01_000007 is : 143
2016-05-18 12:12:18,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0006_01_000004 is : 143
2016-05-18 12:12:18,974 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0006_01_000002 is : 143
2016-05-18 12:12:19,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463573378405_0006_01_000003 is : 143
2016-05-18 12:12:20,432 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/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final/_temporary
2016-05-18 12:12:20,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:30.985, using cpu time: 00:06.750
2016-05-18 12:12:20,459 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/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned
2016-05-18 12:12:20,478 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/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final