Class cascading.MergePipesPlatformTest

all > cascading > MergePipesPlatformTest

tests

failures

ignored

18m6.25s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testGroupByAggregationMerge	1m26.23s	passed
testHashJoinMergeIntoHashJoinAccumulated	57.311s	passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulated	1m26.36s	passed
testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge	1m30.05s	passed
testHashJoinMergeIntoHashJoinAccumulatedStreamed	1m24.68s	passed
testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge	1m30.35s	passed
testHashJoinMergeIntoHashJoinStreamed	30.189s	passed
testHashJoinMergeIntoHashJoinStreamedAccumulated	57.925s	passed
testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge	57.629s	passed
testHashJoinMergeIntoHashJoinStreamedStreamed	29.353s	passed
testHashJoinMergeIntoHashJoinStreamedStreamedMerge	29.602s	passed
testMergeIntoHashJoinAccumulated	27.776s	passed
testMergeIntoHashJoinStreamed	29.453s	passed
testSameSourceMergeThreeChainGroup	1m8.69s	passed
testSimpleMerge	51.804s	passed
testSimpleMergeFail	0.036s	passed
testSimpleMergeThree	37.245s	passed
testSimpleMergeThreeChain	37.350s	passed
testSimpleMergeThreeChainCoGroup	41.496s	passed
testSimpleMergeThreeChainGroup	43.345s	passed
testSplitSameSourceMerged	24.729s	passed
testSplitSameSourceMergedComplex	24.660s	passed

Standard output

2016-05-18 10:29:12,233 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 10:29:12,262 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 10:29:12,298 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 10:29:13,465 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-05-18 10:29:14,164 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 10:29:19,024 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-05-18 10:29:19,264 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-05-18 10:29:19,441 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-05-18 10:29:19,617 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-05-18 10:29:36,710 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 10:29:36,829 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:29:36,830 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:29:36,895 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: A1D4980F6E7047EBBE6F3DFAA498EFD7
2016-05-18 10:29:37,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-05-18 10:29:37,033 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:29:37,033 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:29:37,167 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 10:29:37,168 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 10:29:37,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:29:37,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:29:37,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-05-18 10:29:37,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  parallel execution of steps is enabled: true
2016-05-18 10:29:37,171 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  executing total steps: 1
2016-05-18 10:29:37,171 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  allocating management threads: 1
2016-05-18 10:29:37,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-18 10:29:38,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463567371208_0001
2016-05-18 10:29:38,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0001/
2016-05-18 10:30:00,497 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0001_01_000003 is : 143
2016-05-18 10:30:01,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0001_01_000006 is : 143
2016-05-18 10:30:01,655 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0001_01_000002 is : 143
2016-05-18 10:30:01,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0001_01_000004 is : 143
2016-05-18 10:30:02,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0001_01_000005 is : 143
2016-05-18 10:30:02,690 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0001_01_000007 is : 143
2016-05-18 10:30:03,977 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-18 10:30:03,979 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  completed in: 00:26.806, using cpu time: 00:06.310
2016-05-18 10:30:04,073 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge
2016-05-18 10:30:04,157 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:30:04,158 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:30:04,364 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.193
2016-05-18 10:30:04,367 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 10:30:04,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:30:04,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-18 10:30:04,449 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:30:04,449 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:30:04,449 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:30:04,449 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-05-18 10:30:04,450 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  parallel execution of steps is enabled: true
2016-05-18 10:30:04,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  executing total steps: 3
2016-05-18 10:30:04,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  allocating management threads: 3
2016-05-18 10:30:04,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/3)
2016-05-18 10:30:04,624 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463567371208_0002
2016-05-18 10:30:04,624 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0002/
2016-05-18 10:30:33,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0002_01_000003 is : 143
2016-05-18 10:30:33,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0002_01_000005 is : 143
2016-05-18 10:30:33,746 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0002_01_000007 is : 143
2016-05-18 10:30:33,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0002_01_000004 is : 143
2016-05-18 10:30:34,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0002_01_000006 is : 143
2016-05-18 10:30:34,181 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0002_01_000002 is : 143
2016-05-18 10:30:35,382 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/3)
2016-05-18 10:30:35,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463567371208_0003
2016-05-18 10:30:35,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0003/
2016-05-18 10:31:03,589 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0003_01_000006 is : 143
2016-05-18 10:31:03,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0003_01_000003 is : 143
2016-05-18 10:31:03,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0003_01_000002 is : 143
2016-05-18 10:31:03,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0003_01_000007 is : 143
2016-05-18 10:31:04,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0003_01_000004 is : 143
2016-05-18 10:31:04,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0003_01_000005 is : 143
2016-05-18 10:31:05,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-05-18 10:31:05,859 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-05-18 10:31:05,859 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-05-18 10:31:05,860 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-05-18 10:31:06,094 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-05-18 10:31:06,094 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-05-18 10:31:06,094 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-05-18 10:31:06,095 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-05-18 10:31:06,095 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-05-18 10:31:06,095 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-05-18 10:31:06,096 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-05-18 10:31:06,096 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-05-18 10:31:06,139 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463567371208_0004
2016-05-18 10:31:06,139 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0004/
2016-05-18 10:31:11,671 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463567371208_0003_01_000001
2016-05-18 10:31:31,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0004_01_000005 is : 143
2016-05-18 10:31:32,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0004_01_000002 is : 143
2016-05-18 10:31:32,366 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0004_01_000004 is : 143
2016-05-18 10:31:32,708 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0004_01_000003 is : 143
2016-05-18 10:31:32,889 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0004_01_000006 is : 143
2016-05-18 10:31:34,105 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-05-18 10:31:34,108 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  completed in: 01:29.651, using cpu time: 00:21.420
2016-05-18 10:31:34,140 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-05-18 10:31:34,191 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:31:34,192 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:31:34,275 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-05-18 10:31:34,277 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:31:34,278 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:31:34,300 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-18 10:31:34,301 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:31:34,301 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:31:34,301 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:31:34,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-05-18 10:31:34,305 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  parallel execution of steps is enabled: true
2016-05-18 10:31:34,305 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  executing total steps: 1
2016-05-18 10:31:34,305 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  allocating management threads: 1
2016-05-18 10:31:34,306 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-05-18 10:31:34,463 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463567371208_0005
2016-05-18 10:31:34,463 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0005/
2016-05-18 10:32:00,641 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0005_01_000007 is : 143
2016-05-18 10:32:00,954 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0005_01_000006 is : 143
2016-05-18 10:32:02,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0005_01_000003 is : 143
2016-05-18 10:32:02,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0005_01_000002 is : 143
2016-05-18 10:32:02,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0005_01_000004 is : 143
2016-05-18 10:32:03,702 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-05-18 10:32:03,703 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  completed in: 00:29.399, using cpu time: 00:07.080
2016-05-18 10:32:03,741 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-05-18 10:32:03,779 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:32:03,780 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:32:03,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-05-18 10:32:03,862 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:32:03,862 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:32:03,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 10:32:03,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:32:03,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:32:03,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:32:03,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-18 10:32:03,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  parallel execution of steps is enabled: true
2016-05-18 10:32:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  executing total steps: 1
2016-05-18 10:32:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  allocating management threads: 1
2016-05-18 10:32:03,893 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-18 10:32:04,047 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463567371208_0006
2016-05-18 10:32:04,048 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0006/
2016-05-18 10:32:36,291 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000007 is : 143
2016-05-18 10:32:38,252 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000006 is : 143
2016-05-18 10:32:38,762 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000009 is : 143
2016-05-18 10:32:38,875 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000010 is : 143
2016-05-18 10:32:39,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000002 is : 143
2016-05-18 10:32:39,077 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000004 is : 143
2016-05-18 10:32:39,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000005 is : 143
2016-05-18 10:32:39,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0006_01_000008 is : 143
2016-05-18 10:32:40,935 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-18 10:32:40,937 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  completed in: 00:37.043, using cpu time: 00:10.220
2016-05-18 10:32:40,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-05-18 10:32:41,025 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:32:41,027 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:32:41,128 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2016-05-18 10:32:41,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:32:41,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:32:41,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting
2016-05-18 10:32:41,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:32:41,160 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:32:41,160 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:32:41,160 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-05-18 10:32:41,161 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  parallel execution of steps is enabled: true
2016-05-18 10:32:41,161 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  executing total steps: 1
2016-05-18 10:32:41,161 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  allocating management threads: 1
2016-05-18 10:32:41,162 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-05-18 10:32:41,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] submitted hadoop job: job_1463567371208_0007
2016-05-18 10:32:41,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0007/
2016-05-18 10:33:08,156 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0007_01_000002 is : 143
2016-05-18 10:33:08,692 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0007_01_000005 is : 143
2016-05-18 10:33:08,936 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0007_01_000004 is : 143
2016-05-18 10:33:09,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0007_01_000003 is : 143
2016-05-18 10:33:10,311 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-05-18 10:33:10,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset]  completed in: 00:29.151, using cpu time: 00:07.080
2016-05-18 10:33:10,341 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-05-18 10:33:10,384 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:33:10,385 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:33:10,443 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 10:33:10,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:33:10,445 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:33:10,467 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-18 10:33:10,468 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:33:10,468 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:33:10,469 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:33:10,469 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-05-18 10:33:10,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  parallel execution of steps is enabled: true
2016-05-18 10:33:10,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  executing total steps: 1
2016-05-18 10:33:10,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  allocating management threads: 1
2016-05-18 10:33:10,471 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-05-18 10:33:10,607 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463567371208_0008
2016-05-18 10:33:10,607 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0008/
2016-05-18 10:33:43,264 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000003 is : 143
2016-05-18 10:33:45,691 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000004 is : 143
2016-05-18 10:33:45,783 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000008 is : 143
2016-05-18 10:33:45,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000009 is : 143
2016-05-18 10:33:45,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000006 is : 143
2016-05-18 10:33:46,231 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000007 is : 143
2016-05-18 10:33:46,307 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000005 is : 143
2016-05-18 10:33:46,456 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0008_01_000010 is : 143
2016-05-18 10:33:47,651 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-05-18 10:33:47,652 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  completed in: 00:37.182, using cpu time: 00:10.070
2016-05-18 10:33:47,685 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-05-18 10:33:47,726 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:33:47,726 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:33:47,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.112
2016-05-18 10:33:47,846 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 10:33:47,846 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:33:47,887 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-18 10:33:47,888 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:33:47,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:33:47,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:33:47,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-05-18 10:33:47,892 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2016-05-18 10:33:47,892 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  executing total steps: 2
2016-05-18 10:33:47,893 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  allocating management threads: 2
2016-05-18 10:33:47,895 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/2)
2016-05-18 10:33:48,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463567371208_0009
2016-05-18 10:33:48,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0009/
2016-05-18 10:34:14,289 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0009_01_000007 is : 143
2016-05-18 10:34:15,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0009_01_000005 is : 143
2016-05-18 10:34:15,385 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0009_01_000006 is : 143
2016-05-18 10:34:15,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0009_01_000004 is : 143
2016-05-18 10:34:16,141 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0009_01_000003 is : 143
2016-05-18 10:34:16,944 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0009_01_000002 is : 143
2016-05-18 10:34:18,096 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-05-18 10:34:18,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463567371208_0010
2016-05-18 10:34:18,414 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0010/
2016-05-18 10:34:43,190 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0010_01_000004 is : 143
2016-05-18 10:34:43,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0010_01_000002 is : 143
2016-05-18 10:34:44,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0010_01_000005 is : 143
2016-05-18 10:34:44,400 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0010_01_000006 is : 143
2016-05-18 10:34:45,593 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-05-18 10:34:45,595 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  completed in: 00:57.698, using cpu time: 00:13.940
2016-05-18 10:34:45,619 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-05-18 10:34:45,673 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:34:45,674 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:34:45,714 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 10:34:45,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:34:45,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:34:45,731 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-18 10:34:45,732 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 10:34:45,732 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-18 10:34:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  parallel execution of steps is enabled: true
2016-05-18 10:34:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  executing total steps: 1
2016-05-18 10:34:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  allocating management threads: 1
2016-05-18 10:34:45,734 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-18 10:34:45,849 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463567371208_0011
2016-05-18 10:34:45,849 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0011/
2016-05-18 10:35:08,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0011_01_000002 is : 143
2016-05-18 10:35:08,961 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0011_01_000003 is : 143
2016-05-18 10:35:09,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0011_01_000004 is : 143
2016-05-18 10:35:09,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0011_01_000005 is : 143
2016-05-18 10:35:10,326 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-18 10:35:10,328 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged]  completed in: 00:24.593, using cpu time: 00:04.410
2016-05-18 10:35:10,351 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-18 10:35:10,380 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:35:10,380 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:35:10,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 10:35:10,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:35:10,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:35:10,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-18 10:35:10,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:35:10,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:35:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:35:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-05-18 10:35:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  parallel execution of steps is enabled: true
2016-05-18 10:35:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  executing total steps: 1
2016-05-18 10:35:10,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  allocating management threads: 1
2016-05-18 10:35:10,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-18 10:35:10,986 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463567371208_0012
2016-05-18 10:35:10,986 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0012/
2016-05-18 10:35:16,389 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463567371208_0011_01_000001
2016-05-18 10:35:38,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0012_01_000007 is : 143
2016-05-18 10:35:38,564 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0012_01_000006 is : 143
2016-05-18 10:35:39,004 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0012_01_000003 is : 143
2016-05-18 10:35:39,161 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0012_01_000002 is : 143
2016-05-18 10:35:39,198 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0012_01_000005 is : 143
2016-05-18 10:35:39,318 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0012_01_000004 is : 143
2016-05-18 10:35:40,510 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-05-18 10:35:40,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  completed in: 00:30.054, using cpu time: 00:07.120
2016-05-18 10:35:40,537 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-05-18 10:35:40,566 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:35:40,567 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:35:40,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-18 10:35:40,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 10:35:40,586 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-05-18 10:35:40,602 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:35:40,602 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:35:40,669 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2016-05-18 10:35:40,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 10:35:40,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:35:40,691 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-18 10:35:40,692 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:35:40,692 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:35:40,693 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:35:40,693 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-05-18 10:35:40,693 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  parallel execution of steps is enabled: true
2016-05-18 10:35:40,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  executing total steps: 1
2016-05-18 10:35:40,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  allocating management threads: 1
2016-05-18 10:35:40,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-05-18 10:35:40,837 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463567371208_0013
2016-05-18 10:35:40,838 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0013/
2016-05-18 10:36:16,054 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000007 is : 143
2016-05-18 10:36:16,544 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000008 is : 143
2016-05-18 10:36:16,605 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000006 is : 143
2016-05-18 10:36:17,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000009 is : 143
2016-05-18 10:36:17,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000005 is : 143
2016-05-18 10:36:17,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000002 is : 143
2016-05-18 10:36:17,341 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000003 is : 143
2016-05-18 10:36:22,710 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0013_01_000011 is : 143
2016-05-18 10:36:23,908 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-05-18 10:36:23,910 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  completed in: 00:43.215, using cpu time: 00:12.140
2016-05-18 10:36:23,926 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-05-18 10:36:23,949 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:36:23,949 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:36:24,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 10:36:24,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 10:36:24,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:36:24,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-18 10:36:24,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:36:24,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:36:24,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:36:24,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-05-18 10:36:24,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  parallel execution of steps is enabled: true
2016-05-18 10:36:24,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  executing total steps: 3
2016-05-18 10:36:24,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  allocating management threads: 3
2016-05-18 10:36:24,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/3)
2016-05-18 10:36:24,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463567371208_0014
2016-05-18 10:36:24,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0014/
2016-05-18 10:36:51,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0014_01_000002 is : 143
2016-05-18 10:36:51,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0014_01_000005 is : 143
2016-05-18 10:36:51,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0014_01_000007 is : 143
2016-05-18 10:36:52,262 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0014_01_000006 is : 143
2016-05-18 10:36:52,462 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0014_01_000003 is : 143
2016-05-18 10:36:53,630 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/3)
2016-05-18 10:36:53,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463567371208_0015
2016-05-18 10:36:53,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0015/
2016-05-18 10:37:19,685 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0015_01_000005 is : 143
2016-05-18 10:37:19,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0015_01_000004 is : 143
2016-05-18 10:37:20,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0015_01_000006 is : 143
2016-05-18 10:37:20,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0015_01_000003 is : 143
2016-05-18 10:37:20,134 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0015_01_000002 is : 143
2016-05-18 10:37:21,293 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-05-18 10:37:21,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463567371208_0016
2016-05-18 10:37:21,509 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0016/
2016-05-18 10:37:46,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0016_01_000002 is : 143
2016-05-18 10:37:47,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0016_01_000003 is : 143
2016-05-18 10:37:47,366 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0016_01_000006 is : 143
2016-05-18 10:37:48,573 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-05-18 10:37:48,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset]  completed in: 01:24.509, using cpu time: 00:20.480
2016-05-18 10:37:48,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-05-18 10:37:48,626 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:37:48,626 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:37:48,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-18 10:37:48,680 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:37:48,680 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:37:48,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-18 10:37:48,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:37:48,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:37:48,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:37:48,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-05-18 10:37:48,697 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  parallel execution of steps is enabled: true
2016-05-18 10:37:48,697 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  executing total steps: 1
2016-05-18 10:37:48,697 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  allocating management threads: 1
2016-05-18 10:37:48,698 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-18 10:37:49,015 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463567371208_0017
2016-05-18 10:37:49,015 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0017/
2016-05-18 10:38:15,203 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0017_01_000007 is : 143
2016-05-18 10:38:16,029 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0017_01_000006 is : 143
2016-05-18 10:38:16,506 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0017_01_000002 is : 143
2016-05-18 10:38:16,599 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0017_01_000003 is : 143
2016-05-18 10:38:16,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0017_01_000005 is : 143
2016-05-18 10:38:16,818 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0017_01_000004 is : 143
2016-05-18 10:38:18,023 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-05-18 10:38:18,025 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  completed in: 00:29.324, using cpu time: 00:07.010
2016-05-18 10:38:18,050 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-05-18 10:38:18,080 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:38:18,081 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:38:18,126 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 10:38:18,127 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 10:38:18,127 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:38:18,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-18 10:38:18,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:38:18,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:38:18,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:38:18,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-05-18 10:38:18,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  parallel execution of steps is enabled: true
2016-05-18 10:38:18,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  executing total steps: 1
2016-05-18 10:38:18,174 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  allocating management threads: 1
2016-05-18 10:38:18,175 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-05-18 10:38:18,309 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463567371208_0018
2016-05-18 10:38:18,309 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0018/
2016-05-18 10:38:51,051 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000010 is : 143
2016-05-18 10:38:52,897 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000004 is : 143
2016-05-18 10:38:53,181 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000005 is : 143
2016-05-18 10:38:53,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000009 is : 143
2016-05-18 10:38:53,772 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000002 is : 143
2016-05-18 10:38:53,911 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000003 is : 143
2016-05-18 10:38:54,005 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000006 is : 143
2016-05-18 10:38:54,064 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000008 is : 143
2016-05-18 10:38:54,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000007 is : 143
2016-05-18 10:38:58,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0018_01_000011 is : 143
2016-05-18 10:38:59,537 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-05-18 10:38:59,539 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset]  completed in: 00:41.363, using cpu time: 00:11.980
2016-05-18 10:38:59,555 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-05-18 10:38:59,577 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:38:59,577 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:38:59,636 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 10:38:59,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 10:38:59,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:38:59,664 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-18 10:38:59,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:38:59,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-18 10:38:59,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  parallel execution of steps is enabled: true
2016-05-18 10:38:59,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  executing total steps: 2
2016-05-18 10:38:59,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  allocating management threads: 2
2016-05-18 10:38:59,668 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/2)
2016-05-18 10:38:59,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463567371208_0019
2016-05-18 10:38:59,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0019/
2016-05-18 10:39:24,691 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0019_01_000006 is : 143
2016-05-18 10:39:24,860 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0019_01_000005 is : 143
2016-05-18 10:39:25,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0019_01_000002 is : 143
2016-05-18 10:39:25,095 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0019_01_000003 is : 143
2016-05-18 10:39:25,493 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0019_01_000004 is : 143
2016-05-18 10:39:31,710 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0019_01_000007 is : 143
2016-05-18 10:39:32,871 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-18 10:39:33,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463567371208_0020
2016-05-18 10:39:33,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0020/
2016-05-18 10:39:59,793 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000007 is : 143
2016-05-18 10:40:00,360 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000006 is : 143
2016-05-18 10:40:01,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000004 is : 143
2016-05-18 10:40:01,176 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000003 is : 143
2016-05-18 10:40:01,194 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000005 is : 143
2016-05-18 10:40:01,291 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000002 is : 143
2016-05-18 10:40:07,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0020_01_000008 is : 143
2016-05-18 10:40:08,222 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-18 10:40:08,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset]  completed in: 01:08.554, using cpu time: 00:15.090
2016-05-18 10:40:08,245 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-18 10:40:08,268 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:40:08,268 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:40:08,356 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 10:40:08,358 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 10:40:08,358 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:40:08,388 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-18 10:40:08,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:40:08,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:40:08,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:40:08,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-05-18 10:40:08,391 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  parallel execution of steps is enabled: true
2016-05-18 10:40:08,391 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  executing total steps: 3
2016-05-18 10:40:08,391 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  allocating management threads: 3
2016-05-18 10:40:08,394 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/3)
2016-05-18 10:40:08,522 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463567371208_0021
2016-05-18 10:40:08,522 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0021/
2016-05-18 10:40:35,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0021_01_000003 is : 143
2016-05-18 10:40:35,922 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0021_01_000002 is : 143
2016-05-18 10:40:36,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0021_01_000005 is : 143
2016-05-18 10:40:36,611 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0021_01_000004 is : 143
2016-05-18 10:40:36,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0021_01_000006 is : 143
2016-05-18 10:40:37,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0021_01_000007 is : 143
2016-05-18 10:40:38,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (2/3)
2016-05-18 10:40:38,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463567371208_0022
2016-05-18 10:40:38,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0022/
2016-05-18 10:40:43,861 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463567371208_0021_01_000001
2016-05-18 10:41:04,538 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0022_01_000003 is : 143
2016-05-18 10:41:04,796 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0022_01_000002 is : 143
2016-05-18 10:41:06,144 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0022_01_000005 is : 143
2016-05-18 10:41:06,332 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0022_01_000007 is : 143
2016-05-18 10:41:06,460 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0022_01_000004 is : 143
2016-05-18 10:41:07,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-05-18 10:41:07,760 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463567371208_0023
2016-05-18 10:41:07,760 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0023/
2016-05-18 10:41:36,191 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0023_01_000003 is : 143
2016-05-18 10:41:36,586 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0023_01_000002 is : 143
2016-05-18 10:41:37,091 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0023_01_000006 is : 143
2016-05-18 10:41:37,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0023_01_000007 is : 143
2016-05-18 10:41:38,545 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-05-18 10:41:38,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset]  completed in: 01:30.153, using cpu time: 00:22.560
2016-05-18 10:41:38,584 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-05-18 10:41:38,613 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:41:38,613 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:41:38,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 10:41:38,653 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:41:38,653 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:41:38,664 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-18 10:41:38,664 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:41:38,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:41:38,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:41:38,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-05-18 10:41:38,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  parallel execution of steps is enabled: true
2016-05-18 10:41:38,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  executing total steps: 1
2016-05-18 10:41:38,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  allocating management threads: 1
2016-05-18 10:41:38,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-05-18 10:41:38,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463567371208_0024
2016-05-18 10:41:38,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0024/
2016-05-18 10:42:04,208 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0024_01_000003 is : 143
2016-05-18 10:42:04,411 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0024_01_000002 is : 143
2016-05-18 10:42:05,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0024_01_000004 is : 143
2016-05-18 10:42:05,136 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0024_01_000006 is : 143
2016-05-18 10:42:06,339 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-05-18 10:42:06,341 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  completed in: 00:27.668, using cpu time: 00:05.970
2016-05-18 10:42:06,363 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-05-18 10:42:06,388 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:42:06,388 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:42:06,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 10:42:06,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 10:42:06,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:42:06,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting
2016-05-18 10:42:06,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/apache.10.txt"]
2016-05-18 10:42:06,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-05-18 10:42:06,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  parallel execution of steps is enabled: true
2016-05-18 10:42:06,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  executing total steps: 1
2016-05-18 10:42:06,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  allocating management threads: 1
2016-05-18 10:42:06,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-05-18 10:42:06,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] submitted hadoop job: job_1463567371208_0025
2016-05-18 10:42:06,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0025/
2016-05-18 10:42:29,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0025_01_000005 is : 143
2016-05-18 10:42:29,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0025_01_000002 is : 143
2016-05-18 10:42:29,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0025_01_000003 is : 143
2016-05-18 10:42:29,833 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0025_01_000004 is : 143
2016-05-18 10:42:31,000 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-05-18 10:42:31,002 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second]  completed in: 00:24.547, using cpu time: 00:04.570
2016-05-18 10:42:31,023 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-05-18 10:42:31,049 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:42:31,049 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:42:31,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-18 10:42:31,121 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 10:42:31,121 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:42:31,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-18 10:42:31,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:42:31,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:42:31,149 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:42:31,149 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-05-18 10:42:31,150 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  parallel execution of steps is enabled: true
2016-05-18 10:42:31,150 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  executing total steps: 2
2016-05-18 10:42:31,151 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  allocating management threads: 2
2016-05-18 10:42:31,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/2)
2016-05-18 10:42:31,314 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463567371208_0026
2016-05-18 10:42:31,314 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0026/
2016-05-18 10:42:57,733 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0026_01_000006 is : 143
2016-05-18 10:42:58,151 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0026_01_000007 is : 143
2016-05-18 10:42:59,064 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0026_01_000003 is : 143
2016-05-18 10:42:59,219 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0026_01_000004 is : 143
2016-05-18 10:42:59,329 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0026_01_000005 is : 143
2016-05-18 10:43:00,467 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-05-18 10:43:00,603 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463567371208_0027
2016-05-18 10:43:00,603 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0027/
2016-05-18 10:43:25,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0027_01_000003 is : 143
2016-05-18 10:43:26,455 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0027_01_000006 is : 143
2016-05-18 10:43:26,785 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0027_01_000005 is : 143
2016-05-18 10:43:26,941 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0027_01_000002 is : 143
2016-05-18 10:43:27,122 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0027_01_000004 is : 143
2016-05-18 10:43:28,311 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-05-18 10:43:28,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge]  completed in: 00:57.160, using cpu time: 00:13.540
2016-05-18 10:43:28,334 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-05-18 10:43:28,360 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:43:28,360 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:43:28,434 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-05-18 10:43:28,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 10:43:28,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:43:28,487 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting
2016-05-18 10:43:28,487 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:43:28,487 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:43:28,487 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:43:28,488 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-05-18 10:43:28,488 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  parallel execution of steps is enabled: true
2016-05-18 10:43:28,488 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  executing total steps: 3
2016-05-18 10:43:28,488 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  allocating management threads: 3
2016-05-18 10:43:28,489 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (1/3)
2016-05-18 10:43:28,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463567371208_0028
2016-05-18 10:43:28,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0028/
2016-05-18 10:43:56,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0028_01_000002 is : 143
2016-05-18 10:43:56,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0028_01_000003 is : 143
2016-05-18 10:43:56,695 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0028_01_000004 is : 143
2016-05-18 10:43:56,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0028_01_000005 is : 143
2016-05-18 10:43:56,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0028_01_000006 is : 143
2016-05-18 10:43:57,743 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0028_01_000007 is : 143
2016-05-18 10:43:58,888 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (2/3)
2016-05-18 10:43:59,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463567371208_0029
2016-05-18 10:43:59,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0029/
2016-05-18 10:44:24,432 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0029_01_000003 is : 143
2016-05-18 10:44:24,562 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0029_01_000002 is : 143
2016-05-18 10:44:24,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0029_01_000004 is : 143
2016-05-18 10:44:25,484 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0029_01_000005 is : 143
2016-05-18 10:44:26,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-05-18 10:44:26,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463567371208_0030
2016-05-18 10:44:26,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0030/
2016-05-18 10:44:52,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0030_01_000002 is : 143
2016-05-18 10:44:52,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0030_01_000004 is : 143
2016-05-18 10:44:53,082 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0030_01_000003 is : 143
2016-05-18 10:44:53,118 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0030_01_000006 is : 143
2016-05-18 10:44:53,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0030_01_000005 is : 143
2016-05-18 10:44:54,667 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-05-18 10:44:54,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1]  completed in: 01:26.173, using cpu time: 00:20.550
2016-05-18 10:44:54,693 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-05-18 10:44:54,719 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:44:54,720 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:44:54,797 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-18 10:44:54,800 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 10:44:54,800 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:44:54,852 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 10:44:54,852 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:44:54,852 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:44:54,852 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testGroupByAggregationMerge"]
2016-05-18 10:44:54,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  parallel execution of steps is enabled: true
2016-05-18 10:44:54,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  executing total steps: 3
2016-05-18 10:44:54,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  allocating management threads: 3
2016-05-18 10:44:54,855 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/3)
2016-05-18 10:44:54,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (2/3)
2016-05-18 10:44:55,050 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463567371208_0031
2016-05-18 10:44:55,050 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0031/
2016-05-18 10:44:55,064 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463567371208_0032
2016-05-18 10:44:55,064 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0032/
2016-05-18 10:45:20,004 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0031_01_000004 is : 143
2016-05-18 10:45:20,358 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0031_01_000002 is : 143
2016-05-18 10:45:20,467 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0031_01_000005 is : 143
2016-05-18 10:45:20,524 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0031_01_000003 is : 143
2016-05-18 10:45:20,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0031_01_000006 is : 143
2016-05-18 10:45:26,693 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0031_01_000007 is : 143
2016-05-18 10:45:52,911 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0032_01_000003 is : 143
2016-05-18 10:45:52,978 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0032_01_000004 is : 143
2016-05-18 10:45:53,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0032_01_000005 is : 143
2016-05-18 10:45:53,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0032_01_000002 is : 143
2016-05-18 10:45:53,275 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0032_01_000006 is : 143
2016-05-18 10:45:59,225 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0032_01_000007 is : 143
2016-05-18 10:46:00,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (3/3) ...stGroupByAggregationMerge
2016-05-18 10:46:00,509 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463567371208_0033
2016-05-18 10:46:00,509 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0033/
2016-05-18 10:46:20,892 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testGroupByAggregationMerge/_temporary
2016-05-18 10:46:20,894 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merge]  completed in: 01:26.036, using cpu time: 00:15.760
2016-05-18 10:46:20,952 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 10:46:20,952 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 10:46:21,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 10:46:21,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 10:46:21,029 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 10:46:21,051 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-18 10:46:21,051 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 10:46:21,052 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 10:46:21,052 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 10:46:21,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-05-18 10:46:21,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  parallel execution of steps is enabled: true
2016-05-18 10:46:21,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  executing total steps: 2
2016-05-18 10:46:21,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  allocating management threads: 2
2016-05-18 10:46:21,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/2)
2016-05-18 10:46:21,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463567371208_0034
2016-05-18 10:46:21,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0034/
2016-05-18 10:46:48,096 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0034_01_000002 is : 143
2016-05-18 10:46:48,408 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0034_01_000003 is : 143
2016-05-18 10:46:48,534 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0034_01_000006 is : 143
2016-05-18 10:46:48,971 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0034_01_000004 is : 143
2016-05-18 10:46:49,139 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0034_01_000007 is : 143
2016-05-18 10:46:49,254 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0034_01_000005 is : 143
2016-05-18 10:46:50,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-05-18 10:46:50,543 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463567371208_0035
2016-05-18 10:46:50,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:40867/proxy/application_1463567371208_0035/
2016-05-18 10:47:16,268 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0035_01_000003 is : 143
2016-05-18 10:47:16,604 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0035_01_000005 is : 143
2016-05-18 10:47:16,645 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0035_01_000006 is : 143
2016-05-18 10:47:17,016 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0035_01_000004 is : 143
2016-05-18 10:47:17,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463567371208_0035_01_000002 is : 143
2016-05-18 10:47:18,526 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-05-18 10:47:18,528 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2]  completed in: 00:57.468, using cpu time: 00:13.940
2016-05-18 10:47:18,549 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge

Standard error

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