Class cascading.MergePipesPlatformTest

all > cascading > MergePipesPlatformTest
21

tests
0

failures
0

ignored
13m6.00s

duration
100%

successful

Tests

Test Duration Result
testHashJoinMergeIntoHashJoinAccumulated 43.427s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated 1m5.78s passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge 1m8.36s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed 1m4.92s passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge 1m10.38s passed
testHashJoinMergeIntoHashJoinStreamed 23.222s passed
testHashJoinMergeIntoHashJoinStreamedAccumulated 43.626s passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge 43.540s passed
testHashJoinMergeIntoHashJoinStreamedStreamed 23.261s passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge 23.145s passed
testMergeIntoHashJoinAccumulated 20.391s passed
testMergeIntoHashJoinStreamed 22.977s passed
testSameSourceMergeThreeChainGroup 54.636s passed
testSimpleMerge 48.518s passed
testSimpleMergeFail 0.033s passed
testSimpleMergeThree 31.075s passed
testSimpleMergeThreeChain 31.409s passed
testSimpleMergeThreeChainCoGroup 34.850s passed
testSimpleMergeThreeChainGroup 34.779s passed
testSplitSameSourceMerged 18.942s passed
testSplitSameSourceMergedComplex 18.735s passed

Standard output

2016-01-14 22:50:01,373 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 22:50:01,403 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2016-01-14 22:50:01,440 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-14 22:50:02,349 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2016-01-14 22:50:03,000 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 22:50:03,607 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 22:50:07,237 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 22:50:07,400 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 22:50:07,523 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 22:50:07,642 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 22:50:19,472 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 22:50:20,510 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 22:50:20,511 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 22:50:24,724 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 22:50:24,866 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:50:24,867 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:50:24,935 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 317B3BB0FA584A3B82EA1E9D41EA748C
2016-01-14 22:50:25,073 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.101
2016-01-14 22:50:25,076 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:50:25,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:50:25,217 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 22:50:25,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 22:50:25,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:50:25,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:50:25,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-01-14 22:50:25,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2016-01-14 22:50:25,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2016-01-14 22:50:25,220 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2016-01-14 22:50:25,220 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-01-14 22:50:26,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1452811819222_0001
2016-01-14 22:50:26,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0001/
2016-01-14 22:50:47,570 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0001_01_000006 is : 143
2016-01-14 22:50:47,690 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0001_01_000007 is : 143
2016-01-14 22:50:47,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0001_01_000004 is : 143
2016-01-14 22:50:48,212 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0001_01_000002 is : 143
2016-01-14 22:50:48,443 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0001_01_000003 is : 143
2016-01-14 22:50:48,491 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0001_01_000005 is : 143
2016-01-14 22:50:49,832 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-01-14 22:50:49,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:24.611, using cpu time: 00:06.120
2016-01-14 22:50:49,934 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge
2016-01-14 22:50:50,002 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:50:50,002 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:50:50,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.204
2016-01-14 22:50:50,221 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 22:50:50,221 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:50:50,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2016-01-14 22:50:50,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:50:50,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:50:50,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:50:50,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-01-14 22:50:50,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  parallel execution of steps is enabled: true
2016-01-14 22:50:50,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  executing total steps: 3
2016-01-14 22:50:50,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  allocating management threads: 3
2016-01-14 22:50:50,304 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/3)
2016-01-14 22:50:50,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452811819222_0002
2016-01-14 22:50:50,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0002/
2016-01-14 22:51:10,914 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0002_01_000006 is : 143
2016-01-14 22:51:11,875 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0002_01_000003 is : 143
2016-01-14 22:51:11,927 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0002_01_000007 is : 143
2016-01-14 22:51:12,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0002_01_000005 is : 143
2016-01-14 22:51:12,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0002_01_000004 is : 143
2016-01-14 22:51:12,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0002_01_000002 is : 143
2016-01-14 22:51:13,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/3)
2016-01-14 22:51:13,754 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452811819222_0003
2016-01-14 22:51:13,755 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0003/
2016-01-14 22:51:33,940 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0003_01_000002 is : 143
2016-01-14 22:51:34,414 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0003_01_000003 is : 143
2016-01-14 22:51:35,215 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0003_01_000006 is : 143
2016-01-14 22:51:35,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0003_01_000004 is : 143
2016-01-14 22:51:35,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0003_01_000007 is : 143
2016-01-14 22:51:36,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0003_01_000005 is : 143
2016-01-14 22:51:37,473 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-01-14 22:51:37,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452811819222_0004
2016-01-14 22:51:37,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0004/
2016-01-14 22:51:55,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0004_01_000002 is : 143
2016-01-14 22:51:56,214 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0004_01_000003 is : 143
2016-01-14 22:51:56,819 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0004_01_000004 is : 143
2016-01-14 22:51:56,857 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0004_01_000006 is : 143
2016-01-14 22:51:57,025 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0004_01_000005 is : 143
2016-01-14 22:51:58,270 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-01-14 22:51:58,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  completed in: 01:07.964, using cpu time: 00:21.110
2016-01-14 22:51:58,303 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-01-14 22:51:58,341 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:51:58,342 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:51:58,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-01-14 22:51:58,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:51:58,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:51:58,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2016-01-14 22:51:58,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:51:58,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:51:58,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:51:58,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-01-14 22:51:58,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  parallel execution of steps is enabled: true
2016-01-14 22:51:58,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  executing total steps: 1
2016-01-14 22:51:58,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  allocating management threads: 1
2016-01-14 22:51:58,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-01-14 22:51:58,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452811819222_0005
2016-01-14 22:51:58,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0005/
2016-01-14 22:52:19,321 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0005_01_000002 is : 143
2016-01-14 22:52:19,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0005_01_000003 is : 143
2016-01-14 22:52:19,840 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0005_01_000007 is : 143
2016-01-14 22:52:19,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0005_01_000005 is : 143
2016-01-14 22:52:19,968 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0005_01_000006 is : 143
2016-01-14 22:52:20,179 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0005_01_000004 is : 143
2016-01-14 22:52:21,420 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-01-14 22:52:21,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  completed in: 00:22.956, using cpu time: 00:06.880
2016-01-14 22:52:21,450 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-01-14 22:52:21,482 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:52:21,483 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:52:21,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 22:52:21,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:52:21,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:52:21,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 22:52:21,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:52:21,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:52:21,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:52:21,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-01-14 22:52:21,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2016-01-14 22:52:21,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2016-01-14 22:52:21,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2016-01-14 22:52:21,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-01-14 22:52:21,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1452811819222_0006
2016-01-14 22:52:21,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0006/
2016-01-14 22:52:48,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0006_01_000003 is : 143
2016-01-14 22:52:48,549 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0006_01_000002 is : 143
2016-01-14 22:52:50,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0006_01_000008 is : 143
2016-01-14 22:52:50,300 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0006_01_000005 is : 143
2016-01-14 22:52:51,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0006_01_000009 is : 143
2016-01-14 22:52:51,219 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0006_01_000010 is : 143
2016-01-14 22:52:52,478 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-01-14 22:52:52,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:30.906, using cpu time: 00:09.650
2016-01-14 22:52:52,520 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-01-14 22:52:52,559 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:52:52,560 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:52:52,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 22:52:52,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:52:52,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:52:52,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting
2016-01-14 22:52:52,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:52:52,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:52:52,664 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:52:52,664 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-01-14 22:52:52,664 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  parallel execution of steps is enabled: true
2016-01-14 22:52:52,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  executing total steps: 1
2016-01-14 22:52:52,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  allocating management threads: 1
2016-01-14 22:52:52,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-01-14 22:52:52,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] submitted hadoop job: job_1452811819222_0007
2016-01-14 22:52:52,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0007/
2016-01-14 22:53:13,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0007_01_000003 is : 143
2016-01-14 22:53:14,113 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0007_01_000007 is : 143
2016-01-14 22:53:14,307 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0007_01_000006 is : 143
2016-01-14 22:53:14,409 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0007_01_000005 is : 143
2016-01-14 22:53:14,502 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0007_01_000004 is : 143
2016-01-14 22:53:15,757 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-01-14 22:53:15,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset]  completed in: 00:23.092, using cpu time: 00:07.000
2016-01-14 22:53:15,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-01-14 22:53:15,821 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:53:15,821 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:53:15,903 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-14 22:53:15,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:53:15,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:53:15,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-14 22:53:15,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:53:15,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:53:15,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:53:15,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-01-14 22:53:15,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  parallel execution of steps is enabled: true
2016-01-14 22:53:15,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  executing total steps: 1
2016-01-14 22:53:15,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  allocating management threads: 1
2016-01-14 22:53:15,923 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-01-14 22:53:16,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452811819222_0008
2016-01-14 22:53:16,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0008/
2016-01-14 22:53:43,316 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000003 is : 143
2016-01-14 22:53:44,785 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000005 is : 143
2016-01-14 22:53:44,887 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000007 is : 143
2016-01-14 22:53:44,955 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000010 is : 143
2016-01-14 22:53:45,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000009 is : 143
2016-01-14 22:53:45,028 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000006 is : 143
2016-01-14 22:53:45,693 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000004 is : 143
2016-01-14 22:53:45,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0008_01_000008 is : 143
2016-01-14 22:53:47,159 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-01-14 22:53:47,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  completed in: 00:31.236, using cpu time: 00:09.760
2016-01-14 22:53:47,191 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-01-14 22:53:47,229 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:53:47,230 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:53:47,328 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-01-14 22:53:47,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 22:53:47,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:53:47,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2016-01-14 22:53:47,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:53:47,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:53:47,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:53:47,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-01-14 22:53:47,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2016-01-14 22:53:47,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  executing total steps: 2
2016-01-14 22:53:47,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  allocating management threads: 2
2016-01-14 22:53:47,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/2)
2016-01-14 22:53:47,474 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-14 22:53:47,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452811819222_0009
2016-01-14 22:53:47,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0009/
2016-01-14 22:54:07,668 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0009_01_000006 is : 143
2016-01-14 22:54:08,207 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0009_01_000004 is : 143
2016-01-14 22:54:08,297 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0009_01_000007 is : 143
2016-01-14 22:54:08,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0009_01_000005 is : 143
2016-01-14 22:54:08,739 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0009_01_000003 is : 143
2016-01-14 22:54:08,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0009_01_000002 is : 143
2016-01-14 22:54:10,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-01-14 22:54:10,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452811819222_0010
2016-01-14 22:54:10,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0010/
2016-01-14 22:54:28,262 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0010_01_000006 is : 143
2016-01-14 22:54:29,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0010_01_000003 is : 143
2016-01-14 22:54:29,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0010_01_000004 is : 143
2016-01-14 22:54:29,381 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0010_01_000002 is : 143
2016-01-14 22:54:29,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0010_01_000005 is : 143
2016-01-14 22:54:30,799 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-01-14 22:54:30,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  completed in: 00:43.419, using cpu time: 00:13.790
2016-01-14 22:54:30,823 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-01-14 22:54:30,872 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:54:30,873 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:54:30,911 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 22:54:30,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:54:30,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:54:30,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-14 22:54:30,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 22:54:30,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-01-14 22:54:30,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2016-01-14 22:54:30,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2016-01-14 22:54:30,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2016-01-14 22:54:30,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-01-14 22:54:31,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1452811819222_0011
2016-01-14 22:54:31,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0011/
2016-01-14 22:54:47,387 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0011_01_000002 is : 143
2016-01-14 22:54:47,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0011_01_000005 is : 143
2016-01-14 22:54:48,519 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0011_01_000003 is : 143
2016-01-14 22:54:49,742 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-01-14 22:54:49,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:18.816, using cpu time: 00:04.260
2016-01-14 22:54:49,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-01-14 22:54:49,794 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:54:49,795 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:54:49,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-14 22:54:49,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:54:49,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:54:49,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-14 22:54:49,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:54:49,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:54:49,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:54:49,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-01-14 22:54:49,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  parallel execution of steps is enabled: true
2016-01-14 22:54:49,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  executing total steps: 1
2016-01-14 22:54:49,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  allocating management threads: 1
2016-01-14 22:54:49,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-01-14 22:54:50,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1452811819222_0012
2016-01-14 22:54:50,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0012/
2016-01-14 22:55:09,848 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0012_01_000006 is : 143
2016-01-14 22:55:10,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0012_01_000007 is : 143
2016-01-14 22:55:10,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0012_01_000005 is : 143
2016-01-14 22:55:11,331 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0012_01_000002 is : 143
2016-01-14 22:55:11,360 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0012_01_000004 is : 143
2016-01-14 22:55:11,711 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0012_01_000003 is : 143
2016-01-14 22:55:12,960 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-01-14 22:55:12,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  completed in: 00:23.094, using cpu time: 00:06.840
2016-01-14 22:55:12,987 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-01-14 22:55:13,014 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:55:13,014 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:55:13,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-14 22:55:13,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:55:13,032 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-01-14 22:55:13,047 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:55:13,047 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:55:13,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-01-14 22:55:13,122 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:55:13,122 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:55:13,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-14 22:55:13,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:55:13,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:55:13,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:55:13,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-01-14 22:55:13,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  parallel execution of steps is enabled: true
2016-01-14 22:55:13,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  executing total steps: 1
2016-01-14 22:55:13,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  allocating management threads: 1
2016-01-14 22:55:13,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-01-14 22:55:13,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452811819222_0013
2016-01-14 22:55:13,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0013/
2016-01-14 22:55:40,152 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000002 is : 143
2016-01-14 22:55:41,542 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000006 is : 143
2016-01-14 22:55:41,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000010 is : 143
2016-01-14 22:55:41,697 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000005 is : 143
2016-01-14 22:55:41,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000004 is : 143
2016-01-14 22:55:41,986 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000008 is : 143
2016-01-14 22:55:41,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000007 is : 143
2016-01-14 22:55:42,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000009 is : 143
2016-01-14 22:55:46,547 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0013_01_000011 is : 143
2016-01-14 22:55:47,777 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-01-14 22:55:47,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  completed in: 00:34.632, using cpu time: 00:11.350
2016-01-14 22:55:47,807 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-01-14 22:55:47,831 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:55:47,831 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:55:47,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-14 22:55:47,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 22:55:47,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:55:47,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2016-01-14 22:55:47,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:55:47,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:55:47,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:55:47,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-01-14 22:55:47,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2016-01-14 22:55:47,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  executing total steps: 3
2016-01-14 22:55:47,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  allocating management threads: 3
2016-01-14 22:55:47,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/3)
2016-01-14 22:55:48,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452811819222_0014
2016-01-14 22:55:48,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0014/
2016-01-14 22:56:08,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0014_01_000002 is : 143
2016-01-14 22:56:09,337 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0014_01_000005 is : 143
2016-01-14 22:56:09,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0014_01_000007 is : 143
2016-01-14 22:56:09,931 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0014_01_000006 is : 143
2016-01-14 22:56:11,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/3)
2016-01-14 22:56:11,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452811819222_0015
2016-01-14 22:56:11,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0015/
2016-01-14 22:56:30,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0015_01_000005 is : 143
2016-01-14 22:56:30,647 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0015_01_000006 is : 143
2016-01-14 22:56:30,713 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0015_01_000003 is : 143
2016-01-14 22:56:30,791 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0015_01_000004 is : 143
2016-01-14 22:56:31,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-01-14 22:56:32,128 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452811819222_0016
2016-01-14 22:56:32,128 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0016/
2016-01-14 22:56:50,374 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0016_01_000002 is : 143
2016-01-14 22:56:50,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0016_01_000003 is : 143
2016-01-14 22:56:51,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0016_01_000004 is : 143
2016-01-14 22:56:51,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0016_01_000005 is : 143
2016-01-14 22:56:51,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0016_01_000006 is : 143
2016-01-14 22:56:52,694 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-01-14 22:56:52,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset]  completed in: 01:04.739, using cpu time: 00:19.580
2016-01-14 22:56:52,718 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-01-14 22:56:52,742 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:56:52,743 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:56:52,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 22:56:52,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:56:52,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:56:52,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-14 22:56:52,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:56:52,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:56:52,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:56:52,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-01-14 22:56:52,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  parallel execution of steps is enabled: true
2016-01-14 22:56:52,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  executing total steps: 1
2016-01-14 22:56:52,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  allocating management threads: 1
2016-01-14 22:56:52,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-01-14 22:56:52,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1452811819222_0017
2016-01-14 22:56:52,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0017/
2016-01-14 22:57:13,222 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0017_01_000003 is : 143
2016-01-14 22:57:14,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0017_01_000006 is : 143
2016-01-14 22:57:14,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0017_01_000005 is : 143
2016-01-14 22:57:14,302 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0017_01_000007 is : 143
2016-01-14 22:57:14,349 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0017_01_000002 is : 143
2016-01-14 22:57:14,404 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0017_01_000004 is : 143
2016-01-14 22:57:15,668 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-01-14 22:57:15,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  completed in: 00:22.866, using cpu time: 00:06.920
2016-01-14 22:57:15,692 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-01-14 22:57:15,719 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:57:15,719 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:57:15,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 22:57:15,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 22:57:15,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:57:15,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-14 22:57:15,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:57:15,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:57:15,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:57:15,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-01-14 22:57:15,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  parallel execution of steps is enabled: true
2016-01-14 22:57:15,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  executing total steps: 1
2016-01-14 22:57:15,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  allocating management threads: 1
2016-01-14 22:57:15,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-01-14 22:57:15,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1452811819222_0018
2016-01-14 22:57:15,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0018/
2016-01-14 22:57:42,638 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000003 is : 143
2016-01-14 22:57:42,796 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000002 is : 143
2016-01-14 22:57:44,283 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000009 is : 143
2016-01-14 22:57:44,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000007 is : 143
2016-01-14 22:57:44,610 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000008 is : 143
2016-01-14 22:57:44,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000010 is : 143
2016-01-14 22:57:44,894 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000005 is : 143
2016-01-14 22:57:44,954 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000006 is : 143
2016-01-14 22:57:45,052 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000004 is : 143
2016-01-14 22:57:49,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0018_01_000011 is : 143
2016-01-14 22:57:50,532 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-01-14 22:57:50,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset]  completed in: 00:34.745, using cpu time: 00:11.400
2016-01-14 22:57:50,550 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-01-14 22:57:50,567 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:57:50,568 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:57:50,639 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-01-14 22:57:50,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 22:57:50,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:57:50,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-14 22:57:50,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:57:50,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-01-14 22:57:50,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  parallel execution of steps is enabled: true
2016-01-14 22:57:50,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  executing total steps: 2
2016-01-14 22:57:50,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  allocating management threads: 2
2016-01-14 22:57:50,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/2)
2016-01-14 22:57:50,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452811819222_0019
2016-01-14 22:57:50,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0019/
2016-01-14 22:58:09,199 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0019_01_000006 is : 143
2016-01-14 22:58:09,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0019_01_000002 is : 143
2016-01-14 22:58:09,706 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0019_01_000003 is : 143
2016-01-14 22:58:09,761 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0019_01_000005 is : 143
2016-01-14 22:58:09,826 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0019_01_000004 is : 143
2016-01-14 22:58:15,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0019_01_000007 is : 143
2016-01-14 22:58:16,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-01-14 22:58:16,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452811819222_0020
2016-01-14 22:58:16,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0020/
2016-01-14 22:58:37,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000002 is : 143
2016-01-14 22:58:37,755 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000003 is : 143
2016-01-14 22:58:38,067 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000004 is : 143
2016-01-14 22:58:38,115 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000006 is : 143
2016-01-14 22:58:38,143 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000005 is : 143
2016-01-14 22:58:38,164 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000007 is : 143
2016-01-14 22:58:43,908 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0020_01_000008 is : 143
2016-01-14 22:58:45,164 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-01-14 22:58:45,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset]  completed in: 00:54.484, using cpu time: 00:14.470
2016-01-14 22:58:45,187 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-01-14 22:58:45,207 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:58:45,208 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:58:45,297 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-01-14 22:58:45,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 22:58:45,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:58:45,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2016-01-14 22:58:45,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:58:45,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:58:45,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:58:45,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-01-14 22:58:45,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  parallel execution of steps is enabled: true
2016-01-14 22:58:45,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  executing total steps: 3
2016-01-14 22:58:45,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  allocating management threads: 3
2016-01-14 22:58:45,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/3)
2016-01-14 22:58:45,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452811819222_0021
2016-01-14 22:58:45,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0021/
2016-01-14 22:59:05,758 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0021_01_000007 is : 143
2016-01-14 22:59:06,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0021_01_000006 is : 143
2016-01-14 22:59:06,214 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0021_01_000004 is : 143
2016-01-14 22:59:06,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0021_01_000005 is : 143
2016-01-14 22:59:06,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0021_01_000003 is : 143
2016-01-14 22:59:06,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0021_01_000002 is : 143
2016-01-14 22:59:08,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (2/3)
2016-01-14 22:59:08,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452811819222_0022
2016-01-14 22:59:08,297 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0022/
2016-01-14 22:59:28,741 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0022_01_000002 is : 143
2016-01-14 22:59:28,860 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0022_01_000003 is : 143
2016-01-14 22:59:29,453 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0022_01_000005 is : 143
2016-01-14 22:59:29,808 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0022_01_000007 is : 143
2016-01-14 22:59:29,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0022_01_000006 is : 143
2016-01-14 22:59:30,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0022_01_000004 is : 143
2016-01-14 22:59:32,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-01-14 22:59:32,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452811819222_0023
2016-01-14 22:59:32,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0023/
2016-01-14 22:59:53,217 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0023_01_000003 is : 143
2016-01-14 22:59:53,388 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0023_01_000002 is : 143
2016-01-14 22:59:53,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0023_01_000005 is : 143
2016-01-14 22:59:53,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0023_01_000004 is : 143
2016-01-14 22:59:54,280 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0023_01_000006 is : 143
2016-01-14 22:59:55,532 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-01-14 22:59:55,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset]  completed in: 01:10.196, using cpu time: 00:22.050
2016-01-14 22:59:55,558 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-01-14 22:59:55,585 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:59:55,585 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 22:59:55,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 22:59:55,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:59:55,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:59:55,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2016-01-14 22:59:55,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 22:59:55,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 22:59:55,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 22:59:55,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-01-14 22:59:55,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  parallel execution of steps is enabled: true
2016-01-14 22:59:55,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  executing total steps: 1
2016-01-14 22:59:55,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  allocating management threads: 1
2016-01-14 22:59:55,649 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-01-14 22:59:55,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1452811819222_0024
2016-01-14 22:59:55,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0024/
2016-01-14 23:00:13,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0024_01_000004 is : 143
2016-01-14 23:00:14,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0024_01_000003 is : 143
2016-01-14 23:00:14,178 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0024_01_000002 is : 143
2016-01-14 23:00:14,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0024_01_000006 is : 143
2016-01-14 23:00:14,688 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0024_01_000005 is : 143
2016-01-14 23:00:15,927 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-01-14 23:00:15,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  completed in: 00:20.277, using cpu time: 00:05.570
2016-01-14 23:00:15,949 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-01-14 23:00:15,979 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:00:15,979 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:00:16,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 23:00:16,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:00:16,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:00:16,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting
2016-01-14 23:00:16,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/apache.10.txt"]
2016-01-14 23:00:16,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-01-14 23:00:16,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  parallel execution of steps is enabled: true
2016-01-14 23:00:16,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  executing total steps: 1
2016-01-14 23:00:16,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  allocating management threads: 1
2016-01-14 23:00:16,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-01-14 23:00:16,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] submitted hadoop job: job_1452811819222_0025
2016-01-14 23:00:16,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0025/
2016-01-14 23:00:32,375 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0025_01_000004 is : 143
2016-01-14 23:00:32,546 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0025_01_000003 is : 143
2016-01-14 23:00:32,570 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0025_01_000002 is : 143
2016-01-14 23:00:33,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0025_01_000005 is : 143
2016-01-14 23:00:34,667 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-01-14 23:00:34,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second]  completed in: 00:18.625, using cpu time: 00:04.160
2016-01-14 23:00:34,689 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-01-14 23:00:34,713 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:00:34,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:00:34,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-14 23:00:34,776 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 23:00:34,776 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:00:34,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2016-01-14 23:00:34,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 23:00:34,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 23:00:34,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 23:00:34,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-01-14 23:00:34,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  parallel execution of steps is enabled: true
2016-01-14 23:00:34,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  executing total steps: 2
2016-01-14 23:00:34,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  allocating management threads: 2
2016-01-14 23:00:34,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/2)
2016-01-14 23:00:34,975 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1452811819222_0026
2016-01-14 23:00:34,976 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0026/
2016-01-14 23:00:55,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0026_01_000002 is : 143
2016-01-14 23:00:55,941 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0026_01_000004 is : 143
2016-01-14 23:00:56,008 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0026_01_000006 is : 143
2016-01-14 23:00:56,120 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0026_01_000003 is : 143
2016-01-14 23:00:56,230 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0026_01_000007 is : 143
2016-01-14 23:00:56,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0026_01_000005 is : 143
2016-01-14 23:00:57,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-01-14 23:00:57,723 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1452811819222_0027
2016-01-14 23:00:57,723 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0027/
2016-01-14 23:01:16,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0027_01_000006 is : 143
2016-01-14 23:01:16,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0027_01_000003 is : 143
2016-01-14 23:01:16,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0027_01_000005 is : 143
2016-01-14 23:01:16,833 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0027_01_000002 is : 143
2016-01-14 23:01:16,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0027_01_000004 is : 143
2016-01-14 23:01:18,092 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-01-14 23:01:18,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge]  completed in: 00:43.292, using cpu time: 00:13.700
2016-01-14 23:01:18,114 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-01-14 23:01:18,149 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:01:18,149 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:01:18,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.105
2016-01-14 23:01:18,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 23:01:18,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:01:18,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting
2016-01-14 23:01:18,291 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 23:01:18,291 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 23:01:18,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 23:01:18,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-01-14 23:01:18,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  parallel execution of steps is enabled: true
2016-01-14 23:01:18,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  executing total steps: 3
2016-01-14 23:01:18,293 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  allocating management threads: 3
2016-01-14 23:01:18,295 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (1/3)
2016-01-14 23:01:18,427 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1452811819222_0028
2016-01-14 23:01:18,427 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0028/
2016-01-14 23:01:39,541 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0028_01_000004 is : 143
2016-01-14 23:01:39,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0028_01_000003 is : 143
2016-01-14 23:01:39,763 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0028_01_000005 is : 143
2016-01-14 23:01:39,944 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0028_01_000006 is : 143
2016-01-14 23:01:40,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0028_01_000002 is : 143
2016-01-14 23:01:41,090 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0028_01_000007 is : 143
2016-01-14 23:01:42,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (2/3)
2016-01-14 23:01:42,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1452811819222_0029
2016-01-14 23:01:42,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0029/
2016-01-14 23:02:01,050 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0029_01_000006 is : 143
2016-01-14 23:02:01,427 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0029_01_000004 is : 143
2016-01-14 23:02:01,491 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0029_01_000002 is : 143
2016-01-14 23:02:01,674 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0029_01_000005 is : 143
2016-01-14 23:02:01,736 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0029_01_000003 is : 143
2016-01-14 23:02:02,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-01-14 23:02:03,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1452811819222_0030
2016-01-14 23:02:03,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0030/
2016-01-14 23:02:22,095 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0030_01_000002 is : 143
2016-01-14 23:02:22,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0030_01_000006 is : 143
2016-01-14 23:02:22,278 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0030_01_000003 is : 143
2016-01-14 23:02:22,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0030_01_000005 is : 143
2016-01-14 23:02:22,610 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0030_01_000004 is : 143
2016-01-14 23:02:23,860 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-01-14 23:02:23,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1]  completed in: 01:05.565, using cpu time: 00:20.460
2016-01-14 23:02:23,892 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-01-14 23:02:23,917 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:02:23,918 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 23:02:24,001 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2016-01-14 23:02:24,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 23:02:24,004 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:02:24,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2016-01-14 23:02:24,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 23:02:24,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 23:02:24,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 23:02:24,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-01-14 23:02:24,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  parallel execution of steps is enabled: true
2016-01-14 23:02:24,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  executing total steps: 2
2016-01-14 23:02:24,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  allocating management threads: 2
2016-01-14 23:02:24,031 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/2)
2016-01-14 23:02:24,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452811819222_0031
2016-01-14 23:02:24,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0031/
2016-01-14 23:02:44,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0031_01_000003 is : 143
2016-01-14 23:02:45,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0031_01_000006 is : 143
2016-01-14 23:02:45,185 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0031_01_000007 is : 143
2016-01-14 23:02:45,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0031_01_000004 is : 143
2016-01-14 23:02:45,460 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0031_01_000002 is : 143
2016-01-14 23:02:45,712 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0031_01_000005 is : 143
2016-01-14 23:02:46,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-01-14 23:02:47,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452811819222_0032
2016-01-14 23:02:47,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:57774/proxy/application_1452811819222_0032/
2016-01-14 23:03:05,020 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0032_01_000006 is : 143
2016-01-14 23:03:05,671 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0032_01_000002 is : 143
2016-01-14 23:03:05,972 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0032_01_000005 is : 143
2016-01-14 23:03:06,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0032_01_000003 is : 143
2016-01-14 23:03:06,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452811819222_0032_01_000004 is : 143
2016-01-14 23:03:07,409 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-01-14 23:03:07,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2]  completed in: 00:43.378, using cpu time: 00:13.920
2016-01-14 23:03:07,432 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge

Standard error

Jan 14, 2016 10:50:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jan 14, 2016 10:50:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 10:50:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 10:50:19 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 10:50:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Jan 14, 2016 10:50:20 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 10:50:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 10:50:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jan 14, 2016 10:50:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 10:50:20 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 10:50:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:21 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 10:50:21 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:22 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 10:50:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 10:50:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 10:50:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 10:50:22 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 10:50:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:23 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 10:50:23 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 10:50:23 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.