2016-05-17 21:29:49,581 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 21:29:49,610 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2016-05-17 21:29:49,646 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-17 21:29:50,450 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-17 21:29:51,031 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 21:29:56,024 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-17 21:29:57,287 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-17 21:29:58,436 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-17 21:29:59,569 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-17 21:30:02,117 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 21:30:02,229 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:30:02,230 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-17 21:30:02,303 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: CCFE04B9B0A6409B963D5970A4A036B6
2016-05-17 21:30:02,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-05-17 21:30:02,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:30:02,445 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-17 21:30:02,569 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 21:30:02,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:30:02,570 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:30:02,572 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:30:02,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-05-17 21:30:02,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 21:30:02,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-17 21:30:02,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-17 21:30:02,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-17 21:30:03,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463520594191_0001
2016-05-17 21:30:03,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0001/
2016-05-17 21:30:23,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0001_01_000003 is : 143
2016-05-17 21:30:23,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0001_01_000002 is : 143
2016-05-17 21:30:24,023 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0001_01_000005 is : 143
2016-05-17 21:30:24,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0001_01_000004 is : 143
2016-05-17 21:30:24,370 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0001_01_000007 is : 143
2016-05-17 21:30:24,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0001_01_000006 is : 143
2016-05-17 21:30:25,780 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-17 21:30:25,782 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:23.204, using cpu time: 00:05.890
2016-05-17 21:30:25,875 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge
2016-05-17 21:30:25,942 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:30:25,942 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-17 21:30:26,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.188
2016-05-17 21:30:26,144 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:30:26,144 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-17 21:30:26,207 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-17 21:30:26,208 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:30:26,210 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:30:26,211 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:30:26,213 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-05-17 21:30:26,213 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] parallel execution of steps is enabled: true
2016-05-17 21:30:26,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executing total steps: 3
2016-05-17 21:30:26,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] allocating management threads: 3
2016-05-17 21:30:26,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/3)
2016-05-17 21:30:26,385 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463520594191_0002
2016-05-17 21:30:26,385 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0002/
2016-05-17 21:30:46,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0002_01_000004 is : 143
2016-05-17 21:30:47,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0002_01_000002 is : 143
2016-05-17 21:30:47,247 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0002_01_000006 is : 143
2016-05-17 21:30:47,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0002_01_000003 is : 143
2016-05-17 21:30:47,980 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0002_01_000005 is : 143
2016-05-17 21:30:49,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/3)
2016-05-17 21:30:49,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463520594191_0003
2016-05-17 21:30:49,352 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0003/
2016-05-17 21:31:09,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0003_01_000003 is : 143
2016-05-17 21:31:09,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0003_01_000002 is : 143
2016-05-17 21:31:09,695 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0003_01_000004 is : 143
2016-05-17 21:31:09,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0003_01_000007 is : 143
2016-05-17 21:31:10,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0003_01_000005 is : 143
2016-05-17 21:31:11,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-05-17 21:31:11,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463520594191_0004
2016-05-17 21:31:11,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0004/
2016-05-17 21:31:29,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0004_01_000003 is : 143
2016-05-17 21:31:29,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0004_01_000005 is : 143
2016-05-17 21:31:30,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0004_01_000004 is : 143
2016-05-17 21:31:30,140 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0004_01_000002 is : 143
2016-05-17 21:31:31,361 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-05-17 21:31:31,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] completed in: 01:05.146, using cpu time: 00:18.940
2016-05-17 21:31:31,386 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-05-17 21:31:31,418 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:31:31,419 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-17 21:31:31,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.077
2016-05-17 21:31:31,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:31:31,505 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-17 21:31:31,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-17 21:31:31,528 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:31:31,528 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:31:31,529 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:31:31,530 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-05-17 21:31:31,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] parallel execution of steps is enabled: true
2016-05-17 21:31:31,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executing total steps: 1
2016-05-17 21:31:31,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] allocating management threads: 1
2016-05-17 21:31:31,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-05-17 21:31:31,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463520594191_0005
2016-05-17 21:31:31,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0005/
2016-05-17 21:31:51,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0005_01_000006 is : 143
2016-05-17 21:31:51,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0005_01_000007 is : 143
2016-05-17 21:31:52,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0005_01_000005 is : 143
2016-05-17 21:31:52,718 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0005_01_000002 is : 143
2016-05-17 21:31:52,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0005_01_000004 is : 143
2016-05-17 21:31:52,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0005_01_000003 is : 143
2016-05-17 21:31:54,010 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-05-17 21:31:54,012 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] completed in: 00:22.480, using cpu time: 00:06.690
2016-05-17 21:31:54,037 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-05-17 21:31:54,068 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:31:54,068 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-17 21:31:54,125 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-17 21:31:54,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:31:54,128 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-17 21:31:54,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:31:54,148 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:31:54,149 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:31:54,150 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:31:54,151 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-17 21:31:54,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 21:31:54,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-17 21:31:54,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-17 21:31:54,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-17 21:31:54,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463520594191_0006
2016-05-17 21:31:54,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0006/
2016-05-17 21:32:20,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000010 is : 143
2016-05-17 21:32:21,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000009 is : 143
2016-05-17 21:32:21,732 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000002 is : 143
2016-05-17 21:32:21,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000007 is : 143
2016-05-17 21:32:21,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000005 is : 143
2016-05-17 21:32:21,940 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000006 is : 143
2016-05-17 21:32:22,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000008 is : 143
2016-05-17 21:32:22,772 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0006_01_000003 is : 143
2016-05-17 21:32:24,015 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-17 21:32:24,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:29.865, using cpu time: 00:08.680
2016-05-17 21:32:24,046 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-05-17 21:32:24,082 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:32:24,082 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-17 21:32:24,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-05-17 21:32:24,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:32:24,161 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-17 21:32:24,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting
2016-05-17 21:32:24,190 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:32:24,191 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:32:24,191 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:32:24,191 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-05-17 21:32:24,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] parallel execution of steps is enabled: true
2016-05-17 21:32:24,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executing total steps: 1
2016-05-17 21:32:24,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] allocating management threads: 1
2016-05-17 21:32:24,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-05-17 21:32:24,346 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] submitted hadoop job: job_1463520594191_0007
2016-05-17 21:32:24,346 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0007/
2016-05-17 21:32:44,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0007_01_000004 is : 143
2016-05-17 21:32:44,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0007_01_000006 is : 143
2016-05-17 21:32:44,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0007_01_000002 is : 143
2016-05-17 21:32:44,713 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0007_01_000005 is : 143
2016-05-17 21:32:45,091 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0007_01_000003 is : 143
2016-05-17 21:32:45,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0007_01_000007 is : 143
2016-05-17 21:32:46,386 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-05-17 21:32:46,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] completed in: 00:22.194, using cpu time: 00:06.180
2016-05-17 21:32:46,412 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-05-17 21:32:46,439 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:32:46,440 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-17 21:32:46,492 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-05-17 21:32:46,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:32:46,493 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-17 21:32:46,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 21:32:46,507 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:32:46,507 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:32:46,508 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:32:46,508 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-05-17 21:32:46,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-17 21:32:46,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 1
2016-05-17 21:32:46,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 1
2016-05-17 21:32:46,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-05-17 21:32:46,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463520594191_0008
2016-05-17 21:32:46,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0008/
2016-05-17 21:33:12,080 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000006 is : 143
2016-05-17 21:33:12,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000007 is : 143
2016-05-17 21:33:13,555 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000010 is : 143
2016-05-17 21:33:13,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000009 is : 143
2016-05-17 21:33:13,806 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000005 is : 143
2016-05-17 21:33:14,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000004 is : 143
2016-05-17 21:33:14,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000003 is : 143
2016-05-17 21:33:14,244 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000008 is : 143
2016-05-17 21:33:14,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0008_01_000002 is : 143
2016-05-17 21:33:15,588 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-05-17 21:33:15,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:29.074, using cpu time: 00:09.150
2016-05-17 21:33:15,617 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-05-17 21:33:15,652 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:33:15,652 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-17 21:33:15,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-05-17 21:33:15,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 21:33:15,729 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-17 21:33:15,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-17 21:33:15,754 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:33:15,754 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:33:15,754 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:33:15,755 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-05-17 21:33:15,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-05-17 21:33:15,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executing total steps: 2
2016-05-17 21:33:15,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] allocating management threads: 2
2016-05-17 21:33:15,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/2)
2016-05-17 21:33:15,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463520594191_0009
2016-05-17 21:33:15,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0009/
2016-05-17 21:33:35,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0009_01_000007 is : 143
2016-05-17 21:33:36,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0009_01_000006 is : 143
2016-05-17 21:33:36,535 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0009_01_000005 is : 143
2016-05-17 21:33:36,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0009_01_000002 is : 143
2016-05-17 21:33:36,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0009_01_000004 is : 143
2016-05-17 21:33:37,585 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0009_01_000003 is : 143
2016-05-17 21:33:38,764 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-05-17 21:33:38,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463520594191_0010
2016-05-17 21:33:38,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0010/
2016-05-17 21:33:57,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0010_01_000005 is : 143
2016-05-17 21:33:57,146 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0010_01_000002 is : 143
2016-05-17 21:33:57,308 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0010_01_000003 is : 143
2016-05-17 21:33:57,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0010_01_000004 is : 143
2016-05-17 21:33:57,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0010_01_000006 is : 143
2016-05-17 21:33:58,770 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-05-17 21:33:58,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] completed in: 00:43.010, using cpu time: 00:12.770
2016-05-17 21:33:58,792 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-05-17 21:33:58,830 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:33:58,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-17 21:33:58,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-17 21:33:58,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:33:58,882 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-17 21:33:58,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-17 21:33:58,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:33:58,894 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-17 21:33:58,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-17 21:33:58,895 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-17 21:33:58,895 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-17 21:33:58,896 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-17 21:33:59,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463520594191_0011
2016-05-17 21:33:59,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0011/
2016-05-17 21:34:14,323 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0011_01_000004 is : 143
2016-05-17 21:34:14,578 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0011_01_000005 is : 143
2016-05-17 21:34:14,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0011_01_000002 is : 143
2016-05-17 21:34:15,874 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-17 21:34:15,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:16.979, using cpu time: 00:03.750
2016-05-17 21:34:15,895 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-17 21:34:15,919 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:34:15,919 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-17 21:34:15,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-05-17 21:34:15,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:34:15,976 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-17 21:34:15,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 21:34:15,995 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:34:15,996 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:34:15,996 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:34:15,996 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-05-17 21:34:15,998 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-17 21:34:15,998 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-17 21:34:15,998 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-17 21:34:15,999 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-17 21:34:16,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463520594191_0012
2016-05-17 21:34:16,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0012/
2016-05-17 21:34:35,980 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0012_01_000007 is : 143
2016-05-17 21:34:36,338 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0012_01_000003 is : 143
2016-05-17 21:34:36,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0012_01_000002 is : 143
2016-05-17 21:34:36,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0012_01_000005 is : 143
2016-05-17 21:34:37,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0012_01_000004 is : 143
2016-05-17 21:34:39,088 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-05-17 21:34:39,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:23.090, using cpu time: 00:06.130
2016-05-17 21:34:39,116 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-05-17 21:34:39,142 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:34:39,142 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-17 21:34:39,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-05-17 21:34:39,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 21:34:39,161 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-05-17 21:34:39,175 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:34:39,175 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-17 21:34:39,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-17 21:34:39,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:34:39,230 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-17 21:34:39,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 21:34:39,253 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:34:39,253 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:34:39,253 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:34:39,254 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-05-17 21:34:39,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-17 21:34:39,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 1
2016-05-17 21:34:39,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 1
2016-05-17 21:34:39,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-05-17 21:34:39,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463520594191_0013
2016-05-17 21:34:39,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0013/
2016-05-17 21:35:05,340 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000006 is : 143
2016-05-17 21:35:06,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000009 is : 143
2016-05-17 21:35:06,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000007 is : 143
2016-05-17 21:35:06,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000010 is : 143
2016-05-17 21:35:06,963 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000008 is : 143
2016-05-17 21:35:07,239 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000004 is : 143
2016-05-17 21:35:07,304 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000005 is : 143
2016-05-17 21:35:07,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000002 is : 143
2016-05-17 21:35:07,583 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000003 is : 143
2016-05-17 21:35:11,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0013_01_000011 is : 143
2016-05-17 21:35:12,894 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-05-17 21:35:12,896 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:33.640, using cpu time: 00:10.450
2016-05-17 21:35:12,912 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-05-17 21:35:12,940 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:35:12,940 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-17 21:35:13,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-05-17 21:35:13,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:35:13,020 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-17 21:35:13,049 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-17 21:35:13,049 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:35:13,049 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:35:13,050 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:35:13,051 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-05-17 21:35:13,051 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-05-17 21:35:13,052 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executing total steps: 3
2016-05-17 21:35:13,052 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] allocating management threads: 3
2016-05-17 21:35:13,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/3)
2016-05-17 21:35:13,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463520594191_0014
2016-05-17 21:35:13,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0014/
2016-05-17 21:35:32,766 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0014_01_000002 is : 143
2016-05-17 21:35:33,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0014_01_000007 is : 143
2016-05-17 21:35:33,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0014_01_000006 is : 143
2016-05-17 21:35:33,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0014_01_000003 is : 143
2016-05-17 21:35:33,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0014_01_000005 is : 143
2016-05-17 21:35:34,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0014_01_000004 is : 143
2016-05-17 21:35:35,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/3)
2016-05-17 21:35:35,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463520594191_0015
2016-05-17 21:35:35,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0015/
2016-05-17 21:35:52,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0015_01_000006 is : 143
2016-05-17 21:35:53,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0015_01_000002 is : 143
2016-05-17 21:35:53,682 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0015_01_000005 is : 143
2016-05-17 21:35:53,708 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0015_01_000003 is : 143
2016-05-17 21:35:54,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0015_01_000004 is : 143
2016-05-17 21:35:55,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-05-17 21:35:55,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463520594191_0016
2016-05-17 21:35:55,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0016/
2016-05-17 21:36:13,745 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0016_01_000003 is : 143
2016-05-17 21:36:13,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0016_01_000005 is : 143
2016-05-17 21:36:14,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0016_01_000004 is : 143
2016-05-17 21:36:15,359 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-05-17 21:36:15,361 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] completed in: 01:02.303, using cpu time: 00:18.480
2016-05-17 21:36:15,391 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-05-17 21:36:15,415 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:36:15,415 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-17 21:36:15,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 21:36:15,455 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:36:15,455 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-17 21:36:15,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 21:36:15,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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:36:15,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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:36:15,470 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:36:15,470 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-05-17 21:36:15,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-17 21:36:15,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-17 21:36:15,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-17 21:36:15,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-17 21:36:15,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463520594191_0017
2016-05-17 21:36:15,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0017/
2016-05-17 21:36:35,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0017_01_000007 is : 143
2016-05-17 21:36:35,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0017_01_000004 is : 143
2016-05-17 21:36:35,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0017_01_000006 is : 143
2016-05-17 21:36:35,745 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0017_01_000003 is : 143
2016-05-17 21:36:35,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0017_01_000005 is : 143
2016-05-17 21:36:36,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0017_01_000002 is : 143
2016-05-17 21:36:38,049 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-05-17 21:36:38,051 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:22.577, using cpu time: 00:06.240
2016-05-17 21:36:38,072 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-05-17 21:36:38,098 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:36:38,099 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-17 21:36:38,141 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 21:36:38,143 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:36:38,143 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-17 21:36:38,163 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 21:36:38,163 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:36:38,164 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:36:38,165 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:36:38,165 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-05-17 21:36:38,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-17 21:36:38,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-17 21:36:38,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-17 21:36:38,168 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-05-17 21:36:38,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463520594191_0018
2016-05-17 21:36:38,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0018/
2016-05-17 21:37:04,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000007 is : 143
2016-05-17 21:37:04,825 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000006 is : 143
2016-05-17 21:37:05,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000002 is : 143
2016-05-17 21:37:05,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000009 is : 143
2016-05-17 21:37:05,969 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000004 is : 143
2016-05-17 21:37:06,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000005 is : 143
2016-05-17 21:37:06,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000003 is : 143
2016-05-17 21:37:06,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000010 is : 143
2016-05-17 21:37:06,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000008 is : 143
2016-05-17 21:37:10,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0018_01_000011 is : 143
2016-05-17 21:37:11,973 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-05-17 21:37:11,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:33.808, using cpu time: 00:11.350
2016-05-17 21:37:11,989 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-05-17 21:37:12,006 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:37:12,006 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-17 21:37:12,063 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-17 21:37:12,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:37:12,065 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-17 21:37:12,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 21:37:12,090 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:37:12,090 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-17 21:37:12,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-17 21:37:12,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 2
2016-05-17 21:37:12,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 2
2016-05-17 21:37:12,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/2)
2016-05-17 21:37:12,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463520594191_0019
2016-05-17 21:37:12,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0019/
2016-05-17 21:37:29,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0019_01_000005 is : 143
2016-05-17 21:37:29,688 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0019_01_000004 is : 143
2016-05-17 21:37:29,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0019_01_000003 is : 143
2016-05-17 21:37:29,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0019_01_000002 is : 143
2016-05-17 21:37:30,047 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0019_01_000006 is : 143
2016-05-17 21:37:36,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0019_01_000007 is : 143
2016-05-17 21:37:37,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-17 21:37:37,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463520594191_0020
2016-05-17 21:37:37,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0020/
2016-05-17 21:37:57,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000002 is : 143
2016-05-17 21:37:57,736 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000006 is : 143
2016-05-17 21:37:57,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000007 is : 143
2016-05-17 21:37:57,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000004 is : 143
2016-05-17 21:37:57,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000005 is : 143
2016-05-17 21:37:58,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000003 is : 143
2016-05-17 21:38:03,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0020_01_000008 is : 143
2016-05-17 21:38:05,036 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-17 21:38:05,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:52.942, using cpu time: 00:13.450
2016-05-17 21:38:05,057 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-17 21:38:05,078 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:38:05,079 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-17 21:38:05,162 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-05-17 21:38:05,163 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:38:05,164 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-17 21:38:05,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-17 21:38:05,210 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:38:05,210 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:38:05,210 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:38:05,211 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-05-17 21:38:05,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] parallel execution of steps is enabled: true
2016-05-17 21:38:05,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executing total steps: 3
2016-05-17 21:38:05,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] allocating management threads: 3
2016-05-17 21:38:05,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/3)
2016-05-17 21:38:05,350 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463520594191_0021
2016-05-17 21:38:05,350 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0021/
2016-05-17 21:38:25,132 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0021_01_000007 is : 143
2016-05-17 21:38:25,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0021_01_000006 is : 143
2016-05-17 21:38:25,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0021_01_000003 is : 143
2016-05-17 21:38:25,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0021_01_000002 is : 143
2016-05-17 21:38:25,803 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0021_01_000005 is : 143
2016-05-17 21:38:26,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0021_01_000004 is : 143
2016-05-17 21:38:27,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (2/3)
2016-05-17 21:38:27,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463520594191_0022
2016-05-17 21:38:27,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0022/
2016-05-17 21:38:47,644 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0022_01_000004 is : 143
2016-05-17 21:38:47,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0022_01_000006 is : 143
2016-05-17 21:38:47,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0022_01_000003 is : 143
2016-05-17 21:38:47,986 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0022_01_000002 is : 143
2016-05-17 21:38:48,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0022_01_000005 is : 143
2016-05-17 21:38:48,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0022_01_000007 is : 143
2016-05-17 21:38:50,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-05-17 21:38:50,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463520594191_0023
2016-05-17 21:38:50,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0023/
2016-05-17 21:39:10,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0023_01_000007 is : 143
2016-05-17 21:39:10,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0023_01_000004 is : 143
2016-05-17 21:39:10,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0023_01_000005 is : 143
2016-05-17 21:39:11,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0023_01_000003 is : 143
2016-05-17 21:39:12,388 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-05-17 21:39:12,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] completed in: 01:07.171, using cpu time: 00:20.550
2016-05-17 21:39:12,413 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-05-17 21:39:12,454 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:39:12,455 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-17 21:39:12,490 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 21:39:12,491 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:39:12,492 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-17 21:39:12,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-17 21:39:12,503 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:39:12,503 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:39:12,503 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:39:12,503 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-05-17 21:39:12,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] parallel execution of steps is enabled: true
2016-05-17 21:39:12,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executing total steps: 1
2016-05-17 21:39:12,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] allocating management threads: 1
2016-05-17 21:39:12,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-05-17 21:39:12,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463520594191_0024
2016-05-17 21:39:12,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0024/
2016-05-17 21:39:30,339 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0024_01_000006 is : 143
2016-05-17 21:39:30,644 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0024_01_000005 is : 143
2016-05-17 21:39:30,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0024_01_000002 is : 143
2016-05-17 21:39:30,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0024_01_000004 is : 143
2016-05-17 21:39:31,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0024_01_000003 is : 143
2016-05-17 21:39:32,391 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-05-17 21:39:32,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] completed in: 00:19.886, using cpu time: 00:04.960
2016-05-17 21:39:32,414 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-05-17 21:39:32,438 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:39:32,439 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-17 21:39:32,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 21:39:32,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:39:32,485 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-17 21:39:32,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting
2016-05-17 21:39:32,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache.10.txt"]
2016-05-17 21:39:32,497 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-05-17 21:39:32,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] parallel execution of steps is enabled: true
2016-05-17 21:39:32,498 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executing total steps: 1
2016-05-17 21:39:32,498 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] allocating management threads: 1
2016-05-17 21:39:32,499 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-05-17 21:39:32,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] submitted hadoop job: job_1463520594191_0025
2016-05-17 21:39:32,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0025/
2016-05-17 21:39:48,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0025_01_000004 is : 143
2016-05-17 21:39:48,214 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0025_01_000002 is : 143
2016-05-17 21:39:48,404 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0025_01_000005 is : 143
2016-05-17 21:39:49,611 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-05-17 21:39:49,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] completed in: 00:17.110, using cpu time: 00:03.820
2016-05-17 21:39:49,632 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-05-17 21:39:49,656 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:39:49,657 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-17 21:39:49,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-05-17 21:39:49,713 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 21:39:49,713 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-17 21:39:49,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-17 21:39:49,737 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:39:49,737 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:39:49,737 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:39:49,737 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-05-17 21:39:49,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] parallel execution of steps is enabled: true
2016-05-17 21:39:49,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executing total steps: 2
2016-05-17 21:39:49,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] allocating management threads: 2
2016-05-17 21:39:49,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/2)
2016-05-17 21:39:49,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463520594191_0026
2016-05-17 21:39:49,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0026/
2016-05-17 21:40:09,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0026_01_000006 is : 143
2016-05-17 21:40:10,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0026_01_000007 is : 143
2016-05-17 21:40:10,259 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0026_01_000005 is : 143
2016-05-17 21:40:11,490 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-05-17 21:40:11,617 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463520594191_0027
2016-05-17 21:40:11,617 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0027/
2016-05-17 21:40:29,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0027_01_000005 is : 143
2016-05-17 21:40:30,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0027_01_000002 is : 143
2016-05-17 21:40:30,164 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0027_01_000003 is : 143
2016-05-17 21:40:30,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0027_01_000006 is : 143
2016-05-17 21:40:30,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0027_01_000004 is : 143
2016-05-17 21:40:31,540 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-05-17 21:40:31,542 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] completed in: 00:41.800, using cpu time: 00:12.250
2016-05-17 21:40:31,560 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-05-17 21:40:31,594 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:40:31,595 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-17 21:40:31,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-05-17 21:40:31,687 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 21:40:31,688 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-17 21:40:31,721 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting
2016-05-17 21:40:31,721 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:40:31,721 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:40:31,722 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:40:31,722 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-05-17 21:40:31,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] parallel execution of steps is enabled: true
2016-05-17 21:40:31,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executing total steps: 3
2016-05-17 21:40:31,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] allocating management threads: 3
2016-05-17 21:40:31,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (1/3)
2016-05-17 21:40:31,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463520594191_0028
2016-05-17 21:40:31,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0028/
2016-05-17 21:40:51,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0028_01_000007 is : 143
2016-05-17 21:40:51,917 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0028_01_000004 is : 143
2016-05-17 21:40:51,975 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0028_01_000003 is : 143
2016-05-17 21:40:52,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0028_01_000005 is : 143
2016-05-17 21:40:52,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0028_01_000002 is : 143
2016-05-17 21:40:52,853 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0028_01_000006 is : 143
2016-05-17 21:40:54,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (2/3)
2016-05-17 21:40:54,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463520594191_0029
2016-05-17 21:40:54,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0029/
2016-05-17 21:41:12,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0029_01_000002 is : 143
2016-05-17 21:41:12,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0029_01_000005 is : 143
2016-05-17 21:41:12,646 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0029_01_000003 is : 143
2016-05-17 21:41:13,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0029_01_000004 is : 143
2016-05-17 21:41:14,327 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-05-17 21:41:14,447 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463520594191_0030
2016-05-17 21:41:14,447 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0030/
2016-05-17 21:41:32,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0030_01_000006 is : 143
2016-05-17 21:41:32,920 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0030_01_000005 is : 143
2016-05-17 21:41:32,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0030_01_000002 is : 143
2016-05-17 21:41:33,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0030_01_000003 is : 143
2016-05-17 21:41:33,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0030_01_000004 is : 143
2016-05-17 21:41:34,919 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-05-17 21:41:34,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] completed in: 01:03.191, using cpu time: 00:18.060
2016-05-17 21:41:34,941 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-05-17 21:41:34,969 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:41:34,971 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-17 21:41:35,043 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-17 21:41:35,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-17 21:41:35,046 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-17 21:41:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 21:41:35,100 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:41:35,100 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:41:35,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testGroupByAggregationMerge"]
2016-05-17 21:41:35,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 21:41:35,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 3
2016-05-17 21:41:35,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 3
2016-05-17 21:41:35,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (2/3)
2016-05-17 21:41:35,109 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/3)
2016-05-17 21:41:35,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463520594191_0031
2016-05-17 21:41:35,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0031/
2016-05-17 21:41:35,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463520594191_0032
2016-05-17 21:41:35,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0032/
2016-05-17 21:41:56,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0031_01_000002 is : 143
2016-05-17 21:41:56,558 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0031_01_000003 is : 143
2016-05-17 21:41:56,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0031_01_000005 is : 143
2016-05-17 21:41:57,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0031_01_000006 is : 143
2016-05-17 21:42:09,685 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0032_01_000003 is : 143
2016-05-17 21:42:09,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0032_01_000002 is : 143
2016-05-17 21:42:10,698 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0032_01_000005 is : 143
2016-05-17 21:42:10,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0032_01_000006 is : 143
2016-05-17 21:42:11,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0031_01_000007 is : 143
2016-05-17 21:42:16,226 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0032_01_000007 is : 143
2016-05-17 21:42:17,433 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (3/3) ...stGroupByAggregationMerge
2016-05-17 21:42:17,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463520594191_0033
2016-05-17 21:42:17,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0033/
2016-05-17 21:42:31,359 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0033_01_000002 is : 143
2016-05-17 21:42:31,408 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0033_01_000003 is : 143
2016-05-17 21:42:32,609 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testGroupByAggregationMerge/_temporary
2016-05-17 21:42:32,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:57.503, using cpu time: 00:14.490
2016-05-17 21:42:32,659 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:42:32,659 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-17 21:42:32,722 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-17 21:42:32,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 21:42:32,723 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-17 21:42:32,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-17 21:42:32,756 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.2.x/build/classes/test/data/upper.txt"]
2016-05-17 21:42:32,756 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.2.x/build/classes/test/data/lower.txt"]
2016-05-17 21:42:32,757 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.2.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 21:42:32,757 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.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-05-17 21:42:32,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] parallel execution of steps is enabled: true
2016-05-17 21:42:32,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executing total steps: 2
2016-05-17 21:42:32,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] allocating management threads: 2
2016-05-17 21:42:32,761 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/2)
2016-05-17 21:42:32,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463520594191_0034
2016-05-17 21:42:32,891 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0034/
2016-05-17 21:42:52,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0034_01_000004 is : 143
2016-05-17 21:42:52,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0034_01_000007 is : 143
2016-05-17 21:42:52,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0034_01_000005 is : 143
2016-05-17 21:42:53,145 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0034_01_000006 is : 143
2016-05-17 21:42:53,178 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0034_01_000002 is : 143
2016-05-17 21:42:54,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0034_01_000003 is : 143
2016-05-17 21:42:55,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-05-17 21:42:55,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463520594191_0035
2016-05-17 21:42:55,640 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203:35010/proxy/application_1463520594191_0035/
2016-05-17 21:43:13,436 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0035_01_000006 is : 143
2016-05-17 21:43:13,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0035_01_000005 is : 143
2016-05-17 21:43:14,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0035_01_000003 is : 143
2016-05-17 21:43:14,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463520594191_0035_01_000004 is : 143
2016-05-17 21:43:15,482 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-05-17 21:43:15,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] completed in: 00:42.722, using cpu time: 00:12.520
2016-05-17 21:43:15,505 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge