Class cascading.JoinFieldedPipesPlatformTest

all > cascading > JoinFieldedPipesPlatformTest

tests

failures

12m58.60s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testCross	15.347s	passed
testJoin	16.282s	passed
testJoinAfterEvery	46.092s	passed
testJoinAroundJoinLeftMost	33.306s	passed
testJoinAroundJoinRightMost	16.371s	passed
testJoinAroundJoinRightMostSwapped	32.889s	passed
testJoinDiffFields	16.473s	passed
testJoinFilteredBranch	38.742s	passed
testJoinGroupBy	22.970s	passed
testJoinGroupByJoin	36.807s	passed
testJoinInner	16.552s	passed
testJoinInnerOuter	16.533s	passed
testJoinInnerSingleField	42.277s	passed
testJoinMergeGroupBy	40.243s	passed
testJoinMixed	0s	passed
testJoinNone	15.974s	passed
testJoinOuter	0s	passed
testJoinOuterInner	0s	passed
testJoinSamePipe	16.525s	passed
testJoinSamePipe2	16.298s	passed
testJoinSamePipe3	16.574s	passed
testJoinSamePipeAroundGroupBy	39.251s	passed
testJoinSamePipeName	16.364s	passed
testJoinSameSourceIntoJoin	48.962s	passed
testJoinSelf	32.804s	passed
testJoinWithHasher	17.108s	passed
testJoinWithUnknowns	16.445s	passed
testJoinsIntoCoGroup	24.393s	passed
testJoinsIntoCoGroupLhs	39.811s	passed
testJoinsIntoCoGroupLhsSwappedJoin	23.508s	passed
testJoinsIntoCoGroupRhs	40.452s	passed
testJoinsIntoGroupBy	23.251s	passed

Standard output

2015-08-14 06:17:36,652 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 06:17:36,720 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 06:17:36,721 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.JoinFieldedPipesPlatformTest
2015-08-14 06:17:36,767 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 06:17:37,705 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
2015-08-14 06:17:38,566 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 06:17:39,193 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 06:17:42,972 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 06:17:43,197 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 06:17:43,374 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 06:17:43,565 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-08-14 06:17:55,490 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 06:17:56,889 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 06:17:56,890 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 06:18:00,870 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:18:00,872 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:18:00,886 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 0C83A60566BC49DBB91F5C9A28CAE212
2015-08-14 06:18:01,103 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 06:18:01,105 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:18:01,105 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:18:01,106 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2015-08-14 06:18:01,106 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle"]
2015-08-14 06:18:01,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:18:01,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:18:01,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:18:01,109 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...splatform/joininnersingle
2015-08-14 06:18:02,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0001
2015-08-14 06:18:02,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0001/
2015-08-14 06:18:16,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0001_01_000002 is : 143
2015-08-14 06:18:16,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0001_01_000003 is : 143
2015-08-14 06:18:17,249 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0001_01_000006 is : 143
2015-08-14 06:18:17,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0001_01_000004 is : 143
2015-08-14 06:18:17,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0001_01_000005 is : 143
2015-08-14 06:18:18,868 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle/_temporary
2015-08-14 06:18:19,018 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnersingle
2015-08-14 06:18:19,104 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:18:19,105 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:18:19,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting
2015-08-14 06:18:19,189 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:18:19,190 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:18:19,191 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:18:19,191 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost"]
2015-08-14 06:18:19,192 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  parallel execution is enabled: true
2015-08-14 06:18:19,193 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  starting jobs: 2
2015-08-14 06:18:19,193 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  allocating threads: 2
2015-08-14 06:18:19,195 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (2/2)
2015-08-14 06:18:19,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1439533075175_0002
2015-08-14 06:18:19,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0002/
2015-08-14 06:18:33,712 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0002_01_000003 is : 143
2015-08-14 06:18:33,748 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0002_01_000002 is : 143
2015-08-14 06:18:34,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0002_01_000005 is : 143
2015-08-14 06:18:34,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0002_01_000004 is : 143
2015-08-14 06:18:34,431 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0002_01_000006 is : 143
2015-08-14 06:18:35,759 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (1/2) ...rm/joinaroundjoinleftmost
2015-08-14 06:18:36,027 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1439533075175_0003
2015-08-14 06:18:36,028 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0003/
2015-08-14 06:18:50,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0003_01_000003 is : 143
2015-08-14 06:18:50,178 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0003_01_000002 is : 143
2015-08-14 06:18:50,730 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0003_01_000004 is : 143
2015-08-14 06:18:50,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0003_01_000005 is : 143
2015-08-14 06:18:50,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0003_01_000006 is : 143
2015-08-14 06:18:52,247 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost/_temporary
2015-08-14 06:18:52,330 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost
2015-08-14 06:18:52,380 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:18:52,380 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:18:52,416 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting
2015-08-14 06:18:52,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:18:52,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:18:52,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes"]
2015-08-14 06:18:52,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  parallel execution is enabled: true
2015-08-14 06:18:52,417 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  starting jobs: 1
2015-08-14 06:18:52,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  allocating threads: 1
2015-08-14 06:18:52,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] starting step: (1/1) ...ipesplatform/renamedpipes
2015-08-14 06:18:52,646 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] submitted hadoop job: job_1439533075175_0004
2015-08-14 06:18:52,646 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0004/
2015-08-14 06:19:06,752 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0004_01_000002 is : 143
2015-08-14 06:19:06,810 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0004_01_000003 is : 143
2015-08-14 06:19:07,155 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0004_01_000004 is : 143
2015-08-14 06:19:07,191 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0004_01_000006 is : 143
2015-08-14 06:19:07,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0004_01_000005 is : 143
2015-08-14 06:19:08,616 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes/_temporary
2015-08-14 06:19:08,695 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/renamedpipes
2015-08-14 06:19:08,748 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:19:08,749 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:19:08,822 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:19:08,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:19:08,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:19:08,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery"]
2015-08-14 06:19:08,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:19:08,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-08-14 06:19:08,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-08-14 06:19:08,828 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 06:19:08,828 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 06:19:09,141 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0005
2015-08-14 06:19:09,141 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0005/
2015-08-14 06:19:09,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0006
2015-08-14 06:19:09,144 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0006/
2015-08-14 06:19:25,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0005_01_000006 is : 143
2015-08-14 06:19:25,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0005_01_000002 is : 143
2015-08-14 06:19:25,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0005_01_000005 is : 143
2015-08-14 06:19:25,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0005_01_000003 is : 143
2015-08-14 06:19:25,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0005_01_000004 is : 143
2015-08-14 06:19:30,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0006_01_000003 is : 143
2015-08-14 06:19:30,331 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0006_01_000002 is : 143
2015-08-14 06:19:31,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0006_01_000006 is : 143
2015-08-14 06:19:31,714 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0006_01_000005 is : 143
2015-08-14 06:19:31,812 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0006_01_000004 is : 143
2015-08-14 06:19:34,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0005_01_000007 is : 143
2015-08-14 06:19:37,759 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0006_01_000007 is : 143
2015-08-14 06:19:39,029 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...dpipesplatform/afterevery
2015-08-14 06:19:39,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0007
2015-08-14 06:19:39,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0007/
2015-08-14 06:19:53,441 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0007_01_000002 is : 143
2015-08-14 06:19:54,749 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery/_temporary
2015-08-14 06:19:54,798 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/afterevery
2015-08-14 06:19:54,882 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:19:54,883 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:19:54,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 06:19:54,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:19:54,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:19:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs.txt"]
2015-08-14 06:19:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs.txt"]
2015-08-14 06:19:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin"]
2015-08-14 06:19:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-08-14 06:19:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 1
2015-08-14 06:19:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 1
2015-08-14 06:19:54,943 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-08-14 06:19:55,135 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439533075175_0008
2015-08-14 06:19:55,135 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0008/
2015-08-14 06:20:09,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0008_01_000003 is : 143
2015-08-14 06:20:09,685 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0008_01_000002 is : 143
2015-08-14 06:20:10,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0008_01_000004 is : 143
2015-08-14 06:20:10,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0008_01_000006 is : 143
2015-08-14 06:20:10,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0008_01_000005 is : 143
2015-08-14 06:20:16,982 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0008_01_000007 is : 143
2015-08-14 06:20:18,255 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin/_temporary
2015-08-14 06:20:18,309 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin
2015-08-14 06:20:18,344 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:20:18,344 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:20:18,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 06:20:18,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:20:18,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:20:18,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs.txt"]
2015-08-14 06:20:18,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs.txt"]
2015-08-14 06:20:18,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs"]
2015-08-14 06:20:18,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-08-14 06:20:18,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 2
2015-08-14 06:20:18,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 2
2015-08-14 06:20:18,411 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-08-14 06:20:18,612 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439533075175_0009
2015-08-14 06:20:18,612 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0009/
2015-08-14 06:20:32,673 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0009_01_000003 is : 143
2015-08-14 06:20:33,061 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0009_01_000005 is : 143
2015-08-14 06:20:33,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0009_01_000004 is : 143
2015-08-14 06:20:33,362 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0009_01_000006 is : 143
2015-08-14 06:20:33,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0009_01_000002 is : 143
2015-08-14 06:20:35,060 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouplhs
2015-08-14 06:20:35,287 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439533075175_0010
2015-08-14 06:20:35,287 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0010/
2015-08-14 06:20:49,287 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0010_01_000003 is : 143
2015-08-14 06:20:49,415 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0010_01_000002 is : 143
2015-08-14 06:20:49,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0010_01_000005 is : 143
2015-08-14 06:20:49,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0010_01_000006 is : 143
2015-08-14 06:20:50,157 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0010_01_000004 is : 143
2015-08-14 06:20:56,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0010_01_000007 is : 143
2015-08-14 06:20:58,068 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs/_temporary
2015-08-14 06:20:58,119 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs
2015-08-14 06:20:58,154 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:20:58,155 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:20:58,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 06:20:58,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:20:58,208 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:20:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs.txt"]
2015-08-14 06:20:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs.txt"]
2015-08-14 06:20:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs"]
2015-08-14 06:20:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-08-14 06:20:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 2
2015-08-14 06:20:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 2
2015-08-14 06:20:58,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-08-14 06:20:58,391 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439533075175_0011
2015-08-14 06:20:58,391 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0011/
2015-08-14 06:21:12,719 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0011_01_000003 is : 143
2015-08-14 06:21:12,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0011_01_000002 is : 143
2015-08-14 06:21:13,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0011_01_000006 is : 143
2015-08-14 06:21:13,372 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0011_01_000004 is : 143
2015-08-14 06:21:13,450 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0011_01_000005 is : 143
2015-08-14 06:21:14,742 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouprhs
2015-08-14 06:21:14,919 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439533075175_0012
2015-08-14 06:21:14,920 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0012/
2015-08-14 06:21:28,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0012_01_000006 is : 143
2015-08-14 06:21:29,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0012_01_000004 is : 143
2015-08-14 06:21:29,548 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0012_01_000002 is : 143
2015-08-14 06:21:29,585 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0012_01_000005 is : 143
2015-08-14 06:21:29,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0012_01_000003 is : 143
2015-08-14 06:21:37,230 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0012_01_000007 is : 143
2015-08-14 06:21:38,520 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs/_temporary
2015-08-14 06:21:38,572 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs
2015-08-14 06:21:38,723 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:21:38,724 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:21:38,759 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:21:38,760 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:21:38,760 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:21:38,760 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher"]
2015-08-14 06:21:38,761 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:21:38,761 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:21:38,761 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:21:38,762 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/joinhasher
2015-08-14 06:21:38,945 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0013
2015-08-14 06:21:38,945 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0013/
2015-08-14 06:21:53,596 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0013_01_000003 is : 143
2015-08-14 06:21:53,638 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0013_01_000002 is : 143
2015-08-14 06:21:54,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0013_01_000004 is : 143
2015-08-14 06:21:54,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0013_01_000005 is : 143
2015-08-14 06:21:54,312 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0013_01_000006 is : 143
2015-08-14 06:21:55,604 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher/_temporary
2015-08-14 06:21:55,672 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinhasher
2015-08-14 06:21:55,734 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:21:55,735 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:21:55,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting
2015-08-14 06:21:55,780 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:21:55,780 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 06:21:55,780 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:21:55,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin"]
2015-08-14 06:21:55,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  parallel execution is enabled: true
2015-08-14 06:21:55,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  starting jobs: 2
2015-08-14 06:21:55,781 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  allocating threads: 2
2015-08-14 06:21:55,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (2/2)
2015-08-14 06:21:55,982 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1439533075175_0014
2015-08-14 06:21:55,982 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0014/
2015-08-14 06:22:10,002 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0014_01_000002 is : 143
2015-08-14 06:22:10,147 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0014_01_000003 is : 143
2015-08-14 06:22:10,477 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0014_01_000004 is : 143
2015-08-14 06:22:10,687 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0014_01_000005 is : 143
2015-08-14 06:22:10,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0014_01_000006 is : 143
2015-08-14 06:22:16,799 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0014_01_000007 is : 143
2015-08-14 06:22:18,063 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (1/2) ...splatform/joingroupbyjoin
2015-08-14 06:22:18,239 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1439533075175_0015
2015-08-14 06:22:18,240 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0015/
2015-08-14 06:22:31,126 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0015_01_000002 is : 143
2015-08-14 06:22:32,427 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin/_temporary
2015-08-14 06:22:32,489 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin
2015-08-14 06:22:32,517 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:22:32,517 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:22:32,538 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-14 06:22:32,538 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs.txt"]
2015-08-14 06:22:32,538 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs.txt"]
2015-08-14 06:22:32,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross"]
2015-08-14 06:22:32,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-08-14 06:22:32,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 1
2015-08-14 06:22:32,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 1
2015-08-14 06:22:32,540 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...ieldedpipesplatform/cross
2015-08-14 06:22:32,710 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439533075175_0016
2015-08-14 06:22:32,710 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0016/
2015-08-14 06:22:45,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0016_01_000003 is : 143
2015-08-14 06:22:45,989 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0016_01_000002 is : 143
2015-08-14 06:22:46,430 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0016_01_000005 is : 143
2015-08-14 06:22:46,466 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0016_01_000004 is : 143
2015-08-14 06:22:47,756 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross/_temporary
2015-08-14 06:22:47,828 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/cross
2015-08-14 06:22:47,864 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:22:47,864 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:22:47,886 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:22:47,886 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:22:47,886 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:22:47,887 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join"]
2015-08-14 06:22:47,887 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:22:47,887 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:22:47,887 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:22:47,888 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...fieldedpipesplatform/join
2015-08-14 06:22:48,084 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0017
2015-08-14 06:22:48,085 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0017/
2015-08-14 06:23:02,001 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0017_01_000006 is : 143
2015-08-14 06:23:02,544 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0017_01_000005 is : 143
2015-08-14 06:23:02,625 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0017_01_000002 is : 143
2015-08-14 06:23:02,690 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0017_01_000004 is : 143
2015-08-14 06:23:02,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0017_01_000003 is : 143
2015-08-14 06:23:04,040 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join/_temporary
2015-08-14 06:23:04,109 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/join
2015-08-14 06:23:04,150 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:23:04,151 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:23:04,186 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting
2015-08-14 06:23:04,186 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:23:04,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:23:04,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs.txt"]
2015-08-14 06:23:04,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs.txt"]
2015-08-14 06:23:04,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby"]
2015-08-14 06:23:04,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  parallel execution is enabled: true
2015-08-14 06:23:04,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  starting jobs: 1
2015-08-14 06:23:04,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  allocating threads: 1
2015-08-14 06:23:04,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] starting step: (1/1) ...platform/joinsintogroupby
2015-08-14 06:23:04,365 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] submitted hadoop job: job_1439533075175_0018
2015-08-14 06:23:04,365 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0018/
2015-08-14 06:23:19,403 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000002 is : 143
2015-08-14 06:23:19,458 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000003 is : 143
2015-08-14 06:23:19,753 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000007 is : 143
2015-08-14 06:23:19,851 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000006 is : 143
2015-08-14 06:23:19,931 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000005 is : 143
2015-08-14 06:23:20,002 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000004 is : 143
2015-08-14 06:23:26,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0018_01_000008 is : 143
2015-08-14 06:23:27,321 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby/_temporary
2015-08-14 06:23:27,370 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby
2015-08-14 06:23:27,397 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:23:27,398 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:23:27,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:23:27,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:23:27,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:23:27,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown"]
2015-08-14 06:23:27,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:23:27,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:23:27,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:23:27,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ldedpipesplatform/unknown
2015-08-14 06:23:27,593 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0019
2015-08-14 06:23:27,593 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0019/
2015-08-14 06:23:41,864 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0019_01_000003 is : 143
2015-08-14 06:23:41,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0019_01_000002 is : 143
2015-08-14 06:23:42,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0019_01_000006 is : 143
2015-08-14 06:23:42,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0019_01_000004 is : 143
2015-08-14 06:23:42,448 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0019_01_000005 is : 143
2015-08-14 06:23:43,739 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown/_temporary
2015-08-14 06:23:43,805 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/unknown
2015-08-14 06:23:43,845 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:23:43,845 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:23:43,880 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-08-14 06:23:43,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:23:43,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:23:43,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:23:43,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost"]
2015-08-14 06:23:43,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  parallel execution is enabled: true
2015-08-14 06:23:43,881 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  starting jobs: 1
2015-08-14 06:23:43,882 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  allocating threads: 1
2015-08-14 06:23:43,885 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/1) ...m/joinaroundjoinrightmost
2015-08-14 06:23:44,070 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439533075175_0020
2015-08-14 06:23:44,070 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0020/
2015-08-14 06:23:58,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0020_01_000006 is : 143
2015-08-14 06:23:58,634 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0020_01_000003 is : 143
2015-08-14 06:23:58,670 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0020_01_000004 is : 143
2015-08-14 06:23:58,751 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0020_01_000002 is : 143
2015-08-14 06:23:58,809 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0020_01_000005 is : 143
2015-08-14 06:24:00,113 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost/_temporary
2015-08-14 06:24:00,178 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost
2015-08-14 06:24:00,215 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:24:00,216 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:24:00,236 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:24:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:24:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:24:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone"]
2015-08-14 06:24:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:24:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:24:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:24:00,238 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dedpipesplatform/joinnone
2015-08-14 06:24:00,411 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0021
2015-08-14 06:24:00,411 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0021/
2015-08-14 06:24:14,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0021_01_000002 is : 143
2015-08-14 06:24:14,414 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0021_01_000003 is : 143
2015-08-14 06:24:14,733 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0021_01_000004 is : 143
2015-08-14 06:24:14,772 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0021_01_000005 is : 143
2015-08-14 06:24:14,805 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0021_01_000006 is : 143
2015-08-14 06:24:16,086 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone/_temporary
2015-08-14 06:24:16,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinnone
2015-08-14 06:24:16,188 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:24:16,189 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:24:16,217 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:24:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:24:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:24:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself"]
2015-08-14 06:24:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:24:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 06:24:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 06:24:16,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 06:24:16,316 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-14 06:24:16,420 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0022
2015-08-14 06:24:16,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0022/
2015-08-14 06:24:30,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0022_01_000003 is : 143
2015-08-14 06:24:30,610 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0022_01_000002 is : 143
2015-08-14 06:24:30,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0022_01_000006 is : 143
2015-08-14 06:24:31,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0022_01_000004 is : 143
2015-08-14 06:24:31,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0022_01_000005 is : 143
2015-08-14 06:24:32,566 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...dedpipesplatform/joinself
2015-08-14 06:24:32,742 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0023
2015-08-14 06:24:32,742 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0023/
2015-08-14 06:24:46,674 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0023_01_000003 is : 143
2015-08-14 06:24:46,743 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0023_01_000002 is : 143
2015-08-14 06:24:47,328 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0023_01_000006 is : 143
2015-08-14 06:24:47,361 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0023_01_000004 is : 143
2015-08-14 06:24:47,600 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0023_01_000005 is : 143
2015-08-14 06:24:48,891 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself/_temporary
2015-08-14 06:24:48,957 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinself
2015-08-14 06:24:48,996 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:24:48,996 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:24:49,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting
2015-08-14 06:24:49,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:24:49,038 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:24:49,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:24:49,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped"]
2015-08-14 06:24:49,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  parallel execution is enabled: true
2015-08-14 06:24:49,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  starting jobs: 2
2015-08-14 06:24:49,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  allocating threads: 2
2015-08-14 06:24:49,040 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (2/2)
2015-08-14 06:24:49,294 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1439533075175_0024
2015-08-14 06:24:49,294 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0024/
2015-08-14 06:25:03,399 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0024_01_000002 is : 143
2015-08-14 06:25:03,443 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0024_01_000003 is : 143
2015-08-14 06:25:04,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0024_01_000005 is : 143
2015-08-14 06:25:04,131 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0024_01_000006 is : 143
2015-08-14 06:25:04,166 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0024_01_000004 is : 143
2015-08-14 06:25:05,477 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (1/2) ...orm/joinaroundjoinswapped
2015-08-14 06:25:05,649 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1439533075175_0025
2015-08-14 06:25:05,650 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0025/
2015-08-14 06:25:19,632 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0025_01_000006 is : 143
2015-08-14 06:25:20,233 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0025_01_000004 is : 143
2015-08-14 06:25:20,395 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0025_01_000005 is : 143
2015-08-14 06:25:20,434 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0025_01_000002 is : 143
2015-08-14 06:25:20,467 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0025_01_000003 is : 143
2015-08-14 06:25:21,781 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped/_temporary
2015-08-14 06:25:21,846 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped
2015-08-14 06:25:21,885 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:25:21,885 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:25:21,918 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:25:21,919 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:25:21,919 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:25:21,919 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch"]
2015-08-14 06:25:21,919 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:25:21,919 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-08-14 06:25:21,920 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-08-14 06:25:21,921 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 06:25:22,100 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0026
2015-08-14 06:25:22,101 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0026/
2015-08-14 06:25:35,939 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0026_01_000003 is : 143
2015-08-14 06:25:35,991 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0026_01_000002 is : 143
2015-08-14 06:25:36,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0026_01_000004 is : 143
2015-08-14 06:25:36,469 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0026_01_000006 is : 143
2015-08-14 06:25:36,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0026_01_000005 is : 143
2015-08-14 06:25:43,024 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0026_01_000007 is : 143
2015-08-14 06:25:44,330 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...atform/joinfilteredbranch
2015-08-14 06:25:44,515 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0027
2015-08-14 06:25:44,515 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0027/
2015-08-14 06:25:58,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0027_01_000002 is : 143
2015-08-14 06:25:58,548 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0027_01_000003 is : 143
2015-08-14 06:25:58,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0027_01_000006 is : 143
2015-08-14 06:25:59,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0027_01_000005 is : 143
2015-08-14 06:25:59,210 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0027_01_000004 is : 143
2015-08-14 06:26:00,523 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch/_temporary
2015-08-14 06:26:00,588 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch
2015-08-14 06:26:00,624 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:26:00,625 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:26:00,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-08-14 06:26:00,679 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:26:00,679 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:26:00,679 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:26:00,679 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin"]
2015-08-14 06:26:00,680 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  parallel execution is enabled: true
2015-08-14 06:26:00,680 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  starting jobs: 3
2015-08-14 06:26:00,680 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  allocating threads: 3
2015-08-14 06:26:00,683 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (3/3)
2015-08-14 06:26:00,871 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439533075175_0028
2015-08-14 06:26:00,871 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0028/
2015-08-14 06:26:14,777 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0028_01_000002 is : 143
2015-08-14 06:26:14,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0028_01_000003 is : 143
2015-08-14 06:26:15,449 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0028_01_000006 is : 143
2015-08-14 06:26:15,491 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0028_01_000004 is : 143
2015-08-14 06:26:15,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0028_01_000005 is : 143
2015-08-14 06:26:16,894 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (2/3)
2015-08-14 06:26:17,072 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439533075175_0029
2015-08-14 06:26:17,072 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0029/
2015-08-14 06:26:31,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0029_01_000003 is : 143
2015-08-14 06:26:31,373 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0029_01_000002 is : 143
2015-08-14 06:26:31,637 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0029_01_000004 is : 143
2015-08-14 06:26:31,696 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0029_01_000006 is : 143
2015-08-14 06:26:31,730 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0029_01_000005 is : 143
2015-08-14 06:26:33,022 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/3) ...rm/joinsamesourceintojoin
2015-08-14 06:26:33,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439533075175_0030
2015-08-14 06:26:33,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0030/
2015-08-14 06:26:47,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0030_01_000002 is : 143
2015-08-14 06:26:47,635 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0030_01_000003 is : 143
2015-08-14 06:26:47,747 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0030_01_000006 is : 143
2015-08-14 06:26:48,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0030_01_000005 is : 143
2015-08-14 06:26:48,176 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0030_01_000004 is : 143
2015-08-14 06:26:49,475 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin/_temporary
2015-08-14 06:26:49,550 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin
2015-08-14 06:26:49,590 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:26:49,591 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:26:49,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 06:26:49,630 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:26:49,630 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:26:49,630 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs.txt"]
2015-08-14 06:26:49,630 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs.txt"]
2015-08-14 06:26:49,630 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup"]
2015-08-14 06:26:49,630 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-08-14 06:26:49,631 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 1
2015-08-14 06:26:49,631 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 1
2015-08-14 06:26:49,632 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...platform/joinsintocogroup
2015-08-14 06:26:49,822 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439533075175_0031
2015-08-14 06:26:49,822 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0031/
2015-08-14 06:27:05,675 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000002 is : 143
2015-08-14 06:27:05,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000003 is : 143
2015-08-14 06:27:06,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000006 is : 143
2015-08-14 06:27:06,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000005 is : 143
2015-08-14 06:27:06,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000004 is : 143
2015-08-14 06:27:06,262 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000007 is : 143
2015-08-14 06:27:12,598 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0031_01_000008 is : 143
2015-08-14 06:27:13,905 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup/_temporary
2015-08-14 06:27:13,952 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup
2015-08-14 06:27:14,023 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:27:14,024 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:27:14,056 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:27:14,056 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-14 06:27:14,056 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-14 06:27:14,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner"]
2015-08-14 06:27:14,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:27:14,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:27:14,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:27:14,058 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...edpipesplatform/joininner
2015-08-14 06:27:14,236 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0032
2015-08-14 06:27:14,237 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0032/
2015-08-14 06:27:28,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0032_01_000002 is : 143
2015-08-14 06:27:28,531 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0032_01_000003 is : 143
2015-08-14 06:27:28,732 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0032_01_000006 is : 143
2015-08-14 06:27:28,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0032_01_000004 is : 143
2015-08-14 06:27:29,082 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0032_01_000005 is : 143
2015-08-14 06:27:30,416 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner/_temporary
2015-08-14 06:27:30,497 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininner
2015-08-14 06:27:30,533 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:27:30,533 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:27:30,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-14 06:27:30,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:27:30,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby"]
2015-08-14 06:27:30,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-08-14 06:27:30,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 2
2015-08-14 06:27:30,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 2
2015-08-14 06:27:30,569 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (2/2)
2015-08-14 06:27:30,743 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439533075175_0033
2015-08-14 06:27:30,743 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0033/
2015-08-14 06:27:45,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0033_01_000002 is : 143
2015-08-14 06:27:45,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0033_01_000003 is : 143
2015-08-14 06:27:45,475 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0033_01_000005 is : 143
2015-08-14 06:27:45,585 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0033_01_000006 is : 143
2015-08-14 06:27:45,752 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0033_01_000004 is : 143
2015-08-14 06:27:52,146 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0033_01_000007 is : 143
2015-08-14 06:27:53,423 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/2) ...orm/samepipearoundgroupby
2015-08-14 06:27:53,588 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439533075175_0034
2015-08-14 06:27:53,589 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0034/
2015-08-14 06:28:07,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0034_01_000002 is : 143
2015-08-14 06:28:07,682 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0034_01_000003 is : 143
2015-08-14 06:28:08,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0034_01_000006 is : 143
2015-08-14 06:28:08,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0034_01_000004 is : 143
2015-08-14 06:28:08,384 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0034_01_000005 is : 143
2015-08-14 06:28:09,671 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby/_temporary
2015-08-14 06:28:09,748 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby
2015-08-14 06:28:09,824 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:28:09,825 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:28:09,864 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-08-14 06:28:09,864 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextLine[['id2']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 06:28:09,864 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextLine[['id']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.10.txt"]
2015-08-14 06:28:09,864 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  sink: Hfs["TextDelimited[['id2', 'count']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin"]
2015-08-14 06:28:09,865 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  parallel execution is enabled: true
2015-08-14 06:28:09,865 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  starting jobs: 2
2015-08-14 06:28:09,865 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  allocating threads: 2
2015-08-14 06:28:09,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2)
2015-08-14 06:28:10,055 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439533075175_0035
2015-08-14 06:28:10,055 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0035/
2015-08-14 06:28:24,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0035_01_000004 is : 143
2015-08-14 06:28:24,141 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0035_01_000002 is : 143
2015-08-14 06:28:24,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0035_01_000003 is : 143
2015-08-14 06:28:24,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0035_01_000005 is : 143
2015-08-14 06:28:25,483 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...JoinMergeGroupBy/hashjoin
2015-08-14 06:28:25,699 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439533075175_0036
2015-08-14 06:28:25,699 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0036/
2015-08-14 06:28:41,482 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000003 is : 143
2015-08-14 06:28:41,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000002 is : 143
2015-08-14 06:28:42,095 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000007 is : 143
2015-08-14 06:28:42,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000005 is : 143
2015-08-14 06:28:42,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000004 is : 143
2015-08-14 06:28:42,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000006 is : 143
2015-08-14 06:28:42,418 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000008 is : 143
2015-08-14 06:28:48,682 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0036_01_000009 is : 143
2015-08-14 06:28:49,954 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin/_temporary
2015-08-14 06:28:50,001 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin
2015-08-14 06:28:50,026 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:28:50,026 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:28:50,041 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-14 06:28:50,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:28:50,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2"]
2015-08-14 06:28:50,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-08-14 06:28:50,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-08-14 06:28:50,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-08-14 06:28:50,044 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...edpipesplatform/samepipe2
2015-08-14 06:28:50,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439533075175_0037
2015-08-14 06:28:50,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0037/
2015-08-14 06:29:04,195 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0037_01_000003 is : 143
2015-08-14 06:29:04,436 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0037_01_000002 is : 143
2015-08-14 06:29:04,882 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0037_01_000006 is : 143
2015-08-14 06:29:04,920 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0037_01_000005 is : 143
2015-08-14 06:29:04,954 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0037_01_000004 is : 143
2015-08-14 06:29:06,227 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2/_temporary
2015-08-14 06:29:06,290 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe2
2015-08-14 06:29:06,325 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:29:06,325 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:29:06,350 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting
2015-08-14 06:29:06,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:29:06,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3"]
2015-08-14 06:29:06,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  parallel execution is enabled: true
2015-08-14 06:29:06,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  starting jobs: 1
2015-08-14 06:29:06,351 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  allocating threads: 1
2015-08-14 06:29:06,352 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] starting step: (1/1) ...edpipesplatform/samepipe3
2015-08-14 06:29:06,532 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] submitted hadoop job: job_1439533075175_0038
2015-08-14 06:29:06,533 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0038/
2015-08-14 06:29:20,399 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0038_01_000003 is : 143
2015-08-14 06:29:21,007 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0038_01_000006 is : 143
2015-08-14 06:29:21,058 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0038_01_000004 is : 143
2015-08-14 06:29:21,225 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0038_01_000005 is : 143
2015-08-14 06:29:21,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0038_01_000002 is : 143
2015-08-14 06:29:22,804 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3/_temporary
2015-08-14 06:29:22,866 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe3
2015-08-14 06:29:22,900 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:29:22,900 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:29:22,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:29:22,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:29:22,932 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:29:22,932 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby"]
2015-08-14 06:29:22,932 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:29:22,932 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:29:22,932 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:29:22,933 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...pipesplatform/joingroupby
2015-08-14 06:29:23,107 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0039
2015-08-14 06:29:23,107 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0039/
2015-08-14 06:29:36,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0039_01_000003 is : 143
2015-08-14 06:29:36,954 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0039_01_000002 is : 143
2015-08-14 06:29:37,737 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0039_01_000005 is : 143
2015-08-14 06:29:38,005 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0039_01_000006 is : 143
2015-08-14 06:29:38,041 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0039_01_000004 is : 143
2015-08-14 06:29:44,533 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0039_01_000007 is : 143
2015-08-14 06:29:45,799 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby/_temporary
2015-08-14 06:29:45,844 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupby
2015-08-14 06:29:45,869 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:29:45,869 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:29:45,884 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-14 06:29:45,884 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:29:45,885 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe"]
2015-08-14 06:29:45,885 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-08-14 06:29:45,885 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-08-14 06:29:45,885 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-08-14 06:29:45,887 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...dedpipesplatform/samepipe
2015-08-14 06:29:46,066 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439533075175_0040
2015-08-14 06:29:46,067 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0040/
2015-08-14 06:30:00,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0040_01_000002 is : 143
2015-08-14 06:30:00,432 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0040_01_000003 is : 143
2015-08-14 06:30:00,818 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0040_01_000004 is : 143
2015-08-14 06:30:00,935 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0040_01_000006 is : 143
2015-08-14 06:30:00,999 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0040_01_000005 is : 143
2015-08-14 06:30:02,287 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe/_temporary
2015-08-14 06:30:02,360 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe
2015-08-14 06:30:02,397 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:30:02,398 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:30:02,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:30:02,418 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-14 06:30:02,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-14 06:30:02,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter"]
2015-08-14 06:30:02,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:30:02,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:30:02,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:30:02,424 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/joininnerouter
2015-08-14 06:30:02,606 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0041
2015-08-14 06:30:02,606 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0041/
2015-08-14 06:30:16,847 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0041_01_000003 is : 143
2015-08-14 06:30:16,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0041_01_000002 is : 143
2015-08-14 06:30:17,414 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0041_01_000006 is : 143
2015-08-14 06:30:17,495 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0041_01_000004 is : 143
2015-08-14 06:30:17,534 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0041_01_000005 is : 143
2015-08-14 06:30:18,817 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter/_temporary
2015-08-14 06:30:18,894 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnerouter
2015-08-14 06:30:18,928 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:30:18,929 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 06:30:18,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:30:18,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 06:30:18,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 06:30:18,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields"]
2015-08-14 06:30:18,949 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-08-14 06:30:18,949 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-08-14 06:30:18,949 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-08-14 06:30:18,951 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/difffields
2015-08-14 06:30:19,131 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439533075175_0042
2015-08-14 06:30:19,131 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:40254/proxy/application_1439533075175_0042/
2015-08-14 06:30:33,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0042_01_000002 is : 143
2015-08-14 06:30:33,327 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0042_01_000003 is : 143
2015-08-14 06:30:33,863 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0042_01_000006 is : 143
2015-08-14 06:30:33,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0042_01_000005 is : 143
2015-08-14 06:30:34,008 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439533075175_0042_01_000004 is : 143
2015-08-14 06:30:35,304 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields/_temporary
2015-08-14 06:30:35,367 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/difffields

Standard error

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