2015-08-14 09:03:30,792 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 09:03:30,863 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 09:03:30,864 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.FieldedPipesPlatformTest
2015-08-14 09:03:30,912 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 09:03:32,112 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 09:03:32,985 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 09:03:38,562 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 09:03:38,866 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 09:03:39,128 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 09:03:39,404 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 09:03:56,571 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 09:03:56,712 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:03:56,715 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 09:03:56,727 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 09D13AC66B394993A9CAAEE7F651534E
2015-08-14 09:03:56,939 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 09:03:56,942 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:03:56,944 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:03:56,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex"]
2015-08-14 09:03:56,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:03:56,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:03:56,945 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:03:56,947 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/filtercomplex
2015-08-14 09:03:58,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0001
2015-08-14 09:03:58,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0001/
2015-08-14 09:04:12,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0001_01_000002 is : 143
2015-08-14 09:04:12,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0001_01_000003 is : 143
2015-08-14 09:04:13,164 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0001_01_000004 is : 143
2015-08-14 09:04:13,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0001_01_000005 is : 143
2015-08-14 09:04:20,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0001_01_000006 is : 143
2015-08-14 09:04:21,915 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filtercomplex/_temporary
2015-08-14 09:04:21,976 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filtercomplex
2015-08-14 09:04:22,032 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:04:22,033 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 09:04:22,085 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:04:22,086 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:04:22,086 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain"]
2015-08-14 09:04:22,086 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:04:22,086 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:04:22,086 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:04:22,088 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/simplechain
2015-08-14 09:04:22,333 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0002
2015-08-14 09:04:22,334 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0002/
2015-08-14 09:04:37,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0002_01_000003 is : 143
2015-08-14 09:04:37,549 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0002_01_000004 is : 143
2015-08-14 09:04:37,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0002_01_000005 is : 143
2015-08-14 09:04:37,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0002_01_000002 is : 143
2015-08-14 09:04:44,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0002_01_000006 is : 143
2015-08-14 09:04:46,114 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplechain/_temporary
2015-08-14 09:04:46,154 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplechain
2015-08-14 09:04:46,193 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:04:46,194 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 09:04:46,222 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:04:46,222 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:04:46,223 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple"]
2015-08-14 09:04:46,223 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:04:46,223 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:04:46,224 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:04:46,225 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/simple
2015-08-14 09:04:46,415 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0003
2015-08-14 09:04:46,415 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0003/
2015-08-14 09:05:00,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0003_01_000002 is : 143
2015-08-14 09:05:00,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0003_01_000003 is : 143
2015-08-14 09:05:01,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0003_01_000004 is : 143
2015-08-14 09:05:01,483 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0003_01_000005 is : 143
2015-08-14 09:05:07,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0003_01_000006 is : 143
2015-08-14 09:05:09,209 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simple/_temporary
2015-08-14 09:05:09,273 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simple
2015-08-14 09:05:09,355 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:05:09,356 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 09:05:09,388 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-14 09:05:09,389 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]
2015-08-14 09:05:09,389 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 09:05:09,389 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge"]
2015-08-14 09:05:09,389 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-14 09:05:09,390 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-14 09:05:09,390 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-14 09:05:09,392 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-08-14 09:05:09,592 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439543031068_0004
2015-08-14 09:05:09,593 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0004/
2015-08-14 09:05:25,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000002 is : 143
2015-08-14 09:05:25,339 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000003 is : 143
2015-08-14 09:05:25,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000006 is : 143
2015-08-14 09:05:25,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000005 is : 143
2015-08-14 09:05:26,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000007 is : 143
2015-08-14 09:05:26,194 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000004 is : 143
2015-08-14 09:05:32,996 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0004_01_000008 is : 143
2015-08-14 09:05:34,262 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemerge/_temporary
2015-08-14 09:05:34,325 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemerge
2015-08-14 09:05:34,479 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:05:34,479 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 09:05:34,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:05:34,517 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:05:34,518 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach"]
2015-08-14 09:05:34,518 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:05:34,518 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:05:34,518 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:05:34,519 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/chaineach
2015-08-14 09:05:34,759 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0005
2015-08-14 09:05:34,760 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0005/
2015-08-14 09:05:49,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0005_01_000003 is : 143
2015-08-14 09:05:49,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0005_01_000004 is : 143
2015-08-14 09:05:50,034 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0005_01_000002 is : 143
2015-08-14 09:05:50,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0005_01_000005 is : 143
2015-08-14 09:05:57,431 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0005_01_000006 is : 143
2015-08-14 09:05:58,662 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chaineach/_temporary
2015-08-14 09:05:58,697 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chaineach
2015-08-14 09:05:58,733 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:05:58,734 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 09:05:58,765 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:05:58,765 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:05:58,766 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator"]
2015-08-14 09:05:58,766 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:05:58,766 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:05:58,766 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:05:58,767 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...tform/generatoraggregator
2015-08-14 09:05:58,948 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0006
2015-08-14 09:05:58,949 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0006/
2015-08-14 09:06:14,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0006_01_000004 is : 143
2015-08-14 09:06:14,307 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0006_01_000003 is : 143
2015-08-14 09:06:14,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0006_01_000002 is : 143
2015-08-14 09:06:21,491 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0006_01_000006 is : 143
2015-08-14 09:06:22,734 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/generatoraggregator/_temporary
2015-08-14 09:06:22,765 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/generatoraggregator
2015-08-14 09:06:22,819 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:06:22,819 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 09:06:22,864 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-14 09:06:22,864 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]
2015-08-14 09:06:22,864 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 09:06:22,865 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 09:06:22,865 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree"]
2015-08-14 09:06:22,866 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-14 09:06:22,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-14 09:06:22,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-14 09:06:22,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-08-14 09:06:23,050 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439543031068_0007
2015-08-14 09:06:23,051 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0007/
2015-08-14 09:06:41,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000010 is : 143
2015-08-14 09:06:43,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000006 is : 143
2015-08-14 09:06:43,365 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000003 is : 143
2015-08-14 09:06:43,424 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000008 is : 143
2015-08-14 09:06:43,519 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000009 is : 143
2015-08-14 09:06:43,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000005 is : 143
2015-08-14 09:06:43,649 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000007 is : 143
2015-08-14 09:06:48,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0007_01_000011 is : 143
2015-08-14 09:06:50,157 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/simplemergethree/_temporary
2015-08-14 09:06:50,186 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/simplemergethree
2015-08-14 09:06:50,220 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:06:50,221 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 09:06:50,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-14 09:06:50,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:06:50,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1"]
2015-08-14 09:06:50,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2"]
2015-08-14 09:06:50,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-08-14 09:06:50,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 3
2015-08-14 09:06:50,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 3
2015-08-14 09:06:50,275 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-08-14 09:06:50,443 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0008
2015-08-14 09:06:50,444 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0008/
2015-08-14 09:07:05,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0008_01_000005 is : 143
2015-08-14 09:07:05,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0008_01_000003 is : 143
2015-08-14 09:07:05,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0008_01_000004 is : 143
2015-08-14 09:07:07,033 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...pesplatform/nonsafesplit2
2015-08-14 09:07:07,033 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...pesplatform/nonsafesplit1
2015-08-14 09:07:07,640 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0009
2015-08-14 09:07:07,641 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0009/
2015-08-14 09:07:07,644 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0010
2015-08-14 09:07:07,644 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0010/
2015-08-14 09:07:12,533 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439543031068_0008_01_000001
2015-08-14 09:07:23,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0009_01_000005 is : 143
2015-08-14 09:07:23,621 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0009_01_000002 is : 143
2015-08-14 09:07:23,666 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0009_01_000004 is : 143
2015-08-14 09:07:24,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0009_01_000003 is : 143
2015-08-14 09:07:29,139 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0010_01_000002 is : 143
2015-08-14 09:07:29,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0010_01_000003 is : 143
2015-08-14 09:07:29,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0010_01_000005 is : 143
2015-08-14 09:07:29,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0010_01_000004 is : 143
2015-08-14 09:07:30,615 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit2/_temporary
2015-08-14 09:07:30,616 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nonsafesplit1/_temporary
2015-08-14 09:07:30,676 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit2
2015-08-14 09:07:30,689 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nonsafesplit1
2015-08-14 09:07:30,723 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:07:30,723 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 09:07:30,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting
2015-08-14 09:07:30,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:07:30,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2"]
2015-08-14 09:07:30,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1"]
2015-08-14 09:07:30,761 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] parallel execution is enabled: true
2015-08-14 09:07:30,761 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] starting jobs: 3
2015-08-14 09:07:30,761 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [output1+output2] allocating threads: 3
2015-08-14 09:07:30,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (1/3)
2015-08-14 09:07:30,911 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439543031068_0011
2015-08-14 09:07:30,912 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0011/
2015-08-14 09:07:45,997 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0011_01_000004 is : 143
2015-08-14 09:07:46,106 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0011_01_000005 is : 143
2015-08-14 09:07:46,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0011_01_000002 is : 143
2015-08-14 09:07:46,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0011_01_000003 is : 143
2015-08-14 09:07:53,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0011_01_000006 is : 143
2015-08-14 09:07:55,208 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (3/3) ...edpipesplatform/splitout2
2015-08-14 09:07:55,208 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] starting step: (2/3) ...edpipesplatform/splitout1
2015-08-14 09:07:55,388 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439543031068_0012
2015-08-14 09:07:55,388 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0012/
2015-08-14 09:07:55,408 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] submitted hadoop job: job_1439543031068_0013
2015-08-14 09:07:55,409 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [output1+output2] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0013/
2015-08-14 09:08:09,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0012_01_000002 is : 143
2015-08-14 09:08:15,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0013_01_000002 is : 143
2015-08-14 09:08:17,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0012_01_000003 is : 143
2015-08-14 09:08:18,767 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout1/_temporary
2015-08-14 09:08:18,768 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitout2/_temporary
2015-08-14 09:08:18,884 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout1
2015-08-14 09:08:18,890 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitout2
2015-08-14 09:08:18,922 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:08:18,923 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 09:08:18,951 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-14 09:08:18,952 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:08:18,952 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1"]
2015-08-14 09:08:18,952 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2"]
2015-08-14 09:08:18,952 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-08-14 09:08:18,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 2
2015-08-14 09:08:18,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 2
2015-08-14 09:08:18,954 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/2) ...eldedpipesplatform/split2
2015-08-14 09:08:18,955 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/2) ...eldedpipesplatform/split1
2015-08-14 09:08:19,144 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0014
2015-08-14 09:08:19,144 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0014/
2015-08-14 09:08:19,167 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0015
2015-08-14 09:08:19,167 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0015/
2015-08-14 09:08:36,884 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0014_01_000003 is : 143
2015-08-14 09:08:36,974 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0014_01_000002 is : 143
2015-08-14 09:08:37,680 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0014_01_000004 is : 143
2015-08-14 09:08:38,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0014_01_000005 is : 143
2015-08-14 09:08:42,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0015_01_000002 is : 143
2015-08-14 09:08:42,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0015_01_000005 is : 143
2015-08-14 09:08:42,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0015_01_000004 is : 143
2015-08-14 09:08:42,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0015_01_000003 is : 143
2015-08-14 09:08:43,446 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split2/_temporary
2015-08-14 09:08:43,448 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/split1/_temporary
2015-08-14 09:08:43,529 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/split1
2015-08-14 09:08:43,540 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/split2
2015-08-14 09:08:43,577 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:08:43,578 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 09:08:43,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 09:08:43,610 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:08:43,611 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged"]
2015-08-14 09:08:43,611 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 09:08:43,611 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 2
2015-08-14 09:08:43,611 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 2
2015-08-14 09:08:43,612 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-08-14 09:08:43,771 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439543031068_0016
2015-08-14 09:08:43,772 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0016/
2015-08-14 09:09:00,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0016_01_000004 is : 143
2015-08-14 09:09:00,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0016_01_000005 is : 143
2015-08-14 09:09:00,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0016_01_000003 is : 143
2015-08-14 09:09:00,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0016_01_000002 is : 143
2015-08-14 09:09:01,743 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...latform/splitsourcemerged
2015-08-14 09:09:01,901 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439543031068_0017
2015-08-14 09:09:01,902 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0017/
2015-08-14 09:09:16,739 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0017_01_000003 is : 143
2015-08-14 09:09:16,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0017_01_000004 is : 143
2015-08-14 09:09:16,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0017_01_000002 is : 143
2015-08-14 09:09:16,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0017_01_000005 is : 143
2015-08-14 09:09:24,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0017_01_000006 is : 143
2015-08-14 09:09:25,408 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemerged/_temporary
2015-08-14 09:09:25,434 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemerged
2015-08-14 09:09:25,462 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:09:25,462 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 09:09:25,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:09:25,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:09:25,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy"]
2015-08-14 09:09:25,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:09:25,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:09:25,477 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:09:25,478 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/copy
2015-08-14 09:09:25,640 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0018
2015-08-14 09:09:25,640 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0018/
2015-08-14 09:09:39,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0018_01_000003 is : 143
2015-08-14 09:09:39,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0018_01_000002 is : 143
2015-08-14 09:09:40,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0018_01_000005 is : 143
2015-08-14 09:09:40,491 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0018_01_000004 is : 143
2015-08-14 09:09:41,727 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/copy/_temporary
2015-08-14 09:09:41,764 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/copy
2015-08-14 09:09:41,806 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:09:41,806 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 09:09:41,832 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:09:41,832 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:09:41,832 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/none"]
2015-08-14 09:09:41,833 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:09:41,833 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:09:41,833 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:09:41,834 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/none
2015-08-14 09:09:41,980 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0019
2015-08-14 09:09:41,980 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0019/
2015-08-14 09:09:57,047 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0019_01_000004 is : 143
2015-08-14 09:09:57,132 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0019_01_000005 is : 143
2015-08-14 09:09:57,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0019_01_000003 is : 143
2015-08-14 09:09:57,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0019_01_000002 is : 143
2015-08-14 09:10:04,520 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0019_01_000006 is : 143
2015-08-14 09:10:05,758 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/none/_temporary
2015-08-14 09:10:05,785 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/none
2015-08-14 09:10:05,813 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:10:05,814 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 09:10:05,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:10:05,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:10:05,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap"]
2015-08-14 09:10:05,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:10:05,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:10:05,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:10:05,840 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...fieldedpipesplatform/swap
2015-08-14 09:10:06,004 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0020
2015-08-14 09:10:06,005 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0020/
2015-08-14 09:10:19,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0020_01_000003 is : 143
2015-08-14 09:10:20,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0020_01_000002 is : 143
2015-08-14 09:10:20,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0020_01_000005 is : 143
2015-08-14 09:10:20,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0020_01_000004 is : 143
2015-08-14 09:10:27,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0020_01_000006 is : 143
2015-08-14 09:10:28,706 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/swap/_temporary
2015-08-14 09:10:28,732 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/swap
2015-08-14 09:10:28,771 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:10:28,772 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 09:10:28,791 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:10:28,791 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:10:28,791 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter"]
2015-08-14 09:10:28,792 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:10:28,792 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:10:28,792 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:10:28,794 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pipesplatform/logicfilter
2015-08-14 09:10:28,944 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0021
2015-08-14 09:10:28,944 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0021/
2015-08-14 09:10:43,670 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0021_01_000003 is : 143
2015-08-14 09:10:43,728 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0021_01_000004 is : 143
2015-08-14 09:10:43,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0021_01_000005 is : 143
2015-08-14 09:10:44,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0021_01_000002 is : 143
2015-08-14 09:10:45,358 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/logicfilter/_temporary
2015-08-14 09:10:45,392 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/logicfilter
2015-08-14 09:10:45,445 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:10:45,445 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 09:10:45,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:10:45,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 09:10:45,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped"]
2015-08-14 09:10:45,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:10:45,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:10:45,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:10:45,467 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...edpipesplatform/ungrouped
2015-08-14 09:10:45,624 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0022
2015-08-14 09:10:45,625 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0022/
2015-08-14 09:11:01,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0022_01_000006 is : 143
2015-08-14 09:11:01,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0022_01_000004 is : 143
2015-08-14 09:11:01,845 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0022_01_000005 is : 143
2015-08-14 09:11:01,931 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0022_01_000002 is : 143
2015-08-14 09:11:02,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0022_01_000003 is : 143
2015-08-14 09:11:04,167 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped/_temporary
2015-08-14 09:11:04,206 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped
2015-08-14 09:11:04,249 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:11:04,249 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 09:11:04,304 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 09:11:04,305 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:11:04,306 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second"]
2015-08-14 09:11:04,306 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third"]
2015-08-14 09:11:04,307 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first"]
2015-08-14 09:11:04,308 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 09:11:04,309 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 3
2015-08-14 09:11:04,309 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 3
2015-08-14 09:11:04,311 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/3) ...latform/chainedtaps/first
2015-08-14 09:11:04,470 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439543031068_0023
2015-08-14 09:11:04,471 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0023/
2015-08-14 09:11:19,348 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0023_01_000004 is : 143
2015-08-14 09:11:19,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0023_01_000002 is : 143
2015-08-14 09:11:19,456 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0023_01_000005 is : 143
2015-08-14 09:11:19,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0023_01_000003 is : 143
2015-08-14 09:11:27,430 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0023_01_000006 is : 143
2015-08-14 09:11:28,650 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (2/3) ...atform/chainedtaps/second
2015-08-14 09:11:28,794 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439543031068_0024
2015-08-14 09:11:28,794 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0024/
2015-08-14 09:11:43,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0024_01_000005 is : 143
2015-08-14 09:11:43,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0024_01_000002 is : 143
2015-08-14 09:11:43,841 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0024_01_000004 is : 143
2015-08-14 09:11:43,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0024_01_000003 is : 143
2015-08-14 09:11:51,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0024_01_000006 is : 143
2015-08-14 09:11:53,010 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (3/3) ...latform/chainedtaps/third
2015-08-14 09:11:53,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439543031068_0025
2015-08-14 09:11:53,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0025/
2015-08-14 09:12:07,718 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0025_01_000002 is : 143
2015-08-14 09:12:07,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0025_01_000003 is : 143
2015-08-14 09:12:08,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0025_01_000005 is : 143
2015-08-14 09:12:08,512 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0025_01_000004 is : 143
2015-08-14 09:12:15,076 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0025_01_000006 is : 143
2015-08-14 09:12:16,313 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/first/_temporary
2015-08-14 09:12:16,314 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/second/_temporary
2015-08-14 09:12:16,316 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/chainedtaps/third/_temporary
2015-08-14 09:12:16,343 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/third
2015-08-14 09:12:16,351 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/first
2015-08-14 09:12:16,357 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/chainedtaps/second
2015-08-14 09:12:16,387 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:12:16,389 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 09:12:16,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:12:16,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:12:16,424 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall"]
2015-08-14 09:12:16,424 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:12:16,424 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-08-14 09:12:16,424 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-08-14 09:12:16,427 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-14 09:12:16,583 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0026
2015-08-14 09:12:16,584 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0026/
2015-08-14 09:12:30,553 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0026_01_000003 is : 143
2015-08-14 09:12:30,719 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0026_01_000002 is : 143
2015-08-14 09:12:31,409 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0026_01_000005 is : 143
2015-08-14 09:12:31,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0026_01_000004 is : 143
2015-08-14 09:12:38,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0026_01_000006 is : 143
2015-08-14 09:12:39,286 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...edpipesplatform/filterall
2015-08-14 09:12:39,438 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0027
2015-08-14 09:12:39,438 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0027/
2015-08-14 09:12:53,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0027_01_000002 is : 143
2015-08-14 09:13:01,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0027_01_000003 is : 143
2015-08-14 09:13:02,913 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filterall/_temporary
2015-08-14 09:13:02,937 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filterall
2015-08-14 09:13:02,964 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:13:02,964 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 09:13:02,994 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 09:13:02,994 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:13:02,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename"]
2015-08-14 09:13:02,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 09:13:02,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 2
2015-08-14 09:13:02,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 2
2015-08-14 09:13:02,998 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/2)
2015-08-14 09:13:03,174 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439543031068_0028
2015-08-14 09:13:03,175 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0028/
2015-08-14 09:13:18,258 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0028_01_000003 is : 143
2015-08-14 09:13:18,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0028_01_000002 is : 143
2015-08-14 09:13:18,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0028_01_000004 is : 143
2015-08-14 09:13:18,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0028_01_000005 is : 143
2015-08-14 09:13:19,813 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (2/2) ...splitsourcemergedsamename
2015-08-14 09:13:19,961 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439543031068_0029
2015-08-14 09:13:19,961 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0029/
2015-08-14 09:13:34,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0029_01_000003 is : 143
2015-08-14 09:13:34,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0029_01_000002 is : 143
2015-08-14 09:13:35,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0029_01_000005 is : 143
2015-08-14 09:13:35,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0029_01_000004 is : 143
2015-08-14 09:13:41,794 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0029_01_000006 is : 143
2015-08-14 09:13:43,025 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename/_temporary
2015-08-14 09:13:43,052 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitsourcemergedsamename
2015-08-14 09:13:43,082 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:13:43,083 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 09:13:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting
2015-08-14 09:13:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]
2015-08-14 09:13:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 09:13:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic"]
2015-08-14 09:13:43,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] parallel execution is enabled: true
2015-08-14 09:13:43,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] starting jobs: 1
2015-08-14 09:13:43,119 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper] allocating threads: 1
2015-08-14 09:13:43,120 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] starting step: (1/1) ...grouping-nondeterministic
2015-08-14 09:13:43,272 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] submitted hadoop job: job_1439543031068_0030
2015-08-14 09:13:43,272 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0030/
2015-08-14 09:13:58,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000003 is : 143
2015-08-14 09:13:58,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000002 is : 143
2015-08-14 09:13:59,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000007 is : 143
2015-08-14 09:14:00,020 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000006 is : 143
2015-08-14 09:14:00,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000005 is : 143
2015-08-14 09:14:00,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000004 is : 143
2015-08-14 09:14:05,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0030_01_000008 is : 143
2015-08-14 09:14:07,164 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic/_temporary
2015-08-14 09:14:07,190 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/insensitivegrouping-nondeterministic
2015-08-14 09:14:07,228 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:14:07,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 09:14:07,244 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:14:07,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 09:14:07,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon"]
2015-08-14 09:14:07,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:14:07,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:14:07,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:14:07,247 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...pesplatform/ungroupedanon
2015-08-14 09:14:07,388 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0031
2015-08-14 09:14:07,388 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0031/
2015-08-14 09:14:22,140 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0031_01_000003 is : 143
2015-08-14 09:14:22,246 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0031_01_000002 is : 143
2015-08-14 09:14:22,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0031_01_000006 is : 143
2015-08-14 09:14:23,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0031_01_000005 is : 143
2015-08-14 09:14:23,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0031_01_000004 is : 143
2015-08-14 09:14:24,434 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungroupedanon/_temporary
2015-08-14 09:14:24,470 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungroupedanon
2015-08-14 09:14:24,507 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:14:24,508 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 09:14:24,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:14:24,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:14:24,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup"]
2015-08-14 09:14:24,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:14:24,539 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-08-14 09:14:24,539 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 2
2015-08-14 09:14:24,540 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-14 09:14:24,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0032
2015-08-14 09:14:24,703 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0032/
2015-08-14 09:14:39,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0032_01_000003 is : 143
2015-08-14 09:14:39,951 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0032_01_000004 is : 143
2015-08-14 09:14:40,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0032_01_000002 is : 143
2015-08-14 09:14:40,097 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0032_01_000005 is : 143
2015-08-14 09:14:47,724 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0032_01_000006 is : 143
2015-08-14 09:14:48,952 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...dpipesplatform/groupgroup
2015-08-14 09:14:49,095 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0033
2015-08-14 09:14:49,095 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0033/
2015-08-14 09:15:03,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0033_01_000002 is : 143
2015-08-14 09:15:11,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0033_01_000003 is : 143
2015-08-14 09:15:12,675 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/groupgroup/_temporary
2015-08-14 09:15:12,701 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/groupgroup
2015-08-14 09:15:12,729 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:15:12,730 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 09:15:12,777 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting
2015-08-14 09:15:12,778 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.6.x/build/classes/test/data/lower.txt"]
2015-08-14 09:15:12,778 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.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup"]
2015-08-14 09:15:12,778 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] parallel execution is enabled: true
2015-08-14 09:15:12,778 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] starting jobs: 2
2015-08-14 09:15:12,778 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower+upper+offset] allocating threads: 2
2015-08-14 09:15:12,781 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (2/2)
2015-08-14 09:15:12,927 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1439543031068_0034
2015-08-14 09:15:12,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0034/
2015-08-14 09:15:27,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0034_01_000006 is : 143
2015-08-14 09:15:28,499 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0034_01_000004 is : 143
2015-08-14 09:15:28,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0034_01_000003 is : 143
2015-08-14 09:15:28,757 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0034_01_000002 is : 143
2015-08-14 09:15:28,794 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0034_01_000005 is : 143
2015-08-14 09:15:35,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0034_01_000007 is : 143
2015-08-14 09:15:36,567 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] starting step: (1/2) .../samemergethreechaingroup
2015-08-14 09:15:36,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] submitted hadoop job: job_1439543031068_0035
2015-08-14 09:15:36,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower+upper+offset] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0035/
2015-08-14 09:15:53,757 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000004 is : 143
2015-08-14 09:15:53,864 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000005 is : 143
2015-08-14 09:15:53,897 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000006 is : 143
2015-08-14 09:15:53,913 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000003 is : 143
2015-08-14 09:15:53,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000007 is : 143
2015-08-14 09:15:54,034 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000002 is : 143
2015-08-14 09:16:01,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0035_01_000008 is : 143
2015-08-14 09:16:02,994 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup/_temporary
2015-08-14 09:16:03,030 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/samemergethreechaingroup
2015-08-14 09:16:03,060 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:16:03,060 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 09:16:03,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:16:03,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:16:03,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace"]
2015-08-14 09:16:03,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:16:03,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:16:03,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:16:03,079 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/replace
2015-08-14 09:16:03,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0036
2015-08-14 09:16:03,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0036/
2015-08-14 09:16:17,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0036_01_000003 is : 143
2015-08-14 09:16:17,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0036_01_000002 is : 143
2015-08-14 09:16:18,416 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0036_01_000004 is : 143
2015-08-14 09:16:18,460 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0036_01_000005 is : 143
2015-08-14 09:16:19,706 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/replace/_temporary
2015-08-14 09:16:19,741 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/replace
2015-08-14 09:16:19,800 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:16:19,801 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 09:16:19,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:16:19,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/extra+lower+upper.txt"]
2015-08-14 09:16:19,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size"]
2015-08-14 09:16:19,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:16:19,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:16:19,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:16:19,818 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/ungrouped_size
2015-08-14 09:16:19,961 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0037
2015-08-14 09:16:19,961 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0037/
2015-08-14 09:16:34,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0037_01_000005 is : 143
2015-08-14 09:16:34,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0037_01_000002 is : 143
2015-08-14 09:16:34,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0037_01_000003 is : 143
2015-08-14 09:16:35,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0037_01_000004 is : 143
2015-08-14 09:16:36,274 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/ungrouped_size/_temporary
2015-08-14 09:16:36,309 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/ungrouped_size
2015-08-14 09:16:36,345 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:16:36,345 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 09:16:36,360 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:16:36,361 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:16:36,361 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter"]
2015-08-14 09:16:36,361 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:16:36,361 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:16:36,361 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:16:36,363 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...eldedpipesplatform/filter
2015-08-14 09:16:36,522 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0038
2015-08-14 09:16:36,522 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0038/
2015-08-14 09:16:51,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0038_01_000004 is : 143
2015-08-14 09:16:51,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0038_01_000005 is : 143
2015-08-14 09:16:51,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0038_01_000002 is : 143
2015-08-14 09:16:52,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0038_01_000003 is : 143
2015-08-14 09:16:54,186 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/filter/_temporary
2015-08-14 09:16:54,218 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/filter
2015-08-14 09:16:54,255 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:16:54,256 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 09:16:54,275 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting
2015-08-14 09:16:54,276 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.6.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]]]
2015-08-14 09:16:54,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat"]
2015-08-14 09:16:54,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] parallel execution is enabled: true
2015-08-14 09:16:54,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] starting jobs: 1
2015-08-14 09:16:54,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [concat] allocating threads: 1
2015-08-14 09:16:54,277 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] starting step: (1/1) ...pesplatform/complexconcat
2015-08-14 09:16:54,437 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] submitted hadoop job: job_1439543031068_0039
2015-08-14 09:16:54,438 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [concat] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0039/
2015-08-14 09:17:10,438 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000003 is : 143
2015-08-14 09:17:10,487 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000002 is : 143
2015-08-14 09:17:11,101 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000006 is : 143
2015-08-14 09:17:11,155 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000004 is : 143
2015-08-14 09:17:11,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000005 is : 143
2015-08-14 09:17:11,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000007 is : 143
2015-08-14 09:17:18,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0039_01_000008 is : 143
2015-08-14 09:17:19,358 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/complexconcat/_temporary
2015-08-14 09:17:19,384 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/complexconcat
2015-08-14 09:17:19,424 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:17:19,424 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 09:17:19,463 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting
2015-08-14 09:17:19,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:17:19,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1"]
2015-08-14 09:17:19,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2"]
2015-08-14 09:17:19,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] parallel execution is enabled: true
2015-08-14 09:17:19,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] starting jobs: 3
2015-08-14 09:17:19,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [left+right] allocating threads: 3
2015-08-14 09:17:19,466 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (1/3)
2015-08-14 09:17:19,619 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0040
2015-08-14 09:17:19,620 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0040/
2015-08-14 09:17:34,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0040_01_000002 is : 143
2015-08-14 09:17:34,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0040_01_000003 is : 143
2015-08-14 09:17:34,881 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0040_01_000005 is : 143
2015-08-14 09:17:34,920 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0040_01_000004 is : 143
2015-08-14 09:17:42,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0040_01_000006 is : 143
2015-08-14 09:17:43,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (2/3) ...dpipesplatform/splitcomp2
2015-08-14 09:17:43,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] starting step: (3/3) ...dpipesplatform/splitcomp1
2015-08-14 09:17:43,577 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0041
2015-08-14 09:17:43,578 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0041/
2015-08-14 09:17:43,599 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] submitted hadoop job: job_1439543031068_0042
2015-08-14 09:17:43,600 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [left+right] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0042/
2015-08-14 09:17:57,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0041_01_000002 is : 143
2015-08-14 09:18:03,201 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0042_01_000002 is : 143
2015-08-14 09:18:04,444 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp2/_temporary
2015-08-14 09:18:04,446 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/splitcomp1/_temporary
2015-08-14 09:18:04,495 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp1
2015-08-14 09:18:04,501 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/splitcomp2
2015-08-14 09:18:04,527 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:18:04,528 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 09:18:04,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 09:18:04,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2015-08-14 09:18:04,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup"]
2015-08-14 09:18:04,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: true
2015-08-14 09:18:04,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 09:18:04,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 09:18:04,554 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ldedpipesplatform/nogroup
2015-08-14 09:18:04,700 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_1439543031068_0043
2015-08-14 09:18:04,700 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://ip-10-235-34-50:55585/proxy/application_1439543031068_0043/
2015-08-14 09:18:18,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0043_01_000003 is : 143
2015-08-14 09:18:18,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0043_01_000002 is : 143
2015-08-14 09:18:19,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0043_01_000004 is : 143
2015-08-14 09:18:19,584 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439543031068_0043_01_000005 is : 143
2015-08-14 09:18:20,835 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/fieldedpipesplatform/nogroup/_temporary
2015-08-14 09:18:20,900 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/fieldedpipesplatform/nogroup