2016-05-17 23:49:39,213 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 23:49:39,234 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2016-05-17 23:49:39,259 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-17 23:49:39,949 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 23:49:40,469 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-17 23:49:41,006 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-17 23:49:44,204 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 23:49:44,343 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 23:49:44,452 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 23:49:44,562 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 23:50:01,633 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 23:50:01,756 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:50:01,758 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 23:50:01,830 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 819610B8422D4D84936188734BBB15DA
2016-05-17 23:50:01,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-05-17 23:50:01,971 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:50:01,973 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 23:50:02,100 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 23:50:02,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 23:50:02,102 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:50:02,102 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:50:02,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2016-05-17 23:50:02,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 23:50:02,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-17 23:50:02,103 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-17 23:50:02,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-05-17 23:50:02,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463528996130_0001
2016-05-17 23:50:02,989 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0001/
2016-05-17 23:50:27,793 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0001_01_000002 is : 143
2016-05-17 23:50:28,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0001_01_000003 is : 143
2016-05-17 23:50:28,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0001_01_000006 is : 143
2016-05-17 23:50:28,591 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0001_01_000007 is : 143
2016-05-17 23:50:28,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0001_01_000004 is : 143
2016-05-17 23:50:30,146 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2016-05-17 23:50:30,147 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:28.042, using cpu time: 00:06.070
2016-05-17 23:50:30,234 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge
2016-05-17 23:50:30,305 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:50:30,305 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 23:50:30,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.187
2016-05-17 23:50:30,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 23:50:30,502 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 23:50:30,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-17 23:50:30,576 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:50:30,576 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:50:30,576 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:50:30,577 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2016-05-17 23:50:30,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] parallel execution of steps is enabled: true
2016-05-17 23:50:30,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executing total steps: 3
2016-05-17 23:50:30,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] allocating management threads: 3
2016-05-17 23:50:30,580 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/3)
2016-05-17 23:50:30,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463528996130_0002
2016-05-17 23:50:30,776 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0002/
2016-05-17 23:50:49,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0002_01_000007 is : 143
2016-05-17 23:50:50,595 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0002_01_000006 is : 143
2016-05-17 23:50:51,015 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0002_01_000004 is : 143
2016-05-17 23:50:51,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0002_01_000005 is : 143
2016-05-17 23:50:51,226 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0002_01_000002 is : 143
2016-05-17 23:50:52,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0002_01_000003 is : 143
2016-05-17 23:50:53,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/3)
2016-05-17 23:50:53,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463528996130_0003
2016-05-17 23:50:53,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0003/
2016-05-17 23:51:13,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0003_01_000006 is : 143
2016-05-17 23:51:13,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0003_01_000003 is : 143
2016-05-17 23:51:13,790 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0003_01_000007 is : 143
2016-05-17 23:51:13,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0003_01_000004 is : 143
2016-05-17 23:51:13,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0003_01_000005 is : 143
2016-05-17 23:51:13,977 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0003_01_000002 is : 143
2016-05-17 23:51:15,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2016-05-17 23:51:15,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463528996130_0004
2016-05-17 23:51:15,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0004/
2016-05-17 23:51:33,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0004_01_000003 is : 143
2016-05-17 23:51:33,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0004_01_000005 is : 143
2016-05-17 23:51:33,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0004_01_000006 is : 143
2016-05-17 23:51:33,715 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0004_01_000002 is : 143
2016-05-17 23:51:34,968 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2016-05-17 23:51:34,970 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] completed in: 01:04.384, using cpu time: 00:20.310
2016-05-17 23:51:35,000 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2016-05-17 23:51:35,037 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:51:35,038 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 23:51:35,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-05-17 23:51:35,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:51:35,124 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 23:51:35,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-17 23:51:35,155 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:51:35,155 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:51:35,156 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:51:35,156 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2016-05-17 23:51:35,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] parallel execution of steps is enabled: true
2016-05-17 23:51:35,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executing total steps: 1
2016-05-17 23:51:35,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] allocating management threads: 1
2016-05-17 23:51:35,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2016-05-17 23:51:35,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463528996130_0005
2016-05-17 23:51:35,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0005/
2016-05-17 23:51:55,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0005_01_000005 is : 143
2016-05-17 23:51:55,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0005_01_000004 is : 143
2016-05-17 23:51:55,931 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0005_01_000007 is : 143
2016-05-17 23:51:56,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0005_01_000003 is : 143
2016-05-17 23:51:56,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0005_01_000002 is : 143
2016-05-17 23:51:57,562 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2016-05-17 23:51:57,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] completed in: 00:22.404, using cpu time: 00:06.830
2016-05-17 23:51:57,604 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2016-05-17 23:51:57,642 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:51:57,642 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 23:51:57,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-17 23:51:57,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:51:57,701 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 23:51:57,722 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-17 23:51:57,723 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:51:57,724 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:51:57,724 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:51:57,725 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2016-05-17 23:51:57,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-17 23:51:57,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 1
2016-05-17 23:51:57,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 1
2016-05-17 23:51:57,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-05-17 23:51:57,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463528996130_0006
2016-05-17 23:51:57,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0006/
2016-05-17 23:52:23,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000006 is : 143
2016-05-17 23:52:24,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000010 is : 143
2016-05-17 23:52:24,296 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000007 is : 143
2016-05-17 23:52:24,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000004 is : 143
2016-05-17 23:52:24,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000003 is : 143
2016-05-17 23:52:24,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000002 is : 143
2016-05-17 23:52:24,938 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000005 is : 143
2016-05-17 23:52:25,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0006_01_000008 is : 143
2016-05-17 23:52:27,171 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2016-05-17 23:52:27,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:29.447, using cpu time: 00:09.660
2016-05-17 23:52:27,208 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree
2016-05-17 23:52:27,245 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:52:27,245 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 23:52:27,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-17 23:52:27,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:52:27,311 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 23:52:27,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting
2016-05-17 23:52:27,331 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:52:27,331 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:52:27,331 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:52:27,332 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2016-05-17 23:52:27,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] parallel execution of steps is enabled: true
2016-05-17 23:52:27,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] executing total steps: 1
2016-05-17 23:52:27,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] allocating management threads: 1
2016-05-17 23:52:27,334 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2016-05-17 23:52:27,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] submitted hadoop job: job_1463528996130_0007
2016-05-17 23:52:27,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0007/
2016-05-17 23:52:47,343 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0007_01_000006 is : 143
2016-05-17 23:52:47,351 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0007_01_000005 is : 143
2016-05-17 23:52:47,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0007_01_000004 is : 143
2016-05-17 23:52:47,733 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0007_01_000007 is : 143
2016-05-17 23:52:47,796 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0007_01_000002 is : 143
2016-05-17 23:52:47,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0007_01_000003 is : 143
2016-05-17 23:52:49,166 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2016-05-17 23:52:49,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge1*offset*offset] completed in: 00:21.833, using cpu time: 00:06.750
2016-05-17 23:52:49,193 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2016-05-17 23:52:49,226 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:52:49,226 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 23:52:49,307 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-17 23:52:49,308 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:52:49,309 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 23:52:49,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 23:52:49,334 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:52:49,334 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:52:49,334 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:52:49,334 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2016-05-17 23:52:49,334 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-17 23:52:49,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 1
2016-05-17 23:52:49,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 1
2016-05-17 23:52:49,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2016-05-17 23:52:49,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463528996130_0008
2016-05-17 23:52:49,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0008/
2016-05-17 23:53:14,940 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000003 is : 143
2016-05-17 23:53:15,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000006 is : 143
2016-05-17 23:53:16,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000007 is : 143
2016-05-17 23:53:16,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000010 is : 143
2016-05-17 23:53:16,513 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000009 is : 143
2016-05-17 23:53:16,616 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000005 is : 143
2016-05-17 23:53:16,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0008_01_000008 is : 143
2016-05-17 23:53:17,946 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2016-05-17 23:53:17,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:28.611, using cpu time: 00:09.610
2016-05-17 23:53:17,977 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2016-05-17 23:53:18,014 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:53:18,014 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 23:53:18,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-17 23:53:18,110 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 23:53:18,110 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 23:53:18,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-17 23:53:18,150 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:53:18,151 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:53:18,151 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:53:18,151 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2016-05-17 23:53:18,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-05-17 23:53:18,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executing total steps: 2
2016-05-17 23:53:18,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] allocating management threads: 2
2016-05-17 23:53:18,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/2)
2016-05-17 23:53:18,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463528996130_0009
2016-05-17 23:53:18,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0009/
2016-05-17 23:53:37,285 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0009_01_000002 is : 143
2016-05-17 23:53:37,361 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0009_01_000003 is : 143
2016-05-17 23:53:38,419 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0009_01_000005 is : 143
2016-05-17 23:53:38,574 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0009_01_000007 is : 143
2016-05-17 23:53:38,599 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0009_01_000004 is : 143
2016-05-17 23:53:38,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0009_01_000006 is : 143
2016-05-17 23:53:40,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2016-05-17 23:53:40,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463528996130_0010
2016-05-17 23:53:40,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0010/
2016-05-17 23:53:58,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0010_01_000003 is : 143
2016-05-17 23:53:58,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0010_01_000004 is : 143
2016-05-17 23:53:58,210 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0010_01_000006 is : 143
2016-05-17 23:53:58,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0010_01_000005 is : 143
2016-05-17 23:53:59,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0010_01_000002 is : 143
2016-05-17 23:54:00,375 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2016-05-17 23:54:00,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] completed in: 00:42.220, using cpu time: 00:13.260
2016-05-17 23:54:00,398 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2016-05-17 23:54:00,446 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:54:00,446 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 23:54:00,491 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 23:54:00,492 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:54:00,492 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 23:54:00,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting
2016-05-17 23:54:00,506 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2016-05-17 23:54:00,506 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-05-17 23:54:00,506 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] parallel execution of steps is enabled: true
2016-05-17 23:54:00,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] executing total steps: 1
2016-05-17 23:54:00,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] allocating management threads: 1
2016-05-17 23:54:00,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-05-17 23:54:00,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] submitted hadoop job: job_1463528996130_0011
2016-05-17 23:54:00,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0011/
2016-05-17 23:54:16,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0011_01_000004 is : 143
2016-05-17 23:54:16,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0011_01_000005 is : 143
2016-05-17 23:54:16,431 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0011_01_000003 is : 143
2016-05-17 23:54:17,146 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0011_01_000002 is : 143
2016-05-17 23:54:18,369 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2016-05-17 23:54:18,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged] completed in: 00:17.862, using cpu time: 00:04.070
2016-05-17 23:54:18,391 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-05-17 23:54:18,417 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:54:18,417 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 23:54:18,464 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-17 23:54:18,465 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:54:18,465 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 23:54:18,480 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 23:54:18,481 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:54:18,481 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:54:18,481 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:54:18,481 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2016-05-17 23:54:18,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-17 23:54:18,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-17 23:54:18,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-17 23:54:18,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-17 23:54:18,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463528996130_0012
2016-05-17 23:54:18,629 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0012/
2016-05-17 23:54:37,891 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0012_01_000002 is : 143
2016-05-17 23:54:38,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0012_01_000003 is : 143
2016-05-17 23:54:38,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0012_01_000006 is : 143
2016-05-17 23:54:38,732 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0012_01_000005 is : 143
2016-05-17 23:54:38,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0012_01_000004 is : 143
2016-05-17 23:54:39,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0012_01_000007 is : 143
2016-05-17 23:54:40,288 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2016-05-17 23:54:40,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:21.806, using cpu time: 00:06.750
2016-05-17 23:54:40,312 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2016-05-17 23:54:40,338 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:54:40,338 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 23:54:40,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-17 23:54:40,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:54:40,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeFail/simplemergefail
2016-05-17 23:54:40,374 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:54:40,374 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 23:54:40,426 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-05-17 23:54:40,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:54:40,428 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 23:54:40,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 23:54:40,457 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:54:40,457 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:54:40,458 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:54:40,458 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2016-05-17 23:54:40,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-17 23:54:40,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 1
2016-05-17 23:54:40,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 1
2016-05-17 23:54:40,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2016-05-17 23:54:40,592 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463528996130_0013
2016-05-17 23:54:40,593 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0013/
2016-05-17 23:55:06,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000003 is : 143
2016-05-17 23:55:06,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000002 is : 143
2016-05-17 23:55:07,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000010 is : 143
2016-05-17 23:55:07,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000006 is : 143
2016-05-17 23:55:07,919 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000008 is : 143
2016-05-17 23:55:07,950 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000004 is : 143
2016-05-17 23:55:07,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000007 is : 143
2016-05-17 23:55:08,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000009 is : 143
2016-05-17 23:55:08,210 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000005 is : 143
2016-05-17 23:55:12,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0013_01_000011 is : 143
2016-05-17 23:55:13,808 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2016-05-17 23:55:13,810 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:33.349, using cpu time: 00:11.450
2016-05-17 23:55:13,826 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2016-05-17 23:55:13,847 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:55:13,847 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 23:55:13,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-17 23:55:13,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 23:55:13,947 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 23:55:13,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting
2016-05-17 23:55:13,984 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:55:13,984 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:55:13,984 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:55:13,984 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2016-05-17 23:55:13,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2016-05-17 23:55:13,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] executing total steps: 3
2016-05-17 23:55:13,985 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] allocating management threads: 3
2016-05-17 23:55:13,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (1/3)
2016-05-17 23:55:14,142 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463528996130_0014
2016-05-17 23:55:14,142 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0014/
2016-05-17 23:55:33,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0014_01_000006 is : 143
2016-05-17 23:55:33,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0014_01_000007 is : 143
2016-05-17 23:55:33,972 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0014_01_000005 is : 143
2016-05-17 23:55:34,023 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0014_01_000003 is : 143
2016-05-17 23:55:34,251 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0014_01_000002 is : 143
2016-05-17 23:55:34,294 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0014_01_000004 is : 143
2016-05-17 23:55:35,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (2/3)
2016-05-17 23:55:35,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463528996130_0015
2016-05-17 23:55:35,646 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0015/
2016-05-17 23:55:53,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0015_01_000003 is : 143
2016-05-17 23:55:53,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0015_01_000006 is : 143
2016-05-17 23:55:54,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0015_01_000005 is : 143
2016-05-17 23:55:54,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0015_01_000004 is : 143
2016-05-17 23:55:55,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2016-05-17 23:55:55,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] submitted hadoop job: job_1463528996130_0016
2016-05-17 23:55:55,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0016/
2016-05-17 23:56:12,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0016_01_000005 is : 143
2016-05-17 23:56:12,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0016_01_000004 is : 143
2016-05-17 23:56:12,887 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0016_01_000003 is : 143
2016-05-17 23:56:12,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0016_01_000006 is : 143
2016-05-17 23:56:13,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0016_01_000002 is : 143
2016-05-17 23:56:14,286 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2016-05-17 23:56:14,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge1*offset] completed in: 01:00.296, using cpu time: 00:19.660
2016-05-17 23:56:14,309 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2016-05-17 23:56:14,333 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:56:14,334 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 23:56:14,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 23:56:14,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:56:14,374 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 23:56:14,387 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 23:56:14,387 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:56:14,387 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:56:14,388 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:56:14,388 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2016-05-17 23:56:14,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-17 23:56:14,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-17 23:56:14,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-17 23:56:14,390 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2016-05-17 23:56:14,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463528996130_0017
2016-05-17 23:56:14,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0017/
2016-05-17 23:56:34,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0017_01_000002 is : 143
2016-05-17 23:56:34,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0017_01_000007 is : 143
2016-05-17 23:56:34,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0017_01_000005 is : 143
2016-05-17 23:56:34,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0017_01_000003 is : 143
2016-05-17 23:56:34,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0017_01_000006 is : 143
2016-05-17 23:56:35,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0017_01_000004 is : 143
2016-05-17 23:56:36,817 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2016-05-17 23:56:36,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:22.427, using cpu time: 00:06.550
2016-05-17 23:56:36,841 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2016-05-17 23:56:36,868 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:56:36,868 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 23:56:36,910 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 23:56:36,912 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 23:56:36,912 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 23:56:36,932 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting
2016-05-17 23:56:36,932 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:56:36,933 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:56:36,933 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:56:36,933 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2016-05-17 23:56:36,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] parallel execution of steps is enabled: true
2016-05-17 23:56:36,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] executing total steps: 1
2016-05-17 23:56:36,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] allocating management threads: 1
2016-05-17 23:56:36,935 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2016-05-17 23:56:37,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] submitted hadoop job: job_1463528996130_0018
2016-05-17 23:56:37,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0018/
2016-05-17 23:57:03,454 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000002 is : 143
2016-05-17 23:57:03,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000004 is : 143
2016-05-17 23:57:03,881 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000009 is : 143
2016-05-17 23:57:04,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000006 is : 143
2016-05-17 23:57:04,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000003 is : 143
2016-05-17 23:57:04,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000005 is : 143
2016-05-17 23:57:04,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000008 is : 143
2016-05-17 23:57:04,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000010 is : 143
2016-05-17 23:57:04,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000007 is : 143
2016-05-17 23:57:09,640 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0018_01_000011 is : 143
2016-05-17 23:57:10,900 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2016-05-17 23:57:10,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge*offset] completed in: 00:33.965, using cpu time: 00:11.320
2016-05-17 23:57:10,917 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2016-05-17 23:57:10,943 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:57:10,944 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 23:57:11,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-05-17 23:57:11,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 23:57:11,007 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 23:57:11,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting
2016-05-17 23:57:11,048 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:57:11,048 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-05-17 23:57:11,049 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] parallel execution of steps is enabled: true
2016-05-17 23:57:11,049 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] executing total steps: 2
2016-05-17 23:57:11,049 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] allocating management threads: 2
2016-05-17 23:57:11,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (1/2)
2016-05-17 23:57:11,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463528996130_0019
2016-05-17 23:57:11,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0019/
2016-05-17 23:57:28,397 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0019_01_000002 is : 143
2016-05-17 23:57:28,606 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0019_01_000006 is : 143
2016-05-17 23:57:28,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0019_01_000004 is : 143
2016-05-17 23:57:28,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0019_01_000003 is : 143
2016-05-17 23:57:28,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0019_01_000005 is : 143
2016-05-17 23:57:34,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0019_01_000007 is : 143
2016-05-17 23:57:35,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2016-05-17 23:57:35,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] submitted hadoop job: job_1463528996130_0020
2016-05-17 23:57:35,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0020/
2016-05-17 23:57:54,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000002 is : 143
2016-05-17 23:57:55,754 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000003 is : 143
2016-05-17 23:57:56,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000006 is : 143
2016-05-17 23:57:56,328 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000004 is : 143
2016-05-17 23:57:56,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000007 is : 143
2016-05-17 23:57:56,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000005 is : 143
2016-05-17 23:58:00,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0020_01_000008 is : 143
2016-05-17 23:58:02,182 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2016-05-17 23:58:02,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge+offset] completed in: 00:51.127, using cpu time: 00:14.430
2016-05-17 23:58:02,203 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-05-17 23:58:02,234 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:58:02,234 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 23:58:02,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-17 23:58:02,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-17 23:58:02,329 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 23:58:02,361 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting
2016-05-17 23:58:02,361 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:58:02,361 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:58:02,362 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:58:02,362 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2016-05-17 23:58:02,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] parallel execution of steps is enabled: true
2016-05-17 23:58:02,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] executing total steps: 3
2016-05-17 23:58:02,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] allocating management threads: 3
2016-05-17 23:58:02,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (1/3)
2016-05-17 23:58:02,499 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463528996130_0021
2016-05-17 23:58:02,499 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0021/
2016-05-17 23:58:21,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0021_01_000002 is : 143
2016-05-17 23:58:21,434 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0021_01_000003 is : 143
2016-05-17 23:58:22,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0021_01_000007 is : 143
2016-05-17 23:58:22,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0021_01_000005 is : 143
2016-05-17 23:58:22,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0021_01_000004 is : 143
2016-05-17 23:58:22,522 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0021_01_000006 is : 143
2016-05-17 23:58:23,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (2/3)
2016-05-17 23:58:23,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463528996130_0022
2016-05-17 23:58:23,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0022/
2016-05-17 23:58:43,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0022_01_000006 is : 143
2016-05-17 23:58:43,712 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0022_01_000003 is : 143
2016-05-17 23:58:43,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0022_01_000007 is : 143
2016-05-17 23:58:43,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0022_01_000004 is : 143
2016-05-17 23:58:43,847 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0022_01_000002 is : 143
2016-05-17 23:58:44,297 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0022_01_000005 is : 143
2016-05-17 23:58:45,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2016-05-17 23:58:45,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] submitted hadoop job: job_1463528996130_0023
2016-05-17 23:58:45,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0023/
2016-05-17 23:59:04,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0023_01_000006 is : 143
2016-05-17 23:59:05,161 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0023_01_000007 is : 143
2016-05-17 23:59:05,533 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0023_01_000002 is : 143
2016-05-17 23:59:05,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0023_01_000005 is : 143
2016-05-17 23:59:05,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0023_01_000003 is : 143
2016-05-17 23:59:06,012 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0023_01_000004 is : 143
2016-05-17 23:59:07,283 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2016-05-17 23:59:07,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge2*offset] completed in: 01:04.915, using cpu time: 00:21.200
2016-05-17 23:59:07,317 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2016-05-17 23:59:07,344 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:59:07,345 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 23:59:07,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-17 23:59:07,383 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:59:07,384 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 23:59:07,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-17 23:59:07,396 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:59:07,396 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:59:07,397 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:59:07,398 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2016-05-17 23:59:07,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] parallel execution of steps is enabled: true
2016-05-17 23:59:07,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executing total steps: 1
2016-05-17 23:59:07,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] allocating management threads: 1
2016-05-17 23:59:07,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2016-05-17 23:59:07,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463528996130_0024
2016-05-17 23:59:07,520 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0024/
2016-05-17 23:59:24,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0024_01_000006 is : 143
2016-05-17 23:59:24,905 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0024_01_000004 is : 143
2016-05-17 23:59:25,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0024_01_000005 is : 143
2016-05-17 23:59:25,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0024_01_000003 is : 143
2016-05-17 23:59:25,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0024_01_000002 is : 143
2016-05-17 23:59:26,697 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2016-05-17 23:59:26,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] completed in: 00:19.299, using cpu time: 00:05.670
2016-05-17 23:59:26,718 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2016-05-17 23:59:26,742 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:59:26,742 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 23:59:26,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-17 23:59:26,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:59:26,789 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 23:59:26,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting
2016-05-17 23:59:26,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2016-05-17 23:59:26,802 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2016-05-17 23:59:26,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] parallel execution of steps is enabled: true
2016-05-17 23:59:26,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] executing total steps: 1
2016-05-17 23:59:26,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] allocating management threads: 1
2016-05-17 23:59:26,804 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2016-05-17 23:59:26,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] submitted hadoop job: job_1463528996130_0025
2016-05-17 23:59:26,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0025/
2016-05-17 23:59:42,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0025_01_000003 is : 143
2016-05-17 23:59:42,294 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0025_01_000004 is : 143
2016-05-17 23:59:42,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0025_01_000005 is : 143
2016-05-17 23:59:43,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0025_01_000002 is : 143
2016-05-17 23:59:44,406 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2016-05-17 23:59:44,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merged-second] completed in: 00:17.602, using cpu time: 00:04.190
2016-05-17 23:59:44,427 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2016-05-17 23:59:44,451 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:59:44,451 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 23:59:44,526 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-17 23:59:44,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-17 23:59:44,528 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 23:59:44,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting
2016-05-17 23:59:44,561 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.3.x/build/classes/test/data/upper.txt"]
2016-05-17 23:59:44,562 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.3.x/build/classes/test/data/lower.txt"]
2016-05-17 23:59:44,562 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-17 23:59:44,563 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2016-05-17 23:59:44,565 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] parallel execution of steps is enabled: true
2016-05-17 23:59:44,565 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] executing total steps: 2
2016-05-17 23:59:44,565 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] allocating management threads: 2
2016-05-17 23:59:44,569 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (1/2)
2016-05-17 23:59:44,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463528996130_0026
2016-05-17 23:59:44,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0026/
2016-05-18 00:00:04,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0026_01_000002 is : 143
2016-05-18 00:00:04,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0026_01_000003 is : 143
2016-05-18 00:00:04,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0026_01_000007 is : 143
2016-05-18 00:00:05,105 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0026_01_000004 is : 143
2016-05-18 00:00:06,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0026_01_000005 is : 143
2016-05-18 00:00:06,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0026_01_000006 is : 143
2016-05-18 00:00:07,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2016-05-18 00:00:07,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] submitted hadoop job: job_1463528996130_0027
2016-05-18 00:00:07,415 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0027/
2016-05-18 00:00:25,023 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0027_01_000006 is : 143
2016-05-18 00:00:25,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0027_01_000004 is : 143
2016-05-18 00:00:25,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0027_01_000002 is : 143
2016-05-18 00:00:25,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0027_01_000003 is : 143
2016-05-18 00:00:26,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0027_01_000005 is : 143
2016-05-18 00:00:27,307 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2016-05-18 00:00:27,309 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge] completed in: 00:42.742, using cpu time: 00:13.050
2016-05-18 00:00:27,330 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2016-05-18 00:00:27,365 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:00:27,366 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 00:00:27,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.098
2016-05-18 00:00:27,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 00:00:27,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:00:27,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting
2016-05-18 00:00:27,519 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.3.x/build/classes/test/data/upper.txt"]
2016-05-18 00:00:27,519 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.3.x/build/classes/test/data/lower.txt"]
2016-05-18 00:00:27,519 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 00:00:27,520 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2016-05-18 00:00:27,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] parallel execution of steps is enabled: true
2016-05-18 00:00:27,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] executing total steps: 3
2016-05-18 00:00:27,522 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] allocating management threads: 3
2016-05-18 00:00:27,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (1/3)
2016-05-18 00:00:27,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463528996130_0028
2016-05-18 00:00:27,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0028/
2016-05-18 00:00:47,591 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0028_01_000002 is : 143
2016-05-18 00:00:47,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0028_01_000006 is : 143
2016-05-18 00:00:48,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0028_01_000004 is : 143
2016-05-18 00:00:48,172 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0028_01_000005 is : 143
2016-05-18 00:00:48,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0028_01_000007 is : 143
2016-05-18 00:00:49,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (2/3)
2016-05-18 00:00:49,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463528996130_0029
2016-05-18 00:00:49,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0029/
2016-05-18 00:01:06,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0029_01_000002 is : 143
2016-05-18 00:01:07,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0029_01_000003 is : 143
2016-05-18 00:01:07,793 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0029_01_000004 is : 143
2016-05-18 00:01:08,132 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0029_01_000005 is : 143
2016-05-18 00:01:08,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0029_01_000006 is : 143
2016-05-18 00:01:09,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2016-05-18 00:01:09,482 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] submitted hadoop job: job_1463528996130_0030
2016-05-18 00:01:09,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0030/
2016-05-18 00:01:26,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0030_01_000004 is : 143
2016-05-18 00:01:26,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0030_01_000005 is : 143
2016-05-18 00:01:26,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0030_01_000006 is : 143
2016-05-18 00:01:27,269 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0030_01_000002 is : 143
2016-05-18 00:01:27,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0030_01_000003 is : 143
2016-05-18 00:01:28,622 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2016-05-18 00:01:28,625 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*offset*merge1] completed in: 01:01.098, using cpu time: 00:19.300
2016-05-18 00:01:28,644 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2016-05-18 00:01:28,668 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:01:28,668 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 00:01:28,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-18 00:01:28,748 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 00:01:28,749 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:01:28,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting
2016-05-18 00:01:28,817 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.3.x/build/classes/test/data/upper.txt"]
2016-05-18 00:01:28,817 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.3.x/build/classes/test/data/lower.txt"]
2016-05-18 00:01:28,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testGroupByAggregationMerge"]
2016-05-18 00:01:28,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] parallel execution of steps is enabled: true
2016-05-18 00:01:28,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] executing total steps: 3
2016-05-18 00:01:28,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] allocating management threads: 3
2016-05-18 00:01:28,822 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (2/3)
2016-05-18 00:01:28,822 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (1/3)
2016-05-18 00:01:29,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463528996130_0031
2016-05-18 00:01:29,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0031/
2016-05-18 00:01:29,029 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463528996130_0032
2016-05-18 00:01:29,029 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0032/
2016-05-18 00:01:49,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0031_01_000003 is : 143
2016-05-18 00:01:49,919 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0031_01_000002 is : 143
2016-05-18 00:01:50,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0031_01_000005 is : 143
2016-05-18 00:01:50,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0031_01_000004 is : 143
2016-05-18 00:01:50,502 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0031_01_000006 is : 143
2016-05-18 00:02:03,423 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0032_01_000003 is : 143
2016-05-18 00:02:03,753 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0032_01_000006 is : 143
2016-05-18 00:02:03,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0032_01_000004 is : 143
2016-05-18 00:02:03,851 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0032_01_000005 is : 143
2016-05-18 00:02:04,301 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0032_01_000002 is : 143
2016-05-18 00:02:04,997 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0031_01_000007 is : 143
2016-05-18 00:02:09,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0032_01_000007 is : 143
2016-05-18 00:02:11,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] starting step: (3/3) ...stGroupByAggregationMerge
2016-05-18 00:02:11,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] submitted hadoop job: job_1463528996130_0033
2016-05-18 00:02:11,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0033/
2016-05-18 00:02:23,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0033_01_000002 is : 143
2016-05-18 00:02:23,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0033_01_000003 is : 143
2016-05-18 00:02:24,825 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testGroupByAggregationMerge/_temporary
2016-05-18 00:02:24,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [merge] completed in: 00:56.002, using cpu time: 00:14.770
2016-05-18 00:02:24,887 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:02:24,887 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 00:02:24,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-18 00:02:24,945 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 00:02:24,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:02:24,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting
2016-05-18 00:02:24,973 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.3.x/build/classes/test/data/upper.txt"]
2016-05-18 00:02:24,973 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.3.x/build/classes/test/data/lower.txt"]
2016-05-18 00:02:24,974 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.3.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 00:02:24,974 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.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2016-05-18 00:02:24,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] parallel execution of steps is enabled: true
2016-05-18 00:02:24,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] executing total steps: 2
2016-05-18 00:02:24,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] allocating management threads: 2
2016-05-18 00:02:24,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (1/2)
2016-05-18 00:02:25,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463528996130_0034
2016-05-18 00:02:25,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0034/
2016-05-18 00:02:44,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0034_01_000003 is : 143
2016-05-18 00:02:44,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0034_01_000002 is : 143
2016-05-18 00:02:45,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0034_01_000007 is : 143
2016-05-18 00:02:45,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0034_01_000005 is : 143
2016-05-18 00:02:45,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0034_01_000004 is : 143
2016-05-18 00:02:45,470 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0034_01_000006 is : 143
2016-05-18 00:02:46,686 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2016-05-18 00:02:46,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] submitted hadoop job: job_1463528996130_0035
2016-05-18 00:02:46,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] tracking url: http://ip-10-158-37-203.ec2.internal:38126/proxy/application_1463528996130_0035/
2016-05-18 00:03:04,284 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0035_01_000004 is : 143
2016-05-18 00:03:04,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0035_01_000005 is : 143
2016-05-18 00:03:04,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0035_01_000006 is : 143
2016-05-18 00:03:04,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0035_01_000003 is : 143
2016-05-18 00:03:05,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463528996130_0035_01_000002 is : 143
2016-05-18 00:03:06,590 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2016-05-18 00:03:06,592 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [offset*merge2] completed in: 00:41.611, using cpu time: 00:13.430
2016-05-18 00:03:06,613 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge