2015-08-14 03:22:08,435 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 03:22:08,502 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 03:22:08,502 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.FieldedPipesPlatformTest
2015-08-14 03:22:08,550 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 03:22:09,464 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
2015-08-14 03:22:10,227 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 03:22:10,824 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 03:22:14,821 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.
2015-08-14 03:22:15,042 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.
2015-08-14 03:22:15,216 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.
2015-08-14 03:22:15,395 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.
2015-08-14 03:22:32,506 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 03:22:32,655 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:22:32,657 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:22:32,668 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 2482A309C22046F98833B787CC064250
2015-08-14 03:22:32,923 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 03:22:32,925 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:22:32,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:22:32,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex"]
2015-08-14 03:22:32,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:22:32,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:22:32,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:22:32,929 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/filtercomplex
2015-08-14 03:22:33,940 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0001
2015-08-14 03:22:33,940 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0001/
2015-08-14 03:22:47,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0001_01_000002 is : 143
2015-08-14 03:22:47,321 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0001_01_000003 is : 143
2015-08-14 03:22:47,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0001_01_000005 is : 143
2015-08-14 03:22:47,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0001_01_000004 is : 143
2015-08-14 03:22:55,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0001_01_000006 is : 143
2015-08-14 03:22:56,494 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex/_temporary
2015-08-14 03:22:56,552 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filtercomplex
2015-08-14 03:22:56,600 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:22:56,601 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:22:56,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:22:56,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:22:56,648 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain"]
2015-08-14 03:22:56,649 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:22:56,649 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:22:56,649 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:22:56,650 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/simplechain
2015-08-14 03:22:56,925 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0002
2015-08-14 03:22:56,926 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0002/
2015-08-14 03:23:10,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0002_01_000003 is : 143
2015-08-14 03:23:10,633 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0002_01_000005 is : 143
2015-08-14 03:23:10,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0002_01_000002 is : 143
2015-08-14 03:23:10,857 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0002_01_000004 is : 143
2015-08-14 03:23:17,323 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0002_01_000006 is : 143
2015-08-14 03:23:18,598 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain/_temporary
2015-08-14 03:23:18,632 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplechain
2015-08-14 03:23:18,668 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:23:18,669 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:23:18,696 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:23:18,697 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:23:18,698 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple"]
2015-08-14 03:23:18,698 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:23:18,698 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:23:18,698 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:23:18,699 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/simple
2015-08-14 03:23:18,935 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0003
2015-08-14 03:23:18,935 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0003/
2015-08-14 03:23:32,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0003_01_000003 is : 143
2015-08-14 03:23:32,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0003_01_000002 is : 143
2015-08-14 03:23:32,563 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0003_01_000004 is : 143
2015-08-14 03:23:32,643 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0003_01_000005 is : 143
2015-08-14 03:23:39,360 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0003_01_000006 is : 143
2015-08-14 03:23:40,653 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple/_temporary
2015-08-14 03:23:40,712 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simple
2015-08-14 03:23:40,792 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:23:40,792 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:23:40,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-14 03:23:40,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:23:40,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:23:40,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge"]
2015-08-14 03:23:40,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-14 03:23:40,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-14 03:23:40,826 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-14 03:23:40,827 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-08-14 03:23:41,043 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439522547003_0004
2015-08-14 03:23:41,044 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0004/
2015-08-14 03:23:56,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000003 is : 143
2015-08-14 03:23:56,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000002 is : 143
2015-08-14 03:23:56,748 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000007 is : 143
2015-08-14 03:23:56,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000006 is : 143
2015-08-14 03:23:56,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000004 is : 143
2015-08-14 03:23:56,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000005 is : 143
2015-08-14 03:24:03,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0004_01_000008 is : 143
2015-08-14 03:24:04,916 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge/_temporary
2015-08-14 03:24:04,972 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemerge
2015-08-14 03:24:05,129 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:24:05,129 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:24:05,162 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:24:05,163 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:24:05,164 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach"]
2015-08-14 03:24:05,164 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:24:05,164 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:24:05,164 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:24:05,166 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/chaineach
2015-08-14 03:24:05,389 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0005
2015-08-14 03:24:05,390 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0005/
2015-08-14 03:24:19,405 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0005_01_000003 is : 143
2015-08-14 03:24:19,501 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0005_01_000002 is : 143
2015-08-14 03:24:19,541 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0005_01_000005 is : 143
2015-08-14 03:24:19,598 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0005_01_000004 is : 143
2015-08-14 03:24:27,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0005_01_000006 is : 143
2015-08-14 03:24:28,318 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach/_temporary
2015-08-14 03:24:28,346 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chaineach
2015-08-14 03:24:28,377 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:24:28,378 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:24:28,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:24:28,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:24:28,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator"]
2015-08-14 03:24:28,407 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:24:28,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:24:28,408 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:24:28,409 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/generatoraggregator
2015-08-14 03:24:28,601 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0006
2015-08-14 03:24:28,601 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0006/
2015-08-14 03:24:41,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0006_01_000002 is : 143
2015-08-14 03:24:41,579 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0006_01_000003 is : 143
2015-08-14 03:24:42,224 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0006_01_000004 is : 143
2015-08-14 03:24:42,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0006_01_000005 is : 143
2015-08-14 03:24:48,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0006_01_000006 is : 143
2015-08-14 03:24:50,078 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator/_temporary
2015-08-14 03:24:50,105 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/generatoraggregator
2015-08-14 03:24:50,160 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:24:50,161 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:24:50,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-14 03:24:50,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:24:50,208 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:24:50,209 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:24:50,209 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree"]
2015-08-14 03:24:50,210 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-14 03:24:50,210 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-14 03:24:50,210 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-14 03:24:50,212 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-08-14 03:24:50,410 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439522547003_0007
2015-08-14 03:24:50,410 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0007/
2015-08-14 03:25:09,237 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000003 is : 143
2015-08-14 03:25:09,483 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000002 is : 143
2015-08-14 03:25:09,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000004 is : 143
2015-08-14 03:25:09,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000007 is : 143
2015-08-14 03:25:09,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000005 is : 143
2015-08-14 03:25:09,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000010 is : 143
2015-08-14 03:25:09,960 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000006 is : 143
2015-08-14 03:25:09,994 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000008 is : 143
2015-08-14 03:25:10,050 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000009 is : 143
2015-08-14 03:25:16,417 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0007_01_000011 is : 143
2015-08-14 03:25:17,685 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree/_temporary
2015-08-14 03:25:17,712 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemergethree
2015-08-14 03:25:17,743 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:25:17,744 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:25:17,793 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-14 03:25:17,794 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:25:17,795 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1"]
2015-08-14 03:25:17,796 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2"]
2015-08-14 03:25:17,796 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-08-14 03:25:17,797 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 3
2015-08-14 03:25:17,798 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 3
2015-08-14 03:25:17,800 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-08-14 03:25:17,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0008
2015-08-14 03:25:17,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0008/
2015-08-14 03:25:30,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0008_01_000002 is : 143
2015-08-14 03:25:30,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0008_01_000003 is : 143
2015-08-14 03:25:31,466 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0008_01_000004 is : 143
2015-08-14 03:25:31,571 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0008_01_000005 is : 143
2015-08-14 03:25:32,861 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...pesplatform/nonsafesplit1
2015-08-14 03:25:32,861 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...pesplatform/nonsafesplit2
2015-08-14 03:25:33,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0009
2015-08-14 03:25:33,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0009/
2015-08-14 03:25:33,112 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0010
2015-08-14 03:25:33,112 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0010/
2015-08-14 03:25:47,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0009_01_000003 is : 143
2015-08-14 03:25:48,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0009_01_000002 is : 143
2015-08-14 03:25:48,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0009_01_000004 is : 143
2015-08-14 03:25:48,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0009_01_000005 is : 143
2015-08-14 03:25:54,980 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0010_01_000004 is : 143
2015-08-14 03:25:55,012 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0010_01_000002 is : 143
2015-08-14 03:25:55,890 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0010_01_000005 is : 143
2015-08-14 03:25:56,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0010_01_000003 is : 143
2015-08-14 03:25:57,360 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1/_temporary
2015-08-14 03:25:57,362 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2/_temporary
2015-08-14 03:25:57,422 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit2
2015-08-14 03:25:57,435 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit1
2015-08-14 03:25:57,467 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:25:57,467 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:25:57,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting
2015-08-14 03:25:57,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:25:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2"]
2015-08-14 03:25:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1"]
2015-08-14 03:25:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] parallel execution is enabled: true
2015-08-14 03:25:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting jobs: 3
2015-08-14 03:25:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] allocating threads: 3
2015-08-14 03:25:57,509 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (1/3)
2015-08-14 03:25:57,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439522547003_0011
2015-08-14 03:25:57,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0011/
2015-08-14 03:26:11,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0011_01_000003 is : 143
2015-08-14 03:26:11,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0011_01_000002 is : 143
2015-08-14 03:26:11,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0011_01_000004 is : 143
2015-08-14 03:26:11,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0011_01_000005 is : 143
2015-08-14 03:26:18,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0011_01_000006 is : 143
2015-08-14 03:26:19,562 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (3/3) ...edpipesplatform/splitout2
2015-08-14 03:26:19,562 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (2/3) ...edpipesplatform/splitout1
2015-08-14 03:26:19,777 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439522547003_0012
2015-08-14 03:26:19,777 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0012/
2015-08-14 03:26:19,786 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439522547003_0013
2015-08-14 03:26:19,786 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0013/
2015-08-14 03:26:32,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0012_01_000002 is : 143
2015-08-14 03:26:38,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0013_01_000002 is : 143
2015-08-14 03:26:40,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0012_01_000003 is : 143
2015-08-14 03:26:41,502 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1/_temporary
2015-08-14 03:26:41,504 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2/_temporary
2015-08-14 03:26:41,595 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout2
2015-08-14 03:26:41,601 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout1
2015-08-14 03:26:41,629 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:26:41,630 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:26:41,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-14 03:26:41,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:26:41,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1"]
2015-08-14 03:26:41,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2"]
2015-08-14 03:26:41,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-08-14 03:26:41,660 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 2
2015-08-14 03:26:41,660 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 2
2015-08-14 03:26:41,661 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/2) ...eldedpipesplatform/split2
2015-08-14 03:26:41,664 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/2) ...eldedpipesplatform/split1
2015-08-14 03:26:41,891 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0014
2015-08-14 03:26:41,891 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0014/
2015-08-14 03:26:41,916 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0015
2015-08-14 03:26:41,917 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0015/
2015-08-14 03:27:00,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0014_01_000004 is : 143
2015-08-14 03:27:01,021 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0014_01_000003 is : 143
2015-08-14 03:27:01,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0014_01_000002 is : 143
2015-08-14 03:27:01,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0014_01_000005 is : 143
2015-08-14 03:27:03,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0015_01_000002 is : 143
2015-08-14 03:27:03,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0015_01_000003 is : 143
2015-08-14 03:27:04,382 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0015_01_000005 is : 143
2015-08-14 03:27:04,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0015_01_000004 is : 143
2015-08-14 03:27:05,757 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2/_temporary
2015-08-14 03:27:05,758 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1/_temporary
2015-08-14 03:27:05,813 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/split1
2015-08-14 03:27:05,824 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/split2
2015-08-14 03:27:05,875 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:27:05,876 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:27:05,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 03:27:05,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:27:05,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged"]
2015-08-14 03:27:05,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 03:27:05,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 2
2015-08-14 03:27:05,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 2
2015-08-14 03:27:05,910 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-08-14 03:27:06,096 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439522547003_0016
2015-08-14 03:27:06,096 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0016/
2015-08-14 03:27:21,915 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0016_01_000002 is : 143
2015-08-14 03:27:21,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0016_01_000003 is : 143
2015-08-14 03:27:22,270 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0016_01_000004 is : 143
2015-08-14 03:27:22,340 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0016_01_000005 is : 143
2015-08-14 03:27:23,627 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...latform/splitsourcemerged
2015-08-14 03:27:23,798 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439522547003_0017
2015-08-14 03:27:23,798 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0017/
2015-08-14 03:27:36,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0017_01_000002 is : 143
2015-08-14 03:27:36,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0017_01_000003 is : 143
2015-08-14 03:27:37,299 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0017_01_000005 is : 143
2015-08-14 03:27:37,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0017_01_000004 is : 143
2015-08-14 03:27:44,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0017_01_000006 is : 143
2015-08-14 03:27:45,334 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged/_temporary
2015-08-14 03:27:45,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemerged
2015-08-14 03:27:45,384 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:27:45,384 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:27:45,398 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:27:45,398 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:27:45,398 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy"]
2015-08-14 03:27:45,398 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:27:45,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:27:45,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:27:45,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/copy
2015-08-14 03:27:45,578 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0018
2015-08-14 03:27:45,578 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0018/
2015-08-14 03:27:58,943 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0018_01_000003 is : 143
2015-08-14 03:27:59,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0018_01_000002 is : 143
2015-08-14 03:27:59,341 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0018_01_000005 is : 143
2015-08-14 03:27:59,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0018_01_000004 is : 143
2015-08-14 03:28:00,774 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy/_temporary
2015-08-14 03:28:00,810 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/copy
2015-08-14 03:28:00,848 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:28:00,849 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:28:00,874 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:28:00,875 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:28:00,875 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/none"]
2015-08-14 03:28:00,875 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:28:00,875 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:28:00,875 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:28:00,876 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/none
2015-08-14 03:28:01,047 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0019
2015-08-14 03:28:01,047 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0019/
2015-08-14 03:28:13,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0019_01_000003 is : 143
2015-08-14 03:28:14,007 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0019_01_000002 is : 143
2015-08-14 03:28:14,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0019_01_000004 is : 143
2015-08-14 03:28:14,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0019_01_000005 is : 143
2015-08-14 03:28:21,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0019_01_000006 is : 143
2015-08-14 03:28:22,556 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/none/_temporary
2015-08-14 03:28:22,596 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/none
2015-08-14 03:28:22,621 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:28:22,622 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:28:22,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:28:22,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:28:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap"]
2015-08-14 03:28:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:28:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:28:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:28:22,648 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/swap
2015-08-14 03:28:22,820 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0020
2015-08-14 03:28:22,821 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0020/
2015-08-14 03:28:36,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0020_01_000003 is : 143
2015-08-14 03:28:36,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0020_01_000002 is : 143
2015-08-14 03:28:36,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0020_01_000005 is : 143
2015-08-14 03:28:36,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0020_01_000004 is : 143
2015-08-14 03:28:43,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0020_01_000006 is : 143
2015-08-14 03:28:44,771 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap/_temporary
2015-08-14 03:28:44,796 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/swap
2015-08-14 03:28:44,835 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:28:44,835 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:28:44,854 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:28:44,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:28:44,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter"]
2015-08-14 03:28:44,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:28:44,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:28:44,855 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:28:44,856 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/logicfilter
2015-08-14 03:28:45,024 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0021
2015-08-14 03:28:45,024 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0021/
2015-08-14 03:28:58,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0021_01_000002 is : 143
2015-08-14 03:28:58,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0021_01_000003 is : 143
2015-08-14 03:28:58,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0021_01_000004 is : 143
2015-08-14 03:28:58,829 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0021_01_000005 is : 143
2015-08-14 03:29:00,106 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter/_temporary
2015-08-14 03:29:00,138 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/logicfilter
2015-08-14 03:29:00,195 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:29:00,196 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:29:00,216 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:29:00,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 03:29:00,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped"]
2015-08-14 03:29:00,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:29:00,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:29:00,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:29:00,218 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/ungrouped
2015-08-14 03:29:00,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0022
2015-08-14 03:29:00,399 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0022/
2015-08-14 03:29:13,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0022_01_000006 is : 143
2015-08-14 03:29:14,519 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0022_01_000004 is : 143
2015-08-14 03:29:14,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0022_01_000003 is : 143
2015-08-14 03:29:14,627 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0022_01_000002 is : 143
2015-08-14 03:29:14,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0022_01_000005 is : 143
2015-08-14 03:29:16,137 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped/_temporary
2015-08-14 03:29:16,187 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped
2015-08-14 03:29:16,228 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:29:16,229 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:29:16,284 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 03:29:16,284 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:29:16,284 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second"]
2015-08-14 03:29:16,284 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third"]
2015-08-14 03:29:16,285 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first"]
2015-08-14 03:29:16,285 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 03:29:16,285 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 3
2015-08-14 03:29:16,285 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 3
2015-08-14 03:29:16,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/3) ...latform/chainedtaps/first
2015-08-14 03:29:16,450 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439522547003_0023
2015-08-14 03:29:16,450 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0023/
2015-08-14 03:29:29,584 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0023_01_000002 is : 143
2015-08-14 03:29:29,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0023_01_000003 is : 143
2015-08-14 03:29:30,174 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0023_01_000004 is : 143
2015-08-14 03:29:30,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0023_01_000005 is : 143
2015-08-14 03:29:37,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0023_01_000006 is : 143
2015-08-14 03:29:38,332 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (2/3) ...atform/chainedtaps/second
2015-08-14 03:29:38,495 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439522547003_0024
2015-08-14 03:29:38,495 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0024/
2015-08-14 03:29:51,690 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0024_01_000002 is : 143
2015-08-14 03:29:51,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0024_01_000003 is : 143
2015-08-14 03:29:52,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0024_01_000005 is : 143
2015-08-14 03:29:52,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0024_01_000004 is : 143
2015-08-14 03:29:58,908 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0024_01_000006 is : 143
2015-08-14 03:30:00,169 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (3/3) ...latform/chainedtaps/third
2015-08-14 03:30:00,351 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439522547003_0025
2015-08-14 03:30:00,351 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0025/
2015-08-14 03:30:13,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0025_01_000004 is : 143
2015-08-14 03:30:13,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0025_01_000002 is : 143
2015-08-14 03:30:14,094 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0025_01_000003 is : 143
2015-08-14 03:30:14,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0025_01_000005 is : 143
2015-08-14 03:30:20,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0025_01_000006 is : 143
2015-08-14 03:30:21,724 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first/_temporary
2015-08-14 03:30:21,726 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second/_temporary
2015-08-14 03:30:21,727 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third/_temporary
2015-08-14 03:30:21,751 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/third
2015-08-14 03:30:21,757 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/first
2015-08-14 03:30:21,763 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/second
2015-08-14 03:30:21,789 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:30:21,790 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:30:21,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:30:21,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:30:21,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall"]
2015-08-14 03:30:21,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:30:21,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-08-14 03:30:21,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-08-14 03:30:21,828 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-14 03:30:22,002 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0026
2015-08-14 03:30:22,002 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0026/
2015-08-14 03:30:35,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0026_01_000005 is : 143
2015-08-14 03:30:35,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0026_01_000002 is : 143
2015-08-14 03:30:35,908 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0026_01_000003 is : 143
2015-08-14 03:30:36,015 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0026_01_000004 is : 143
2015-08-14 03:30:42,395 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0026_01_000006 is : 143
2015-08-14 03:30:43,658 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...edpipesplatform/filterall
2015-08-14 03:30:43,840 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0027
2015-08-14 03:30:43,841 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0027/
2015-08-14 03:30:56,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0027_01_000002 is : 143
2015-08-14 03:31:03,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0027_01_000003 is : 143
2015-08-14 03:31:05,022 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall/_temporary
2015-08-14 03:31:05,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filterall
2015-08-14 03:31:05,067 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:31:05,068 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:31:05,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 03:31:05,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:31:05,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename"]
2015-08-14 03:31:05,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 03:31:05,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 2
2015-08-14 03:31:05,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 2
2015-08-14 03:31:05,102 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-08-14 03:31:05,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439522547003_0028
2015-08-14 03:31:05,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0028/
2015-08-14 03:31:18,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0028_01_000003 is : 143
2015-08-14 03:31:18,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0028_01_000002 is : 143
2015-08-14 03:31:18,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0028_01_000005 is : 143
2015-08-14 03:31:18,982 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0028_01_000004 is : 143
2015-08-14 03:31:20,302 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...splitsourcemergedsamename
2015-08-14 03:31:20,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439522547003_0029
2015-08-14 03:31:20,484 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0029/
2015-08-14 03:31:34,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0029_01_000005 is : 143
2015-08-14 03:31:34,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0029_01_000004 is : 143
2015-08-14 03:31:34,502 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0029_01_000003 is : 143
2015-08-14 03:31:34,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0029_01_000002 is : 143
2015-08-14 03:31:41,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0029_01_000006 is : 143
2015-08-14 03:31:42,583 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename/_temporary
2015-08-14 03:31:42,607 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename
2015-08-14 03:31:42,636 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:31:42,637 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:31:42,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting
2015-08-14 03:31:42,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:31:42,670 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:31:42,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic"]
2015-08-14 03:31:42,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] parallel execution is enabled: true
2015-08-14 03:31:42,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting jobs: 1
2015-08-14 03:31:42,671 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] allocating threads: 1
2015-08-14 03:31:42,673 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] starting step: (1/1) ...grouping-nondeterministic
2015-08-14 03:31:42,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] submitted hadoop job: job_1439522547003_0030
2015-08-14 03:31:42,854 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0030/
2015-08-14 03:31:57,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000006 is : 143
2015-08-14 03:31:57,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000007 is : 143
2015-08-14 03:31:58,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000004 is : 143
2015-08-14 03:31:58,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000005 is : 143
2015-08-14 03:31:58,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000003 is : 143
2015-08-14 03:31:58,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000002 is : 143
2015-08-14 03:32:05,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0030_01_000008 is : 143
2015-08-14 03:32:06,941 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic/_temporary
2015-08-14 03:32:06,965 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic
2015-08-14 03:32:06,990 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:32:06,990 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:32:07,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:32:07,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 03:32:07,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon"]
2015-08-14 03:32:07,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:32:07,007 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:32:07,007 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:32:07,008 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/ungroupedanon
2015-08-14 03:32:07,191 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0031
2015-08-14 03:32:07,191 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0031/
2015-08-14 03:32:21,155 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0031_01_000003 is : 143
2015-08-14 03:32:21,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0031_01_000002 is : 143
2015-08-14 03:32:21,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0031_01_000006 is : 143
2015-08-14 03:32:21,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0031_01_000005 is : 143
2015-08-14 03:32:21,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0031_01_000004 is : 143
2015-08-14 03:32:22,966 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon/_temporary
2015-08-14 03:32:23,003 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungroupedanon
2015-08-14 03:32:23,037 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:32:23,038 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:32:23,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:32:23,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:32:23,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup"]
2015-08-14 03:32:23,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:32:23,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-08-14 03:32:23,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-08-14 03:32:23,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-14 03:32:23,278 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0032
2015-08-14 03:32:23,279 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0032/
2015-08-14 03:32:36,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0032_01_000003 is : 143
2015-08-14 03:32:36,775 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0032_01_000002 is : 143
2015-08-14 03:32:37,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0032_01_000004 is : 143
2015-08-14 03:32:37,085 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0032_01_000005 is : 143
2015-08-14 03:32:44,095 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0032_01_000006 is : 143
2015-08-14 03:32:45,351 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...dpipesplatform/groupgroup
2015-08-14 03:32:45,516 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0033
2015-08-14 03:32:45,516 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0033/
2015-08-14 03:32:57,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0033_01_000002 is : 143
2015-08-14 03:33:05,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0033_01_000003 is : 143
2015-08-14 03:33:06,459 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup/_temporary
2015-08-14 03:33:06,484 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/groupgroup
2015-08-14 03:33:06,511 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:33:06,512 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:33:06,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting
2015-08-14 03:33:06,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:33:06,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup"]
2015-08-14 03:33:06,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] parallel execution is enabled: true
2015-08-14 03:33:06,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting jobs: 2
2015-08-14 03:33:06,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] allocating threads: 2
2015-08-14 03:33:06,556 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (2/2)
2015-08-14 03:33:06,730 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1439522547003_0034
2015-08-14 03:33:06,730 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0034/
2015-08-14 03:33:20,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0034_01_000003 is : 143
2015-08-14 03:33:20,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0034_01_000002 is : 143
2015-08-14 03:33:21,076 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0034_01_000006 is : 143
2015-08-14 03:33:21,141 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0034_01_000004 is : 143
2015-08-14 03:33:21,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0034_01_000005 is : 143
2015-08-14 03:33:27,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0034_01_000007 is : 143
2015-08-14 03:33:29,187 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (1/2) .../samemergethreechaingroup
2015-08-14 03:33:29,385 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1439522547003_0035
2015-08-14 03:33:29,386 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0035/
2015-08-14 03:33:44,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000002 is : 143
2015-08-14 03:33:44,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000003 is : 143
2015-08-14 03:33:45,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000004 is : 143
2015-08-14 03:33:45,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000005 is : 143
2015-08-14 03:33:45,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000007 is : 143
2015-08-14 03:33:45,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000006 is : 143
2015-08-14 03:33:51,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0035_01_000008 is : 143
2015-08-14 03:33:52,796 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup/_temporary
2015-08-14 03:33:52,821 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup
2015-08-14 03:33:52,850 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:33:52,850 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:33:52,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:33:52,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:33:52,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace"]
2015-08-14 03:33:52,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:33:52,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:33:52,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:33:52,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/replace
2015-08-14 03:33:53,043 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0036
2015-08-14 03:33:53,043 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0036/
2015-08-14 03:34:05,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0036_01_000002 is : 143
2015-08-14 03:34:06,197 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0036_01_000003 is : 143
2015-08-14 03:34:06,642 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0036_01_000004 is : 143
2015-08-14 03:34:06,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0036_01_000005 is : 143
2015-08-14 03:34:07,937 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace/_temporary
2015-08-14 03:34:07,970 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/replace
2015-08-14 03:34:08,023 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:34:08,024 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:34:08,039 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:34:08,039 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/extra+lower+upper.txt"]
2015-08-14 03:34:08,039 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size"]
2015-08-14 03:34:08,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:34:08,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:34:08,040 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:34:08,041 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/ungrouped_size
2015-08-14 03:34:08,212 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0037
2015-08-14 03:34:08,212 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0037/
2015-08-14 03:34:21,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0037_01_000005 is : 143
2015-08-14 03:34:22,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0037_01_000004 is : 143
2015-08-14 03:34:22,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0037_01_000002 is : 143
2015-08-14 03:34:22,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0037_01_000003 is : 143
2015-08-14 03:34:23,655 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size/_temporary
2015-08-14 03:34:23,691 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped_size
2015-08-14 03:34:23,724 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:34:23,725 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:34:23,739 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:34:23,739 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:34:23,739 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter"]
2015-08-14 03:34:23,739 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:34:23,740 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:34:23,740 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:34:23,741 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/filter
2015-08-14 03:34:23,923 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0038
2015-08-14 03:34:23,923 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0038/
2015-08-14 03:34:37,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0038_01_000002 is : 143
2015-08-14 03:34:37,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0038_01_000003 is : 143
2015-08-14 03:34:37,655 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0038_01_000004 is : 143
2015-08-14 03:34:37,751 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0038_01_000005 is : 143
2015-08-14 03:34:39,033 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter/_temporary
2015-08-14 03:34:39,067 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filter
2015-08-14 03:34:39,103 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:34:39,104 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:34:39,125 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting
2015-08-14 03:34:39,126 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]]]
2015-08-14 03:34:39,126 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat"]
2015-08-14 03:34:39,126 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] parallel execution is enabled: true
2015-08-14 03:34:39,126 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting jobs: 1
2015-08-14 03:34:39,126 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] allocating threads: 1
2015-08-14 03:34:39,128 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] starting step: (1/1) ...pesplatform/complexconcat
2015-08-14 03:34:39,298 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] submitted hadoop job: job_1439522547003_0039
2015-08-14 03:34:39,298 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0039/
2015-08-14 03:34:53,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000002 is : 143
2015-08-14 03:34:53,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000003 is : 143
2015-08-14 03:34:54,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000005 is : 143
2015-08-14 03:34:54,223 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000006 is : 143
2015-08-14 03:34:54,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000004 is : 143
2015-08-14 03:34:54,505 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000007 is : 143
2015-08-14 03:35:00,505 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0039_01_000008 is : 143
2015-08-14 03:35:01,771 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat/_temporary
2015-08-14 03:35:01,797 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/complexconcat
2015-08-14 03:35:01,827 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:35:01,828 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:35:01,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-14 03:35:01,870 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:35:01,870 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1"]
2015-08-14 03:35:01,870 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2"]
2015-08-14 03:35:01,870 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-08-14 03:35:01,871 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 3
2015-08-14 03:35:01,871 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 3
2015-08-14 03:35:01,873 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-08-14 03:35:02,052 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0040
2015-08-14 03:35:02,052 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0040/
2015-08-14 03:35:15,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0040_01_000003 is : 143
2015-08-14 03:35:15,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0040_01_000002 is : 143
2015-08-14 03:35:16,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0040_01_000004 is : 143
2015-08-14 03:35:16,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0040_01_000005 is : 143
2015-08-14 03:35:22,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0040_01_000006 is : 143
2015-08-14 03:35:23,974 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...dpipesplatform/splitcomp1
2015-08-14 03:35:23,974 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...dpipesplatform/splitcomp2
2015-08-14 03:35:24,215 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0041
2015-08-14 03:35:24,215 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0041/
2015-08-14 03:35:24,227 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439522547003_0042
2015-08-14 03:35:24,227 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0042/
2015-08-14 03:35:37,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0041_01_000002 is : 143
2015-08-14 03:35:42,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0042_01_000002 is : 143
2015-08-14 03:35:44,239 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1/_temporary
2015-08-14 03:35:44,240 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2/_temporary
2015-08-14 03:35:44,284 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp2
2015-08-14 03:35:44,291 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp1
2015-08-14 03:35:44,315 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:35:44,315 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:35:44,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 03:35:44,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:35:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup"]
2015-08-14 03:35:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 03:35:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 03:35:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 03:35:44,332 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/nogroup
2015-08-14 03:35:44,571 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439522547003_0043
2015-08-14 03:35:44,571 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50.ec2.internal:54399/proxy/application_1439522547003_0043/
2015-08-14 03:35:58,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0043_01_000005 is : 143
2015-08-14 03:35:58,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0043_01_000004 is : 143
2015-08-14 03:35:58,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0043_01_000003 is : 143
2015-08-14 03:35:58,456 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439522547003_0043_01_000002 is : 143
2015-08-14 03:35:59,706 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup/_temporary
2015-08-14 03:35:59,767 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nogroup