2015-08-14 03:09:14,349 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 03:09:14,412 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 03:09:14,412 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest
2015-08-14 03:09:14,451 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 03:09:15,327 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-08-14 03:09:16,097 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 03:09:16,699 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 03:09:20,691 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 03:09:20,906 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 03:09:21,077 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 03:09:21,262 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 03:09:38,374 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 03:09:38,560 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:09:38,563 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:09:38,577 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 4FC771861B3B4D6E85451457C0FC4C00
2015-08-14 03:09:38,823 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 03:09:38,826 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-14 03:09:38,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:09:38,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:09:38,828 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge"]
2015-08-14 03:09:38,829 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-14 03:09:38,829 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-14 03:09:38,829 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-14 03:09:38,831 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-08-14 03:09:39,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439521772870_0001
2015-08-14 03:09:39,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0001/
2015-08-14 03:09:54,799 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0001_01_000006 is : 143
2015-08-14 03:09:54,909 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0001_01_000007 is : 143
2015-08-14 03:09:55,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0001_01_000003 is : 143
2015-08-14 03:09:55,508 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0001_01_000002 is : 143
2015-08-14 03:09:55,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0001_01_000005 is : 143
2015-08-14 03:09:55,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0001_01_000004 is : 143
2015-08-14 03:09:57,217 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge/_temporary
2015-08-14 03:09:57,340 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/simplemerge
2015-08-14 03:09:57,447 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:09:57,448 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:09:57,607 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-08-14 03:09:57,607 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:09:57,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:09:57,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:09:57,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-08-14 03:09:57,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] parallel execution is enabled: true
2015-08-14 03:09:57,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting jobs: 3
2015-08-14 03:09:57,609 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] allocating threads: 3
2015-08-14 03:09:57,612 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-08-14 03:09:57,895 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1439521772870_0002
2015-08-14 03:09:57,895 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0002/
2015-08-14 03:10:13,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0002_01_000003 is : 143
2015-08-14 03:10:14,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0002_01_000005 is : 143
2015-08-14 03:10:14,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0002_01_000006 is : 143
2015-08-14 03:10:14,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0002_01_000004 is : 143
2015-08-14 03:10:14,361 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0002_01_000007 is : 143
2015-08-14 03:10:14,594 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0002_01_000002 is : 143
2015-08-14 03:10:15,912 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-08-14 03:10:16,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1439521772870_0003
2015-08-14 03:10:16,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0003/
2015-08-14 03:10:31,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0003_01_000003 is : 143
2015-08-14 03:10:31,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0003_01_000002 is : 143
2015-08-14 03:10:31,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0003_01_000007 is : 143
2015-08-14 03:10:31,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0003_01_000004 is : 143
2015-08-14 03:10:31,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0003_01_000005 is : 143
2015-08-14 03:10:32,089 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0003_01_000006 is : 143
2015-08-14 03:10:33,411 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-08-14 03:10:33,615 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1439521772870_0004
2015-08-14 03:10:33,615 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0004/
2015-08-14 03:10:47,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0004_01_000002 is : 143
2015-08-14 03:10:47,741 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0004_01_000003 is : 143
2015-08-14 03:10:48,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0004_01_000006 is : 143
2015-08-14 03:10:48,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0004_01_000004 is : 143
2015-08-14 03:10:48,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0004_01_000005 is : 143
2015-08-14 03:10:49,695 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-08-14 03:10:49,734 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-08-14 03:10:49,784 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:10:49,785 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:10:49,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-08-14 03:10:49,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:10:49,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:10:49,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:10:49,896 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-08-14 03:10:49,896 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] parallel execution is enabled: true
2015-08-14 03:10:49,896 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting jobs: 3
2015-08-14 03:10:49,896 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] allocating threads: 3
2015-08-14 03:10:49,897 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-08-14 03:10:50,133 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1439521772870_0005
2015-08-14 03:10:50,134 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0005/
2015-08-14 03:11:05,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0005_01_000006 is : 143
2015-08-14 03:11:05,819 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0005_01_000003 is : 143
2015-08-14 03:11:05,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0005_01_000005 is : 143
2015-08-14 03:11:05,904 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0005_01_000004 is : 143
2015-08-14 03:11:05,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0005_01_000002 is : 143
2015-08-14 03:11:06,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0005_01_000007 is : 143
2015-08-14 03:11:07,722 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-08-14 03:11:08,272 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1439521772870_0006
2015-08-14 03:11:08,273 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0006/
2015-08-14 03:11:26,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000003 is : 143
2015-08-14 03:11:26,466 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000002 is : 143
2015-08-14 03:11:26,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000008 is : 143
2015-08-14 03:11:26,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000010 is : 143
2015-08-14 03:11:27,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000004 is : 143
2015-08-14 03:11:27,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000009 is : 143
2015-08-14 03:11:27,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000005 is : 143
2015-08-14 03:11:27,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000006 is : 143
2015-08-14 03:11:27,251 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0006_01_000007 is : 143
2015-08-14 03:11:28,559 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-08-14 03:11:28,789 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1439521772870_0007
2015-08-14 03:11:28,791 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0007/
2015-08-14 03:11:47,164 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000002 is : 143
2015-08-14 03:11:47,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000003 is : 143
2015-08-14 03:11:47,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000008 is : 143
2015-08-14 03:11:47,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000006 is : 143
2015-08-14 03:11:47,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000010 is : 143
2015-08-14 03:11:47,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000009 is : 143
2015-08-14 03:11:47,781 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000004 is : 143
2015-08-14 03:11:47,838 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000007 is : 143
2015-08-14 03:11:48,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0007_01_000005 is : 143
2015-08-14 03:11:49,931 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-08-14 03:11:49,980 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-08-14 03:11:50,045 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:11:50,046 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:11:50,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-08-14 03:11:50,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:11:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:11:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:11:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree"]
2015-08-14 03:11:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-08-14 03:11:50,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-08-14 03:11:50,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-08-14 03:11:50,078 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-08-14 03:11:50,269 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1439521772870_0008
2015-08-14 03:11:50,269 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0008/
2015-08-14 03:12:07,981 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000002 is : 143
2015-08-14 03:12:08,539 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000005 is : 143
2015-08-14 03:12:08,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000007 is : 143
2015-08-14 03:12:08,690 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000006 is : 143
2015-08-14 03:12:08,708 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000010 is : 143
2015-08-14 03:12:08,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000004 is : 143
2015-08-14 03:12:08,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000008 is : 143
2015-08-14 03:12:08,984 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000009 is : 143
2015-08-14 03:12:09,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0008_01_000003 is : 143
2015-08-14 03:12:10,394 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree/_temporary
2015-08-14 03:12:10,442 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethree
2015-08-14 03:12:10,498 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:12:10,498 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:12:10,561 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting
2015-08-14 03:12:10,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:12:10,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:12:10,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:12:10,564 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-08-14 03:12:10,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] parallel execution is enabled: true
2015-08-14 03:12:10,566 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting jobs: 2
2015-08-14 03:12:10,566 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] allocating threads: 2
2015-08-14 03:12:10,568 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)
2015-08-14 03:12:10,777 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1439521772870_0009
2015-08-14 03:12:10,777 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0009/
2015-08-14 03:12:26,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0009_01_000005 is : 143
2015-08-14 03:12:26,650 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0009_01_000006 is : 143
2015-08-14 03:12:26,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0009_01_000004 is : 143
2015-08-14 03:12:26,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0009_01_000007 is : 143
2015-08-14 03:12:26,812 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0009_01_000003 is : 143
2015-08-14 03:12:26,847 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0009_01_000002 is : 143
2015-08-14 03:12:28,148 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge
2015-08-14 03:12:28,329 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1439521772870_0010
2015-08-14 03:12:28,329 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0010/
2015-08-14 03:12:43,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0010_01_000002 is : 143
2015-08-14 03:12:43,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0010_01_000006 is : 143
2015-08-14 03:12:43,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0010_01_000005 is : 143
2015-08-14 03:12:44,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0010_01_000007 is : 143
2015-08-14 03:12:44,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0010_01_000004 is : 143
2015-08-14 03:12:45,407 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-08-14 03:12:45,447 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-08-14 03:12:45,494 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:12:45,494 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:12:45,524 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-14 03:12:45,524 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:12:45,524 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:12:45,524 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:12:45,525 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain"]
2015-08-14 03:12:45,525 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-08-14 03:12:45,525 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 1
2015-08-14 03:12:45,525 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 1
2015-08-14 03:12:45,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain
2015-08-14 03:12:45,729 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1439521772870_0011
2015-08-14 03:12:45,729 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0011/
2015-08-14 03:13:04,296 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000002 is : 143
2015-08-14 03:13:04,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000003 is : 143
2015-08-14 03:13:05,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000007 is : 143
2015-08-14 03:13:05,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000009 is : 143
2015-08-14 03:13:05,095 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000010 is : 143
2015-08-14 03:13:05,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000006 is : 143
2015-08-14 03:13:05,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000008 is : 143
2015-08-14 03:13:05,331 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0011_01_000005 is : 143
2015-08-14 03:13:06,742 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain/_temporary
2015-08-14 03:13:06,792 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechain
2015-08-14 03:13:06,848 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:13:06,848 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:13:06,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-08-14 03:13:06,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:13:06,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:13:06,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:13:06,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-08-14 03:13:06,929 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] parallel execution is enabled: true
2015-08-14 03:13:06,930 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting jobs: 3
2015-08-14 03:13:06,930 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] allocating threads: 3
2015-08-14 03:13:06,935 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-08-14 03:13:07,145 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1439521772870_0012
2015-08-14 03:13:07,145 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0012/
2015-08-14 03:13:21,960 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0012_01_000002 is : 143
2015-08-14 03:13:22,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0012_01_000003 is : 143
2015-08-14 03:13:22,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0012_01_000004 is : 143
2015-08-14 03:13:22,495 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0012_01_000007 is : 143
2015-08-14 03:13:22,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0012_01_000006 is : 143
2015-08-14 03:13:22,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0012_01_000005 is : 143
2015-08-14 03:13:24,025 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-08-14 03:13:24,196 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1439521772870_0013
2015-08-14 03:13:24,196 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0013/
2015-08-14 03:13:38,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0013_01_000007 is : 143
2015-08-14 03:13:39,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0013_01_000006 is : 143
2015-08-14 03:13:39,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0013_01_000005 is : 143
2015-08-14 03:13:39,644 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0013_01_000002 is : 143
2015-08-14 03:13:39,678 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0013_01_000003 is : 143
2015-08-14 03:13:39,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0013_01_000004 is : 143
2015-08-14 03:13:40,984 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-08-14 03:13:41,161 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1439521772870_0014
2015-08-14 03:13:41,161 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0014/
2015-08-14 03:13:55,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0014_01_000003 is : 143
2015-08-14 03:13:55,700 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0014_01_000006 is : 143
2015-08-14 03:13:55,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0014_01_000005 is : 143
2015-08-14 03:13:55,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0014_01_000004 is : 143
2015-08-14 03:13:56,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0014_01_000002 is : 143
2015-08-14 03:13:57,595 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-08-14 03:13:57,627 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-08-14 03:13:57,684 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:13:57,684 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:13:57,707 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 03:13:57,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:13:57,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged"]
2015-08-14 03:13:57,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 03:13:57,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 1
2015-08-14 03:13:57,708 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 1
2015-08-14 03:13:57,711 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged
2015-08-14 03:13:57,876 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439521772870_0015
2015-08-14 03:13:57,876 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0015/
2015-08-14 03:14:11,308 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0015_01_000004 is : 143
2015-08-14 03:14:11,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0015_01_000005 is : 143
2015-08-14 03:14:11,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0015_01_000003 is : 143
2015-08-14 03:14:12,395 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0015_01_000002 is : 143
2015-08-14 03:14:43,692 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged/_temporary
2015-08-14 03:14:43,726 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemerged
2015-08-14 03:14:43,763 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:14:43,764 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:14:43,813 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-14 03:14:43,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:14:43,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:14:43,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:14:43,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]
2015-08-14 03:14:43,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-08-14 03:14:43,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 2
2015-08-14 03:14:43,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 2
2015-08-14 03:14:43,817 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)
2015-08-14 03:14:44,005 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1439521772870_0016
2015-08-14 03:14:44,006 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0016/
2015-08-14 03:14:58,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0016_01_000007 is : 143
2015-08-14 03:14:59,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0016_01_000006 is : 143
2015-08-14 03:14:59,566 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0016_01_000005 is : 143
2015-08-14 03:14:59,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0016_01_000003 is : 143
2015-08-14 03:14:59,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0016_01_000004 is : 143
2015-08-14 03:14:59,734 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0016_01_000002 is : 143
2015-08-14 03:15:01,033 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed
2015-08-14 03:15:01,207 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1439521772870_0017
2015-08-14 03:15:01,207 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0017/
2015-08-14 03:15:15,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0017_01_000006 is : 143
2015-08-14 03:15:16,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0017_01_000007 is : 143
2015-08-14 03:15:16,627 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0017_01_000003 is : 143
2015-08-14 03:15:16,753 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0017_01_000004 is : 143
2015-08-14 03:15:16,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0017_01_000002 is : 143
2015-08-14 03:15:16,815 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0017_01_000005 is : 143
2015-08-14 03:15:18,068 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary
2015-08-14 03:15:18,103 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed
2015-08-14 03:15:18,141 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:15:18,141 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:15:18,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergefail
2015-08-14 03:15:18,174 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:15:18,174 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:15:18,204 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-14 03:15:18,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:15:18,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:15:18,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:15:18,206 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup"]
2015-08-14 03:15:18,206 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-08-14 03:15:18,206 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 1
2015-08-14 03:15:18,206 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 1
2015-08-14 03:15:18,207 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-08-14 03:15:18,385 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1439521772870_0018
2015-08-14 03:15:18,385 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0018/
2015-08-14 03:15:37,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000003 is : 143
2015-08-14 03:15:37,199 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000002 is : 143
2015-08-14 03:15:37,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000004 is : 143
2015-08-14 03:15:37,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000009 is : 143
2015-08-14 03:15:37,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000006 is : 143
2015-08-14 03:15:37,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000010 is : 143
2015-08-14 03:15:37,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000007 is : 143
2015-08-14 03:15:37,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000005 is : 143
2015-08-14 03:15:37,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000008 is : 143
2015-08-14 03:15:44,666 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0018_01_000011 is : 143
2015-08-14 03:15:45,947 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup/_temporary
2015-08-14 03:15:45,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup
2015-08-14 03:15:46,006 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:15:46,006 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:15:46,081 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-08-14 03:15:46,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:15:46,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:15:46,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:15:46,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-08-14 03:15:46,083 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] parallel execution is enabled: true
2015-08-14 03:15:46,083 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting jobs: 3
2015-08-14 03:15:46,083 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] allocating threads: 3
2015-08-14 03:15:46,084 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-08-14 03:15:46,303 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1439521772870_0019
2015-08-14 03:15:46,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0019/
2015-08-14 03:16:00,989 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0019_01_000006 is : 143
2015-08-14 03:16:01,338 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0019_01_000007 is : 143
2015-08-14 03:16:01,590 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0019_01_000003 is : 143
2015-08-14 03:16:01,747 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0019_01_000004 is : 143
2015-08-14 03:16:01,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0019_01_000002 is : 143
2015-08-14 03:16:01,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0019_01_000005 is : 143
2015-08-14 03:16:03,130 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-08-14 03:16:03,323 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1439521772870_0020
2015-08-14 03:16:03,323 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0020/
2015-08-14 03:16:17,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0020_01_000002 is : 143
2015-08-14 03:16:17,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0020_01_000003 is : 143
2015-08-14 03:16:17,831 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0020_01_000006 is : 143
2015-08-14 03:16:17,913 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0020_01_000005 is : 143
2015-08-14 03:16:18,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0020_01_000004 is : 143
2015-08-14 03:16:20,068 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge
2015-08-14 03:16:20,279 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1439521772870_0021
2015-08-14 03:16:20,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0021/
2015-08-14 03:16:34,308 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0021_01_000003 is : 143
2015-08-14 03:16:34,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0021_01_000002 is : 143
2015-08-14 03:16:34,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0021_01_000004 is : 143
2015-08-14 03:16:35,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0021_01_000005 is : 143
2015-08-14 03:16:35,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0021_01_000006 is : 143
2015-08-14 03:16:36,373 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-08-14 03:16:36,418 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-08-14 03:16:36,454 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:16:36,455 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:16:36,481 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-14 03:16:36,481 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:16:36,481 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:16:36,481 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:16:36,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed"]
2015-08-14 03:16:36,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-08-14 03:16:36,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 1
2015-08-14 03:16:36,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 1
2015-08-14 03:16:36,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-08-14 03:16:36,681 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1439521772870_0022
2015-08-14 03:16:36,681 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0022/
2015-08-14 03:16:52,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0022_01_000002 is : 143
2015-08-14 03:16:52,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0022_01_000007 is : 143
2015-08-14 03:16:52,297 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0022_01_000005 is : 143
2015-08-14 03:16:52,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0022_01_000006 is : 143
2015-08-14 03:16:52,495 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0022_01_000004 is : 143
2015-08-14 03:16:53,796 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed/_temporary
2015-08-14 03:16:53,832 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed
2015-08-14 03:16:53,872 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:16:53,872 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:16:53,901 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-08-14 03:16:53,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:16:53,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:16:53,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:16:53,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup"]
2015-08-14 03:16:53,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-08-14 03:16:53,903 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 1
2015-08-14 03:16:53,903 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 1
2015-08-14 03:16:53,904 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-08-14 03:16:54,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1439521772870_0023
2015-08-14 03:16:54,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0023/
2015-08-14 03:17:11,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000006 is : 143
2015-08-14 03:17:11,974 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000007 is : 143
2015-08-14 03:17:12,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000009 is : 143
2015-08-14 03:17:12,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000002 is : 143
2015-08-14 03:17:12,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000005 is : 143
2015-08-14 03:17:12,705 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000003 is : 143
2015-08-14 03:17:12,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000008 is : 143
2015-08-14 03:17:13,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000010 is : 143
2015-08-14 03:17:13,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000004 is : 143
2015-08-14 03:17:18,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0023_01_000011 is : 143
2015-08-14 03:17:19,646 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup/_temporary
2015-08-14 03:17:19,670 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup
2015-08-14 03:17:19,696 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:17:19,696 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:17:19,729 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-08-14 03:17:19,729 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:17:19,729 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup"]
2015-08-14 03:17:19,730 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-08-14 03:17:19,730 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 2
2015-08-14 03:17:19,730 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 2
2015-08-14 03:17:19,733 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)
2015-08-14 03:17:19,905 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1439521772870_0024
2015-08-14 03:17:19,906 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0024/
2015-08-14 03:17:33,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0024_01_000002 is : 143
2015-08-14 03:17:33,786 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0024_01_000003 is : 143
2015-08-14 03:17:34,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0024_01_000004 is : 143
2015-08-14 03:17:34,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0024_01_000006 is : 143
2015-08-14 03:17:34,589 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0024_01_000005 is : 143
2015-08-14 03:17:40,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0024_01_000007 is : 143
2015-08-14 03:17:41,484 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup
2015-08-14 03:17:41,663 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1439521772870_0025
2015-08-14 03:17:41,663 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0025/
2015-08-14 03:17:56,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000003 is : 143
2015-08-14 03:17:56,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000002 is : 143
2015-08-14 03:17:57,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000004 is : 143
2015-08-14 03:17:57,546 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000005 is : 143
2015-08-14 03:17:57,585 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000006 is : 143
2015-08-14 03:17:57,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000007 is : 143
2015-08-14 03:18:03,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0025_01_000008 is : 143
2015-08-14 03:18:04,634 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup/_temporary
2015-08-14 03:18:04,658 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/samemergethreechaingroup
2015-08-14 03:18:04,691 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:18:04,691 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:18:04,783 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-08-14 03:18:04,784 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:18:04,784 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:18:04,784 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:18:04,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-08-14 03:18:04,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] parallel execution is enabled: true
2015-08-14 03:18:04,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting jobs: 3
2015-08-14 03:18:04,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] allocating threads: 3
2015-08-14 03:18:04,788 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-08-14 03:18:04,959 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1439521772870_0026
2015-08-14 03:18:04,960 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0026/
2015-08-14 03:18:20,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0026_01_000003 is : 143
2015-08-14 03:18:20,073 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0026_01_000002 is : 143
2015-08-14 03:18:20,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0026_01_000007 is : 143
2015-08-14 03:18:20,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0026_01_000005 is : 143
2015-08-14 03:18:20,671 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0026_01_000006 is : 143
2015-08-14 03:18:20,853 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0026_01_000004 is : 143
2015-08-14 03:18:22,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-08-14 03:18:22,313 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1439521772870_0027
2015-08-14 03:18:22,313 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0027/
2015-08-14 03:18:37,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0027_01_000002 is : 143
2015-08-14 03:18:37,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0027_01_000003 is : 143
2015-08-14 03:18:37,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0027_01_000007 is : 143
2015-08-14 03:18:37,763 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0027_01_000004 is : 143
2015-08-14 03:18:38,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0027_01_000005 is : 143
2015-08-14 03:18:38,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0027_01_000006 is : 143
2015-08-14 03:18:39,440 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-08-14 03:18:39,616 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1439521772870_0028
2015-08-14 03:18:39,616 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0028/
2015-08-14 03:18:54,859 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0028_01_000003 is : 143
2015-08-14 03:18:54,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0028_01_000002 is : 143
2015-08-14 03:18:55,020 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0028_01_000007 is : 143
2015-08-14 03:18:55,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0028_01_000006 is : 143
2015-08-14 03:18:55,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0028_01_000004 is : 143
2015-08-14 03:18:55,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0028_01_000005 is : 143
2015-08-14 03:18:56,978 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-08-14 03:18:57,027 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-08-14 03:18:57,067 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:18:57,068 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:18:57,104 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-08-14 03:18:57,104 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:18:57,104 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:18:57,104 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:18:57,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated"]
2015-08-14 03:18:57,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] parallel execution is enabled: true
2015-08-14 03:18:57,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting jobs: 2
2015-08-14 03:18:57,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] allocating threads: 2
2015-08-14 03:18:57,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-08-14 03:18:57,273 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1439521772870_0029
2015-08-14 03:18:57,273 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0029/
2015-08-14 03:19:12,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0029_01_000002 is : 143
2015-08-14 03:19:12,549 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0029_01_000003 is : 143
2015-08-14 03:19:12,951 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0029_01_000007 is : 143
2015-08-14 03:19:13,107 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0029_01_000004 is : 143
2015-08-14 03:19:13,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0029_01_000005 is : 143
2015-08-14 03:19:13,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0029_01_000006 is : 143
2015-08-14 03:19:14,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-08-14 03:19:14,726 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1439521772870_0030
2015-08-14 03:19:14,726 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0030/
2015-08-14 03:19:28,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0030_01_000003 is : 143
2015-08-14 03:19:29,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0030_01_000002 is : 143
2015-08-14 03:19:29,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0030_01_000004 is : 143
2015-08-14 03:19:29,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0030_01_000005 is : 143
2015-08-14 03:19:29,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0030_01_000006 is : 143
2015-08-14 03:19:30,942 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated/_temporary
2015-08-14 03:19:30,987 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated
2015-08-14 03:19:31,023 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:19:31,023 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:19:31,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-08-14 03:19:31,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 03:19:31,051 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex"]
2015-08-14 03:19:31,051 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-08-14 03:19:31,051 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 1
2015-08-14 03:19:31,051 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 1
2015-08-14 03:19:31,053 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex
2015-08-14 03:19:31,249 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1439521772870_0031
2015-08-14 03:19:31,249 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0031/
2015-08-14 03:19:44,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0031_01_000004 is : 143
2015-08-14 03:19:44,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0031_01_000003 is : 143
2015-08-14 03:19:44,881 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0031_01_000005 is : 143
2015-08-14 03:19:45,033 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0031_01_000002 is : 143
2015-08-14 03:19:46,319 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex/_temporary
2015-08-14 03:19:46,351 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex
2015-08-14 03:19:46,387 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:19:46,387 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:19:46,429 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-08-14 03:19:46,429 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:19:46,430 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:19:46,430 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:19:46,430 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]
2015-08-14 03:19:46,430 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] parallel execution is enabled: true
2015-08-14 03:19:46,430 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting jobs: 2
2015-08-14 03:19:46,430 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] allocating threads: 2
2015-08-14 03:19:46,433 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-08-14 03:19:46,614 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1439521772870_0032
2015-08-14 03:19:46,614 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0032/
2015-08-14 03:20:01,516 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0032_01_000007 is : 143
2015-08-14 03:20:01,711 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0032_01_000006 is : 143
2015-08-14 03:20:02,125 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0032_01_000005 is : 143
2015-08-14 03:20:02,161 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0032_01_000004 is : 143
2015-08-14 03:20:02,345 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0032_01_000003 is : 143
2015-08-14 03:20:02,382 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0032_01_000002 is : 143
2015-08-14 03:20:03,651 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-08-14 03:20:03,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1439521772870_0033
2015-08-14 03:20:03,825 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0033/
2015-08-14 03:20:18,019 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0033_01_000002 is : 143
2015-08-14 03:20:18,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0033_01_000003 is : 143
2015-08-14 03:20:18,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0033_01_000004 is : 143
2015-08-14 03:20:18,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0033_01_000005 is : 143
2015-08-14 03:20:18,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0033_01_000006 is : 143
2015-08-14 03:20:19,973 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-08-14 03:20:20,006 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated
2015-08-14 03:20:20,047 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:20:20,048 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:20:20,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting
2015-08-14 03:20:20,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:20:20,123 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:20:20,123 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:20:20,123 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-08-14 03:20:20,123 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] parallel execution is enabled: true
2015-08-14 03:20:20,123 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting jobs: 3
2015-08-14 03:20:20,123 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] allocating threads: 3
2015-08-14 03:20:20,124 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)
2015-08-14 03:20:20,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1439521772870_0034
2015-08-14 03:20:20,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0034/
2015-08-14 03:20:34,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0034_01_000007 is : 143
2015-08-14 03:20:35,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0034_01_000006 is : 143
2015-08-14 03:20:35,413 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0034_01_000005 is : 143
2015-08-14 03:20:35,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0034_01_000004 is : 143
2015-08-14 03:20:35,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0034_01_000002 is : 143
2015-08-14 03:20:35,670 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0034_01_000003 is : 143
2015-08-14 03:20:36,967 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)
2015-08-14 03:20:37,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1439521772870_0035
2015-08-14 03:20:37,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0035/
2015-08-14 03:20:51,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0035_01_000002 is : 143
2015-08-14 03:20:51,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0035_01_000003 is : 143
2015-08-14 03:20:52,085 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0035_01_000005 is : 143
2015-08-14 03:20:52,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0035_01_000006 is : 143
2015-08-14 03:20:52,323 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0035_01_000004 is : 143
2015-08-14 03:20:53,606 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-08-14 03:20:53,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1439521772870_0036
2015-08-14 03:20:53,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0036/
2015-08-14 03:21:08,548 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0036_01_000006 is : 143
2015-08-14 03:21:08,637 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0036_01_000005 is : 143
2015-08-14 03:21:08,671 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0036_01_000003 is : 143
2015-08-14 03:21:08,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0036_01_000002 is : 143
2015-08-14 03:21:09,646 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0036_01_000004 is : 143
2015-08-14 03:21:10,929 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-08-14 03:21:10,962 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-08-14 03:21:11,000 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:21:11,000 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:21:11,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-08-14 03:21:11,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 03:21:11,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 03:21:11,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 03:21:11,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-08-14 03:21:11,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] parallel execution is enabled: true
2015-08-14 03:21:11,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting jobs: 3
2015-08-14 03:21:11,075 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] allocating threads: 3
2015-08-14 03:21:11,080 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-08-14 03:21:11,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1439521772870_0037
2015-08-14 03:21:11,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0037/
2015-08-14 03:21:26,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0037_01_000003 is : 143
2015-08-14 03:21:26,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0037_01_000002 is : 143
2015-08-14 03:21:26,806 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0037_01_000004 is : 143
2015-08-14 03:21:26,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0037_01_000005 is : 143
2015-08-14 03:21:26,897 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0037_01_000007 is : 143
2015-08-14 03:21:26,991 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0037_01_000006 is : 143
2015-08-14 03:21:28,276 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-08-14 03:21:28,458 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1439521772870_0038
2015-08-14 03:21:28,458 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0038/
2015-08-14 03:21:47,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000007 is : 143
2015-08-14 03:21:47,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000006 is : 143
2015-08-14 03:21:47,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000004 is : 143
2015-08-14 03:21:47,928 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000003 is : 143
2015-08-14 03:21:47,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000009 is : 143
2015-08-14 03:21:48,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000010 is : 143
2015-08-14 03:21:48,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000005 is : 143
2015-08-14 03:21:48,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000008 is : 143
2015-08-14 03:21:49,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0038_01_000002 is : 143
2015-08-14 03:21:50,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-08-14 03:21:50,544 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1439521772870_0039
2015-08-14 03:21:50,544 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://ip-10-235-34-50.ec2.internal:36442/proxy/application_1439521772870_0039/
2015-08-14 03:22:04,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0039_01_000003 is : 143
2015-08-14 03:22:04,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0039_01_000002 is : 143
2015-08-14 03:22:05,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0039_01_000006 is : 143
2015-08-14 03:22:05,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0039_01_000004 is : 143
2015-08-14 03:22:05,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439521772870_0039_01_000005 is : 143
2015-08-14 03:22:06,663 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-08-14 03:22:06,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge