2016-01-15 03:47:30,562 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 03:47:30,593 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2016-01-15 03:47:30,630 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-15 03:47:31,801 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-15 03:47:32,521 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-15 03:47:37,287 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-15 03:47:37,507 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-15 03:47:37,691 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-15 03:47:37,875 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for 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-15 03:47:54,983 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 03:47:55,105 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:47:55,106 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-15 03:47:55,171 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 29FD6A3791B84329BEB7A9181DDE6F60
2016-01-15 03:47:55,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.107
2016-01-15 03:47:55,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:47:55,325 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-15 03:47:55,457 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 03:47:55,459 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-15 03:47:55,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:47:55,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:47:55,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-01-15 03:47:55,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2016-01-15 03:47:55,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2016-01-15 03:47:55,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2016-01-15 03:47:55,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-01-15 03:47:56,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1452829669482_0001
2016-01-15 03:47:56,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0001/
2016-01-15 03:48:17,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0001_01_000002 is : 143
2016-01-15 03:48:17,961 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0001_01_000003 is : 143
2016-01-15 03:48:19,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0001_01_000007 is : 143
2016-01-15 03:48:19,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0001_01_000006 is : 143
2016-01-15 03:48:19,558 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0001_01_000004 is : 143
2016-01-15 03:48:19,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0001_01_000005 is : 143
2016-01-15 03:48:21,163 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-01-15 03:48:21,165 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:25.701, using cpu time: 00:06.430
2016-01-15 03:48:21,261 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge
2016-01-15 03:48:21,334 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:48:21,334 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-15 03:48:21,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.186
2016-01-15 03:48:21,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-15 03:48:21,537 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-15 03:48:21,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2016-01-15 03:48:21,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:48:21,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:48:21,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:48:21,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-01-15 03:48:21,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] parallel execution of steps is enabled: true
2016-01-15 03:48:21,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executing total steps: 3
2016-01-15 03:48:21,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] allocating management threads: 3
2016-01-15 03:48:21,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/3)
2016-01-15 03:48:21,700 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 03:48:21,701 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2016-01-15 03:48:21,701 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2016-01-15 03:48:21,805 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452829669482_0002
2016-01-15 03:48:21,805 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0002/
2016-01-15 03:48:47,680 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0002_01_000007 is : 143
2016-01-15 03:48:48,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0002_01_000005 is : 143
2016-01-15 03:48:49,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0002_01_000004 is : 143
2016-01-15 03:48:49,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0002_01_000002 is : 143
2016-01-15 03:48:49,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0002_01_000003 is : 143
2016-01-15 03:48:50,524 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/3)
2016-01-15 03:48:50,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452829669482_0003
2016-01-15 03:48:50,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0003/
2016-01-15 03:49:16,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0003_01_000005 is : 143
2016-01-15 03:49:16,917 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0003_01_000003 is : 143
2016-01-15 03:49:17,562 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0003_01_000006 is : 143
2016-01-15 03:49:17,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0003_01_000004 is : 143
2016-01-15 03:49:17,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0003_01_000002 is : 143
2016-01-15 03:49:17,976 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0003_01_000007 is : 143
2016-01-15 03:49:19,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-01-15 03:49:19,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452829669482_0004
2016-01-15 03:49:19,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0004/
2016-01-15 03:49:43,261 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0004_01_000002 is : 143
2016-01-15 03:49:44,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0004_01_000006 is : 143
2016-01-15 03:49:44,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0004_01_000003 is : 143
2016-01-15 03:49:44,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0004_01_000004 is : 143
2016-01-15 03:49:44,663 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0004_01_000005 is : 143
2016-01-15 03:49:45,864 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-01-15 03:49:45,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] completed in: 01:24.252, using cpu time: 00:21.670
2016-01-15 03:49:45,896 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-01-15 03:49:45,937 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:49:45,938 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-15 03:49:46,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-01-15 03:49:46,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:49:46,026 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-15 03:49:46,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2016-01-15 03:49:46,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:49:46,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:49:46,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:49:46,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-01-15 03:49:46,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] parallel execution of steps is enabled: true
2016-01-15 03:49:46,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executing total steps: 1
2016-01-15 03:49:46,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] allocating management threads: 1
2016-01-15 03:49:46,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-01-15 03:49:46,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452829669482_0005
2016-01-15 03:49:46,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0005/
2016-01-15 03:50:12,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0005_01_000002 is : 143
2016-01-15 03:50:12,877 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0005_01_000005 is : 143
2016-01-15 03:50:13,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0005_01_000004 is : 143
2016-01-15 03:50:13,431 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0005_01_000003 is : 143
2016-01-15 03:50:13,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0005_01_000006 is : 143
2016-01-15 03:50:13,885 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0005_01_000007 is : 143
2016-01-15 03:50:15,088 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-01-15 03:50:15,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] completed in: 00:29.036, using cpu time: 00:07.150
2016-01-15 03:50:15,120 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-01-15 03:50:15,156 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:50:15,156 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-15 03:50:15,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-15 03:50:15,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:50:15,222 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-15 03:50:15,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-15 03:50:15,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:50:15,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:50:15,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:50:15,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-01-15 03:50:15,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2016-01-15 03:50:15,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2016-01-15 03:50:15,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2016-01-15 03:50:15,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-01-15 03:50:15,401 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1452829669482_0006
2016-01-15 03:50:15,402 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0006/
2016-01-15 03:50:49,563 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0006_01_000009 is : 143
2016-01-15 03:50:49,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0006_01_000010 is : 143
2016-01-15 03:50:50,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0006_01_000008 is : 143
2016-01-15 03:50:50,837 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0006_01_000004 is : 143
2016-01-15 03:50:50,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0006_01_000005 is : 143
2016-01-15 03:50:50,972 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0006_01_000007 is : 143
2016-01-15 03:50:52,163 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-01-15 03:50:52,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:36.915, using cpu time: 00:10.040
2016-01-15 03:50:52,198 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-01-15 03:50:52,241 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:50:52,242 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-15 03:50:52,348 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.101
2016-01-15 03:50:52,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:50:52,351 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-15 03:50:52,373 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting
2016-01-15 03:50:52,373 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.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:50:52,373 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.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:50:52,374 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.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:50:52,374 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.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-01-15 03:50:52,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] parallel execution of steps is enabled: true
2016-01-15 03:50:52,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executing total steps: 1
2016-01-15 03:50:52,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] allocating management threads: 1
2016-01-15 03:50:52,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-01-15 03:50:52,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] submitted hadoop job: job_1452829669482_0007
2016-01-15 03:50:52,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0007/
2016-01-15 03:50:57,493 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452829669482_0006_01_000001
2016-01-15 03:51:18,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0007_01_000002 is : 143
2016-01-15 03:51:19,161 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0007_01_000003 is : 143
2016-01-15 03:51:19,396 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0007_01_000007 is : 143
2016-01-15 03:51:19,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0007_01_000004 is : 143
2016-01-15 03:51:19,766 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0007_01_000005 is : 143
2016-01-15 03:51:19,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0007_01_000006 is : 143
2016-01-15 03:51:21,015 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-01-15 03:51:21,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] completed in: 00:28.640, using cpu time: 00:07.290
2016-01-15 03:51:21,046 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-01-15 03:51:21,079 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:51:21,080 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-15 03:51:21,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-15 03:51:21,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:51:21,139 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-15 03:51:21,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-15 03:51:21,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:51:21,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:51:21,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:51:21,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-01-15 03:51:21,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2016-01-15 03:51:21,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 1
2016-01-15 03:51:21,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 1
2016-01-15 03:51:21,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-01-15 03:51:21,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452829669482_0008
2016-01-15 03:51:21,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0008/
2016-01-15 03:51:56,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000010 is : 143
2016-01-15 03:51:56,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000004 is : 143
2016-01-15 03:51:56,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000008 is : 143
2016-01-15 03:51:57,021 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000007 is : 143
2016-01-15 03:51:57,087 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000005 is : 143
2016-01-15 03:51:57,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000009 is : 143
2016-01-15 03:51:57,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0008_01_000006 is : 143
2016-01-15 03:51:58,425 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-01-15 03:51:58,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 00:37.267, using cpu time: 00:10.120
2016-01-15 03:51:58,462 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-01-15 03:51:58,514 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:51:58,514 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-15 03:51:58,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-01-15 03:51:58,621 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-15 03:51:58,622 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-15 03:51:58,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2016-01-15 03:51:58,663 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.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:51:58,663 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.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:51:58,664 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.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:51:58,665 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.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-01-15 03:51:58,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-01-15 03:51:58,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executing total steps: 2
2016-01-15 03:51:58,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] allocating management threads: 2
2016-01-15 03:51:58,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/2)
2016-01-15 03:51:58,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452829669482_0009
2016-01-15 03:51:58,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0009/
2016-01-15 03:52:25,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0009_01_000003 is : 143
2016-01-15 03:52:25,912 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0009_01_000004 is : 143
2016-01-15 03:52:26,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0009_01_000006 is : 143
2016-01-15 03:52:26,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0009_01_000007 is : 143
2016-01-15 03:52:26,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0009_01_000005 is : 143
2016-01-15 03:52:26,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0009_01_000002 is : 143
2016-01-15 03:52:27,609 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-01-15 03:52:27,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452829669482_0010
2016-01-15 03:52:27,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0010/
2016-01-15 03:52:52,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0010_01_000004 is : 143
2016-01-15 03:52:52,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0010_01_000003 is : 143
2016-01-15 03:52:52,749 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0010_01_000005 is : 143
2016-01-15 03:52:52,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0010_01_000006 is : 143
2016-01-15 03:52:54,037 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-01-15 03:52:54,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] completed in: 00:55.367, using cpu time: 00:14.180
2016-01-15 03:52:54,066 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-01-15 03:52:54,115 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:52:54,116 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-15 03:52:54,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-15 03:52:54,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:52:54,161 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-15 03:52:54,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-15 03:52:54,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 03:52:54,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-01-15 03:52:54,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] parallel execution of steps is enabled: true
2016-01-15 03:52:54,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executing total steps: 1
2016-01-15 03:52:54,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] allocating management threads: 1
2016-01-15 03:52:54,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-01-15 03:52:54,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1452829669482_0011
2016-01-15 03:52:54,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0011/
2016-01-15 03:53:15,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0011_01_000002 is : 143
2016-01-15 03:53:15,527 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0011_01_000003 is : 143
2016-01-15 03:53:15,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0011_01_000004 is : 143
2016-01-15 03:53:15,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0011_01_000005 is : 143
2016-01-15 03:53:17,096 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-01-15 03:53:17,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] completed in: 00:22.921, using cpu time: 00:04.320
2016-01-15 03:53:17,120 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-01-15 03:53:17,150 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:53:17,151 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-15 03:53:17,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-01-15 03:53:17,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:53:17,207 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-15 03:53:17,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-15 03:53:17,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:53:17,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:53:17,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:53:17,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-01-15 03:53:17,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2016-01-15 03:53:17,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2016-01-15 03:53:17,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2016-01-15 03:53:17,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-01-15 03:53:17,360 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1452829669482_0012
2016-01-15 03:53:17,360 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0012/
2016-01-15 03:53:44,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0012_01_000003 is : 143
2016-01-15 03:53:44,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0012_01_000004 is : 143
2016-01-15 03:53:44,360 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0012_01_000002 is : 143
2016-01-15 03:53:44,616 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0012_01_000007 is : 143
2016-01-15 03:53:44,770 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0012_01_000005 is : 143
2016-01-15 03:53:44,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0012_01_000006 is : 143
2016-01-15 03:53:46,007 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-01-15 03:53:46,009 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:28.782, using cpu time: 00:07.230
2016-01-15 03:53:46,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-01-15 03:53:46,064 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:53:46,064 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-15 03:53:46,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-01-15 03:53:46,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 03:53:46,083 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-01-15 03:53:46,099 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:53:46,100 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-15 03:53:46,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-15 03:53:46,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:53:46,179 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-15 03:53:46,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-15 03:53:46,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:53:46,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:53:46,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:53:46,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-01-15 03:53:46,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2016-01-15 03:53:46,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 1
2016-01-15 03:53:46,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 1
2016-01-15 03:53:46,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-01-15 03:53:46,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452829669482_0013
2016-01-15 03:53:46,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0013/
2016-01-15 03:54:18,574 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000003 is : 143
2016-01-15 03:54:19,260 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000002 is : 143
2016-01-15 03:54:20,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000004 is : 143
2016-01-15 03:54:20,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000008 is : 143
2016-01-15 03:54:20,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000005 is : 143
2016-01-15 03:54:20,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000007 is : 143
2016-01-15 03:54:20,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000009 is : 143
2016-01-15 03:54:21,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000010 is : 143
2016-01-15 03:54:25,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0013_01_000011 is : 143
2016-01-15 03:54:26,918 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-01-15 03:54:26,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 00:40.710, using cpu time: 00:11.640
2016-01-15 03:54:26,936 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-01-15 03:54:26,968 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:54:26,969 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-15 03:54:27,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.077
2016-01-15 03:54:27,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-15 03:54:27,052 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-15 03:54:27,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2016-01-15 03:54:27,082 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.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:54:27,082 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.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:54:27,082 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.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:54:27,083 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.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-01-15 03:54:27,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-01-15 03:54:27,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executing total steps: 3
2016-01-15 03:54:27,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] allocating management threads: 3
2016-01-15 03:54:27,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/3)
2016-01-15 03:54:27,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452829669482_0014
2016-01-15 03:54:27,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0014/
2016-01-15 03:54:52,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0014_01_000007 is : 143
2016-01-15 03:54:53,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0014_01_000006 is : 143
2016-01-15 03:54:54,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0014_01_000004 is : 143
2016-01-15 03:54:54,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0014_01_000002 is : 143
2016-01-15 03:54:54,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0014_01_000005 is : 143
2016-01-15 03:54:55,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0014_01_000003 is : 143
2016-01-15 03:54:56,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/3)
2016-01-15 03:54:56,758 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452829669482_0015
2016-01-15 03:54:56,758 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0015/
2016-01-15 03:55:21,751 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0015_01_000006 is : 143
2016-01-15 03:55:22,119 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0015_01_000002 is : 143
2016-01-15 03:55:22,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0015_01_000004 is : 143
2016-01-15 03:55:22,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0015_01_000005 is : 143
2016-01-15 03:55:22,722 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0015_01_000003 is : 143
2016-01-15 03:55:23,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-01-15 03:55:24,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1452829669482_0016
2016-01-15 03:55:24,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0016/
2016-01-15 03:55:24,534 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 03:55:24,534 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 03:55:24,534 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK, ARCHIVE], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2016-01-15 03:55:24,534 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) All required storage types are unavailable: unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2016-01-15 03:55:48,430 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0016_01_000006 is : 143
2016-01-15 03:55:48,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0016_01_000002 is : 143
2016-01-15 03:55:48,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0016_01_000003 is : 143
2016-01-15 03:55:48,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0016_01_000004 is : 143
2016-01-15 03:55:49,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0016_01_000005 is : 143
2016-01-15 03:55:50,306 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-01-15 03:55:50,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] completed in: 01:23.214, using cpu time: 00:20.130
2016-01-15 03:55:50,331 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-01-15 03:55:50,357 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:55:50,357 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-15 03:55:50,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-15 03:55:50,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:55:50,400 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-15 03:55:50,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-15 03:55:50,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:55:50,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:55:50,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:55:50,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-01-15 03:55:50,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2016-01-15 03:55:50,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2016-01-15 03:55:50,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2016-01-15 03:55:50,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-01-15 03:55:50,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1452829669482_0017
2016-01-15 03:55:50,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0017/
2016-01-15 03:56:17,359 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0017_01_000006 is : 143
2016-01-15 03:56:17,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0017_01_000002 is : 143
2016-01-15 03:56:17,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0017_01_000004 is : 143
2016-01-15 03:56:17,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0017_01_000007 is : 143
2016-01-15 03:56:17,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0017_01_000003 is : 143
2016-01-15 03:56:18,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0017_01_000005 is : 143
2016-01-15 03:56:19,665 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-01-15 03:56:19,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:29.252, using cpu time: 00:07.110
2016-01-15 03:56:19,700 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-01-15 03:56:19,730 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:56:19,730 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-15 03:56:19,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-15 03:56:19,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 03:56:19,778 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-15 03:56:19,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2016-01-15 03:56:19,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:56:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:56:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:56:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-01-15 03:56:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2016-01-15 03:56:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2016-01-15 03:56:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2016-01-15 03:56:19,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-01-15 03:56:19,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1452829669482_0018
2016-01-15 03:56:19,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0018/
2016-01-15 03:56:53,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000010 is : 143
2016-01-15 03:56:54,502 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000002 is : 143
2016-01-15 03:56:54,829 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000009 is : 143
2016-01-15 03:56:54,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000004 is : 143
2016-01-15 03:56:55,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000006 is : 143
2016-01-15 03:56:55,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000005 is : 143
2016-01-15 03:56:55,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000003 is : 143
2016-01-15 03:57:00,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0018_01_000011 is : 143
2016-01-15 03:57:01,451 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-01-15 03:57:01,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:41.651, using cpu time: 00:12.140
2016-01-15 03:57:01,469 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-01-15 03:57:01,490 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:57:01,490 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-15 03:57:01,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.077
2016-01-15 03:57:01,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 03:57:01,576 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-15 03:57:01,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2016-01-15 03:57:01,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:57:01,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-01-15 03:57:01,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2016-01-15 03:57:01,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 2
2016-01-15 03:57:01,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 2
2016-01-15 03:57:01,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/2)
2016-01-15 03:57:01,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452829669482_0019
2016-01-15 03:57:01,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0019/
2016-01-15 03:57:26,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0019_01_000003 is : 143
2016-01-15 03:57:26,947 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0019_01_000005 is : 143
2016-01-15 03:57:27,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0019_01_000004 is : 143
2016-01-15 03:57:27,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0019_01_000002 is : 143
2016-01-15 03:57:27,396 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0019_01_000006 is : 143
2016-01-15 03:57:33,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0019_01_000007 is : 143
2016-01-15 03:57:34,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-01-15 03:57:34,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1452829669482_0020
2016-01-15 03:57:34,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0020/
2016-01-15 03:58:01,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0020_01_000006 is : 143
2016-01-15 03:58:01,670 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0020_01_000005 is : 143
2016-01-15 03:58:01,722 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0020_01_000002 is : 143
2016-01-15 03:58:01,887 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0020_01_000004 is : 143
2016-01-15 03:58:02,052 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0020_01_000003 is : 143
2016-01-15 03:58:08,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0020_01_000008 is : 143
2016-01-15 03:58:09,557 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-01-15 03:58:09,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 01:07.941, using cpu time: 00:14.860
2016-01-15 03:58:09,580 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-01-15 03:58:09,611 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:58:09,612 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-15 03:58:09,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-01-15 03:58:09,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-15 03:58:09,700 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-15 03:58:09,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2016-01-15 03:58:09,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:58:09,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:58:09,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:58:09,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-01-15 03:58:09,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] parallel execution of steps is enabled: true
2016-01-15 03:58:09,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executing total steps: 3
2016-01-15 03:58:09,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] allocating management threads: 3
2016-01-15 03:58:09,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/3)
2016-01-15 03:58:09,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452829669482_0021
2016-01-15 03:58:09,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0021/
2016-01-15 03:58:35,532 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0021_01_000003 is : 143
2016-01-15 03:58:37,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0021_01_000007 is : 143
2016-01-15 03:58:37,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0021_01_000002 is : 143
2016-01-15 03:58:37,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0021_01_000004 is : 143
2016-01-15 03:58:38,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0021_01_000005 is : 143
2016-01-15 03:58:38,345 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0021_01_000006 is : 143
2016-01-15 03:58:39,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (2/3)
2016-01-15 03:58:39,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452829669482_0022
2016-01-15 03:58:39,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0022/
2016-01-15 03:59:06,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0022_01_000003 is : 143
2016-01-15 03:59:06,909 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0022_01_000002 is : 143
2016-01-15 03:59:07,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0022_01_000005 is : 143
2016-01-15 03:59:07,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0022_01_000004 is : 143
2016-01-15 03:59:07,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0022_01_000007 is : 143
2016-01-15 03:59:08,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0022_01_000006 is : 143
2016-01-15 03:59:09,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-01-15 03:59:09,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1452829669482_0023
2016-01-15 03:59:09,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0023/
2016-01-15 03:59:09,567 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 03:59:09,567 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-15 03:59:09,567 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK, ARCHIVE], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2016-01-15 03:59:09,568 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(382)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) All required storage types are unavailable: unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2016-01-15 03:59:35,881 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0023_01_000003 is : 143
2016-01-15 03:59:36,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0023_01_000002 is : 143
2016-01-15 03:59:36,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0023_01_000005 is : 143
2016-01-15 03:59:36,842 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0023_01_000007 is : 143
2016-01-15 03:59:36,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0023_01_000006 is : 143
2016-01-15 03:59:37,119 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0023_01_000004 is : 143
2016-01-15 03:59:38,323 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-01-15 03:59:38,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] completed in: 01:28.587, using cpu time: 00:22.580
2016-01-15 03:59:38,350 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-01-15 03:59:38,380 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 03:59:38,380 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-15 03:59:38,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-15 03:59:38,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 03:59:38,418 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-15 03:59:38,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2016-01-15 03:59:38,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 03:59:38,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 03:59:38,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 03:59:38,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-01-15 03:59:38,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] parallel execution of steps is enabled: true
2016-01-15 03:59:38,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executing total steps: 1
2016-01-15 03:59:38,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] allocating management threads: 1
2016-01-15 03:59:38,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-01-15 03:59:38,547 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1452829669482_0024
2016-01-15 03:59:38,547 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0024/
2016-01-15 04:00:03,838 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0024_01_000006 is : 143
2016-01-15 04:00:04,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0024_01_000003 is : 143
2016-01-15 04:00:04,499 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0024_01_000005 is : 143
2016-01-15 04:00:04,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0024_01_000004 is : 143
2016-01-15 04:00:04,887 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0024_01_000002 is : 143
2016-01-15 04:00:06,078 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-01-15 04:00:06,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] completed in: 00:27.647, using cpu time: 00:05.850
2016-01-15 04:00:06,102 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-01-15 04:00:06,128 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:00:06,128 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-15 04:00:06,171 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-15 04:00:06,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 04:00:06,173 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-15 04:00:06,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting
2016-01-15 04:00:06,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-01-15 04:00:06,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-01-15 04:00:06,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] parallel execution of steps is enabled: true
2016-01-15 04:00:06,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executing total steps: 1
2016-01-15 04:00:06,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] allocating management threads: 1
2016-01-15 04:00:06,187 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-01-15 04:00:06,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] submitted hadoop job: job_1452829669482_0025
2016-01-15 04:00:06,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0025/
2016-01-15 04:00:27,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0025_01_000002 is : 143
2016-01-15 04:00:28,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0025_01_000003 is : 143
2016-01-15 04:00:28,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0025_01_000004 is : 143
2016-01-15 04:00:28,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0025_01_000005 is : 143
2016-01-15 04:00:29,654 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-01-15 04:00:29,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] completed in: 00:23.468, using cpu time: 00:04.370
2016-01-15 04:00:29,676 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-01-15 04:00:29,711 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:00:29,711 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-15 04:00:29,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2016-01-15 04:00:29,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-15 04:00:29,796 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-15 04:00:29,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2016-01-15 04:00:29,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:00:29,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:00:29,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 04:00:29,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-01-15 04:00:29,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] parallel execution of steps is enabled: true
2016-01-15 04:00:29,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executing total steps: 2
2016-01-15 04:00:29,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] allocating management threads: 2
2016-01-15 04:00:29,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/2)
2016-01-15 04:00:29,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1452829669482_0026
2016-01-15 04:00:29,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0026/
2016-01-15 04:00:35,430 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1452829669482_0025_01_000001
2016-01-15 04:00:57,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0026_01_000003 is : 143
2016-01-15 04:00:57,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0026_01_000006 is : 143
2016-01-15 04:00:57,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0026_01_000005 is : 143
2016-01-15 04:00:58,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0026_01_000007 is : 143
2016-01-15 04:00:59,298 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-01-15 04:00:59,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1452829669482_0027
2016-01-15 04:00:59,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0027/
2016-01-15 04:01:24,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0027_01_000002 is : 143
2016-01-15 04:01:24,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0027_01_000004 is : 143
2016-01-15 04:01:24,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0027_01_000003 is : 143
2016-01-15 04:01:25,024 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0027_01_000005 is : 143
2016-01-15 04:01:25,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0027_01_000006 is : 143
2016-01-15 04:01:26,681 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-01-15 04:01:26,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] completed in: 00:56.861, using cpu time: 00:13.630
2016-01-15 04:01:26,705 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-01-15 04:01:26,731 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:01:26,732 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-15 04:01:26,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-01-15 04:01:26,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-15 04:01:26,816 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-15 04:01:26,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting
2016-01-15 04:01:26,863 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.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:01:26,863 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.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:01:26,864 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.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 04:01:26,864 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.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-01-15 04:01:26,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] parallel execution of steps is enabled: true
2016-01-15 04:01:26,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executing total steps: 3
2016-01-15 04:01:26,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] allocating management threads: 3
2016-01-15 04:01:26,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (1/3)
2016-01-15 04:01:27,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1452829669482_0028
2016-01-15 04:01:27,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0028/
2016-01-15 04:01:54,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0028_01_000006 is : 143
2016-01-15 04:01:54,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0028_01_000003 is : 143
2016-01-15 04:01:54,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0028_01_000004 is : 143
2016-01-15 04:01:55,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0028_01_000005 is : 143
2016-01-15 04:01:55,070 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0028_01_000007 is : 143
2016-01-15 04:01:55,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0028_01_000002 is : 143
2016-01-15 04:01:56,699 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (2/3)
2016-01-15 04:01:56,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1452829669482_0029
2016-01-15 04:01:56,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0029/
2016-01-15 04:02:21,930 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0029_01_000003 is : 143
2016-01-15 04:02:22,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0029_01_000002 is : 143
2016-01-15 04:02:22,396 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0029_01_000004 is : 143
2016-01-15 04:02:22,777 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0029_01_000005 is : 143
2016-01-15 04:02:23,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0029_01_000006 is : 143
2016-01-15 04:02:24,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-01-15 04:02:24,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1452829669482_0030
2016-01-15 04:02:24,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0030/
2016-01-15 04:02:48,321 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0030_01_000002 is : 143
2016-01-15 04:02:48,487 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0030_01_000003 is : 143
2016-01-15 04:02:48,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0030_01_000004 is : 143
2016-01-15 04:02:49,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0030_01_000006 is : 143
2016-01-15 04:02:49,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0030_01_000005 is : 143
2016-01-15 04:02:50,616 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-01-15 04:02:50,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] completed in: 01:23.751, using cpu time: 00:20.290
2016-01-15 04:02:50,640 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-01-15 04:02:50,666 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 04:02:50,667 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-15 04:02:50,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-01-15 04:02:50,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-15 04:02:50,741 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-15 04:02:50,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2016-01-15 04:02:50,767 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-01-15 04:02:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-01-15 04:02:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-01-15 04:02:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-01-15 04:02:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] parallel execution of steps is enabled: true
2016-01-15 04:02:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executing total steps: 2
2016-01-15 04:02:50,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] allocating management threads: 2
2016-01-15 04:02:50,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/2)
2016-01-15 04:02:50,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452829669482_0031
2016-01-15 04:02:50,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0031/
2016-01-15 04:03:18,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0031_01_000003 is : 143
2016-01-15 04:03:18,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0031_01_000006 is : 143
2016-01-15 04:03:18,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0031_01_000005 is : 143
2016-01-15 04:03:19,215 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0031_01_000004 is : 143
2016-01-15 04:03:19,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0031_01_000002 is : 143
2016-01-15 04:03:19,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0031_01_000007 is : 143
2016-01-15 04:03:20,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-01-15 04:03:21,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1452829669482_0032
2016-01-15 04:03:21,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://ip-10-167-78-165:34566/proxy/application_1452829669482_0032/
2016-01-15 04:03:45,300 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0032_01_000002 is : 143
2016-01-15 04:03:45,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0032_01_000004 is : 143
2016-01-15 04:03:45,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0032_01_000005 is : 143
2016-01-15 04:03:45,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0032_01_000003 is : 143
2016-01-15 04:03:46,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1452829669482_0032_01_000006 is : 143
2016-01-15 04:03:47,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-01-15 04:03:47,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] completed in: 00:56.811, using cpu time: 00:14.160
2016-01-15 04:03:47,605 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge