2016-05-17 22:44:07,616 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:44:07,640 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.tap.hadoop.HadoopMR1TapPlatformTest, with platform: hadoop2-mr1
2016-05-17 22:44:07,675 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-17 22:44:08,520 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-17 22:44:09,070 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 22:44:13,771 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-05-17 22:44:14,992 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-05-17 22:44:16,138 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-05-17 22:44:17,279 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-05-17 22:44:19,824 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 22:44:20,062 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:44:20,063 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-17 22:44:20,134 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 0B1D9D22A43540B5A92A982277670BF4
2016-05-17 22:44:20,236 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-17 22:44:20,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:44:20,239 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-17 22:44:20,353 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:44:20,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-17 22:44:20,354 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 22:44:20,355 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@2b08f716"]["[]"]
2016-05-17 22:44:20,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-17 22:44:20,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-17 22:44:20,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-17 22:44:20,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...eredpartition/partitioned
2016-05-17 22:44:20,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463525051937_0001
2016-05-17 22:44:20,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:55420/proxy/application_1463525051937_0001/
2016-05-17 22:44:38,857 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0001_01_000006 is : 143
2016-05-17 22:44:38,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0001_01_000002 is : 143
2016-05-17 22:44:39,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0001_01_000003 is : 143
2016-05-17 22:44:39,818 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0001_01_000005 is : 143
2016-05-17 22:44:40,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0001_01_000004 is : 143
2016-05-17 22:44:41,318 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned/_temporary
2016-05-17 22:44:41,324 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:20.955, using cpu time: 00:05.010
2016-05-17 22:44:41,347 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:44:41,347 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-17 22:44:41,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-17 22:44:41,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:44:41,444 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-17 22:44:41,480 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-17 22:44:41,480 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@2b08f716"]["[]"]
2016-05-17 22:44:41,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final"]
2016-05-17 22:44:41,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-17 22:44:41,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-17 22:44:41,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-17 22:44:41,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...s/filteredpartition/final
2016-05-17 22:44:41,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463525051937_0002
2016-05-17 22:44:41,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:55420/proxy/application_1463525051937_0002/
2016-05-17 22:44:59,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0002_01_000002 is : 143
2016-05-17 22:44:59,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0002_01_000003 is : 143
2016-05-17 22:45:00,304 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0002_01_000006 is : 143
2016-05-17 22:45:00,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0002_01_000005 is : 143
2016-05-17 22:45:00,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0002_01_000004 is : 143
2016-05-17 22:45:01,748 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final/_temporary
2016-05-17 22:45:01,750 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:20.266, using cpu time: 00:04.660
2016-05-17 22:45:01,782 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/partitioned
2016-05-17 22:45:01,801 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_NoFilters/filteredpartition/final
2016-05-17 22:45:01,836 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:45:01,837 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-17 22:45:01,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 22:45:01,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:45:01,876 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-17 22:45:01,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-17 22:45:01,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 22:45:01,892 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@53119ef"]["[]"]
2016-05-17 22:45:01,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-17 22:45:01,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-17 22:45:01,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-17 22:45:01,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...inedpartition/partitioned
2016-05-17 22:45:02,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463525051937_0003
2016-05-17 22:45:02,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:55420/proxy/application_1463525051937_0003/
2016-05-17 22:45:19,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0003_01_000006 is : 143
2016-05-17 22:45:19,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0003_01_000005 is : 143
2016-05-17 22:45:20,020 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0003_01_000002 is : 143
2016-05-17 22:45:20,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0003_01_000004 is : 143
2016-05-17 22:45:20,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0003_01_000003 is : 143
2016-05-17 22:45:21,554 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned/_temporary
2016-05-17 22:45:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:19.658, using cpu time: 00:04.800
2016-05-17 22:45:21,573 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:45:21,573 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-17 22:45:21,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 22:45:21,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:45:21,622 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-17 22:45:21,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-17 22:45:21,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@53119ef"]["[]"]
2016-05-17 22:45:21,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final"]
2016-05-17 22:45:21,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-17 22:45:21,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-17 22:45:21,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-17 22:45:21,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...p/combinedpartition/final
2016-05-17 22:45:21,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463525051937_0004
2016-05-17 22:45:21,797 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:55420/proxy/application_1463525051937_0004/
2016-05-17 22:45:32,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0004_01_000002 is : 143
2016-05-17 22:45:33,842 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final/_temporary
2016-05-17 22:45:33,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:12.206, using cpu time: 00:00.710
2016-05-17 22:45:33,865 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/partitioned
2016-05-17 22:45:33,883 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testCombinedPartitionTap/combinedpartition/final
2016-05-17 22:45:33,908 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:45:33,909 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-17 22:45:33,954 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 22:45:33,955 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:45:33,956 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-17 22:45:33,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting
2016-05-17 22:45:33,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] source: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 22:45:33,967 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] sink: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@52721b3a"]["[]"]
2016-05-17 22:45:33,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] parallel execution of steps is enabled: true
2016-05-17 22:45:33,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] executing total steps: 1
2016-05-17 22:45:33,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] allocating management threads: 1
2016-05-17 22:45:33,970 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] starting step: (1/1) ...eredpartition/partitioned
2016-05-17 22:45:34,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] submitted hadoop job: job_1463525051937_0005
2016-05-17 22:45:34,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] tracking url: http://ip-10-158-37-203:55420/proxy/application_1463525051937_0005/
2016-05-17 22:45:51,332 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0005_01_000005 is : 143
2016-05-17 22:45:51,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0005_01_000004 is : 143
2016-05-17 22:45:51,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0005_01_000003 is : 143
2016-05-17 22:45:52,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0005_01_000006 is : 143
2016-05-17 22:45:52,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0005_01_000002 is : 143
2016-05-17 22:45:53,448 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned/_temporary
2016-05-17 22:45:53,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [partition] completed in: 00:19.475, using cpu time: 00:04.520
2016-05-17 22:45:53,465 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:45:53,465 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-17 22:45:53,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 22:45:53,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:45:53,497 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-17 22:45:53,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting
2016-05-17 22:45:53,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] source: PartitionTap["Hfs["TextDelimited[['lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned"]"]["cascading.tap.partition.DelimitedPartition@52721b3a"]["[cascading.tap.partition.PartitionTapFilter@25c4eb0a]"]
2016-05-17 22:45:53,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] sink: Hfs["TextDelimited[['number', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final"]
2016-05-17 22:45:53,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] parallel execution of steps is enabled: true
2016-05-17 22:45:53,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] executing total steps: 1
2016-05-17 22:45:53,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] allocating management threads: 1
2016-05-17 22:45:53,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] starting step: (1/1) ...l/filteredpartition/final
2016-05-17 22:45:53,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] submitted hadoop job: job_1463525051937_0006
2016-05-17 22:45:53,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] tracking url: http://ip-10-158-37-203:55420/proxy/application_1463525051937_0006/
2016-05-17 22:46:13,544 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0006_01_000003 is : 143
2016-05-17 22:46:13,943 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0006_01_000005 is : 143
2016-05-17 22:46:13,984 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0006_01_000002 is : 143
2016-05-17 22:46:14,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0006_01_000006 is : 143
2016-05-17 22:46:14,613 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0006_01_000004 is : 143
2016-05-17 22:46:15,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463525051937_0006_01_000007 is : 143
2016-05-17 22:46:16,328 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final/_temporary
2016-05-17 22:46:16,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [copy] completed in: 00:22.811, using cpu time: 00:05.360
2016-05-17 22:46:16,351 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/final
2016-05-17 22:46:16,363 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/hadoopmr1tapplatform/testFilteredPartitionTap_Typical/filteredpartition/partitioned