Class cascading.JoinFieldedPipesPlatformTest

44

tests

0

failures

0

ignored

38m19.12s

duration

100%

successful

Tests

Test Duration Result
testCross 24.541s passed
testForkCoGroupThenHashJoin 2m2.53s passed
testForkCoGroupThenHashJoinCoGroupAgain 3m10.15s passed
testForkThenJoin 55.838s passed
testGroupBySplitAroundSplitGroupByJoin 2m12.71s passed
testGroupBySplitGroupByJoin 1m44.17s passed
testGroupBySplitJoins 1m11.74s passed
testGroupBySplitSplitGroupByJoin 1m37.98s passed
testJoin 26.611s passed
testJoinAfterEvery 1m25.89s passed
testJoinAroundJoinLeftMost 54.950s passed
testJoinAroundJoinRightMost 27.483s passed
testJoinAroundJoinRightMostSwapped 54.832s passed
testJoinDiffFields 27.399s passed
testJoinFilteredBranch 1m0.36s passed
testJoinGroupBy 32.546s passed
testJoinGroupByJoin 52.273s passed
testJoinInner 27.536s passed
testJoinInnerOuter 27.162s passed
testJoinInnerSingleField 49.187s passed
testJoinMergeGroupBy 0.077s passed
testJoinMixed 0s passed
testJoinNone 26.669s passed
testJoinOuter 0s passed
testJoinOuterInner 0s passed
testJoinSamePipe 27.875s passed
testJoinSamePipe2 27.133s passed
testJoinSamePipe3 26.989s passed
testJoinSamePipeAroundGroupBy 58.671s passed
testJoinSamePipeName 27.118s passed
testJoinSameSourceIntoJoin 1m22.78s passed
testJoinSameSourceIntoJoinSimple 55.745s passed
testJoinSameSourceOverGroupByIntoJoinSimple 1m24.95s passed
testJoinSelf 55.275s passed
testJoinSplit 50.160s passed
testJoinSplitBeforeJoin 1m31.76s passed
testJoinWithHasher 27.728s passed
testJoinWithUnknowns 26.936s passed
testJoinsIntoCoGroup 35.168s passed
testJoinsIntoCoGroupLhs 1m1.30s passed
testJoinsIntoCoGroupLhsSwappedJoin 33.355s passed
testJoinsIntoCoGroupRhs 1m3.28s passed
testJoinsIntoGroupBy 35.327s passed
testSameSourceJoinSplitIntoJoin 1m14.93s passed

Standard output

2016-05-18 09:08:05,141 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 09:08:05,162 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 09:08:05,193 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 09:08:06,186 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2016-05-18 09:08:06,847 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(125)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 09:08:10,661 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:10,865 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:11,047 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:11,225 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 09:08:29,823 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 09:08:29,943 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:08:29,944 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:08:30,008 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 1ACB1F03A62B4B068ADD5AD2FF500300
2016-05-18 09:08:30,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.099
2016-05-18 09:08:30,155 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:08:30,156 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:08:30,286 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 09:08:30,287 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:08:30,287 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:08:30,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 09:08:30,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2016-05-18 09:08:30,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:08:30,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:08:30,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:08:30,293 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2016-05-18 09:08:31,269 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0001
2016-05-18 09:08:31,270 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0001/
2016-05-18 09:08:52,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000006 is : 143
2016-05-18 09:08:52,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000004 is : 143
2016-05-18 09:08:52,484 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000005 is : 143
2016-05-18 09:08:52,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000002 is : 143
2016-05-18 09:08:52,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0001_01_000003 is : 143
2016-05-18 09:08:54,264 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2016-05-18 09:08:54,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:23.972, using cpu time: 00:05.640
2016-05-18 09:08:54,359 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2016-05-18 09:08:54,408 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:08:54,408 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:08:54,504 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-05-18 09:08:54,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:08:54,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:08:54,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 09:08:54,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:08:54,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:08:54,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2016-05-18 09:08:54,549 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 09:08:54,549 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  executing total steps: 2
2016-05-18 09:08:54,549 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  allocating management threads: 2
2016-05-18 09:08:54,550 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/2)
2016-05-18 09:08:54,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0002
2016-05-18 09:08:54,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0002/
2016-05-18 09:09:20,257 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000006 is : 143
2016-05-18 09:09:20,611 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000004 is : 143
2016-05-18 09:09:20,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000005 is : 143
2016-05-18 09:09:21,030 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000003 is : 143
2016-05-18 09:09:21,074 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0002_01_000002 is : 143
2016-05-18 09:09:22,243 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2016-05-18 09:09:22,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0003
2016-05-18 09:09:22,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0003/
2016-05-18 09:09:47,472 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000006 is : 143
2016-05-18 09:09:48,208 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000005 is : 143
2016-05-18 09:09:48,739 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000002 is : 143
2016-05-18 09:09:48,791 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000003 is : 143
2016-05-18 09:09:48,846 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0003_01_000004 is : 143
2016-05-18 09:09:50,036 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2016-05-18 09:09:50,038 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  completed in: 00:55.483, using cpu time: 00:12.000
2016-05-18 09:09:50,107 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2016-05-18 09:09:50,170 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:09:50,171 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:09:50,278 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.097
2016-05-18 09:09:50,280 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:09:50,281 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:09:50,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting
2016-05-18 09:09:50,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:09:50,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:09:50,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:09:50,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2016-05-18 09:09:50,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  parallel execution of steps is enabled: true
2016-05-18 09:09:50,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  executing total steps: 2
2016-05-18 09:09:50,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  allocating management threads: 2
2016-05-18 09:09:50,315 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (1/2)
2016-05-18 09:09:50,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463562504321_0004
2016-05-18 09:09:50,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0004/
2016-05-18 09:10:15,854 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000004 is : 143
2016-05-18 09:10:15,961 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000002 is : 143
2016-05-18 09:10:16,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000005 is : 143
2016-05-18 09:10:16,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000003 is : 143
2016-05-18 09:10:16,663 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0004_01_000006 is : 143
2016-05-18 09:10:17,832 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2016-05-18 09:10:18,019 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463562504321_0005
2016-05-18 09:10:18,020 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0005/
2016-05-18 09:10:42,606 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000006 is : 143
2016-05-18 09:10:43,353 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000005 is : 143
2016-05-18 09:10:43,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000003 is : 143
2016-05-18 09:10:43,611 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000002 is : 143
2016-05-18 09:10:43,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0005_01_000004 is : 143
2016-05-18 09:10:44,999 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2016-05-18 09:10:45,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  completed in: 00:54.685, using cpu time: 00:12.340
2016-05-18 09:10:45,061 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2016-05-18 09:10:45,097 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:10:45,098 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:10:45,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-05-18 09:10:45,171 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:10:45,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:10:45,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting
2016-05-18 09:10:45,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:10:45,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:10:45,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2016-05-18 09:10:45,198 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  parallel execution of steps is enabled: true
2016-05-18 09:10:45,198 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  executing total steps: 1
2016-05-18 09:10:45,198 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  allocating management threads: 1
2016-05-18 09:10:45,199 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-05-18 09:10:45,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] submitted hadoop job: job_1463562504321_0006
2016-05-18 09:10:45,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0006/
2016-05-18 09:11:10,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000002 is : 143
2016-05-18 09:11:10,725 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000003 is : 143
2016-05-18 09:11:10,799 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000006 is : 143
2016-05-18 09:11:10,910 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0006_01_000005 is : 143
2016-05-18 09:11:12,113 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2016-05-18 09:11:12,116 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  completed in: 00:26.910, using cpu time: 00:05.960
2016-05-18 09:11:12,182 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2016-05-18 09:11:12,215 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:11:12,215 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:11:12,305 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-18 09:11:12,310 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 09:11:12,310 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:11:12,362 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:11:12,362 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:11:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:11:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2016-05-18 09:11:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:11:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 3
2016-05-18 09:11:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 3
2016-05-18 09:11:12,364 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 09:11:12,364 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 09:11:12,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0008
2016-05-18 09:11:12,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0008/
2016-05-18 09:11:12,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0007
2016-05-18 09:11:12,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0007/
2016-05-18 09:11:37,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000002 is : 143
2016-05-18 09:11:37,920 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000003 is : 143
2016-05-18 09:11:38,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000005 is : 143
2016-05-18 09:11:38,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000004 is : 143
2016-05-18 09:11:38,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000006 is : 143
2016-05-18 09:11:44,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0007_01_000007 is : 143
2016-05-18 09:12:11,755 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000006 is : 143
2016-05-18 09:12:11,813 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000003 is : 143
2016-05-18 09:12:12,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000002 is : 143
2016-05-18 09:12:12,466 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000005 is : 143
2016-05-18 09:12:18,386 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0008_01_000007 is : 143
2016-05-18 09:12:19,577 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2016-05-18 09:12:19,729 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0009
2016-05-18 09:12:19,729 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0009/
2016-05-18 09:12:36,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0009_01_000002 is : 143
2016-05-18 09:12:38,043 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2016-05-18 09:12:38,045 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 01:25.677, using cpu time: 00:14.960
2016-05-18 09:12:38,079 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2016-05-18 09:12:38,206 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:12:38,207 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:12:38,403 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.190
2016-05-18 09:12:38,406 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 6, nodes: 12
2016-05-18 09:12:38,407 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:12:38,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:12:38,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:12:38,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:12:38,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join"]
2016-05-18 09:12:38,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 09:12:38,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 6
2016-05-18 09:12:38,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 6
2016-05-18 09:12:38,573 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/6)
2016-05-18 09:12:38,573 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/6)
2016-05-18 09:12:38,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0011
2016-05-18 09:12:38,743 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0011/
2016-05-18 09:12:38,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0010
2016-05-18 09:12:38,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0010/
2016-05-18 09:13:04,250 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000003 is : 143
2016-05-18 09:13:04,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000002 is : 143
2016-05-18 09:13:04,708 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000006 is : 143
2016-05-18 09:13:04,791 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000004 is : 143
2016-05-18 09:13:05,188 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000005 is : 143
2016-05-18 09:13:11,139 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0010_01_000007 is : 143
2016-05-18 09:13:38,821 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000006 is : 143
2016-05-18 09:13:38,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000003 is : 143
2016-05-18 09:13:39,090 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000005 is : 143
2016-05-18 09:13:39,175 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000004 is : 143
2016-05-18 09:13:39,395 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000002 is : 143
2016-05-18 09:13:45,288 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0011_01_000007 is : 143
2016-05-18 09:13:46,434 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (3/6)
2016-05-18 09:13:46,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0012
2016-05-18 09:13:46,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0012/
2016-05-18 09:14:05,518 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0012_01_000002 is : 143
2016-05-18 09:14:05,576 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0012_01_000003 is : 143
2016-05-18 09:14:12,980 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0012_01_000004 is : 143
2016-05-18 09:14:14,133 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (4/6)
2016-05-18 09:14:14,137 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (5/6)
2016-05-18 09:14:14,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0013
2016-05-18 09:14:14,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0013/
2016-05-18 09:14:14,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0014
2016-05-18 09:14:14,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0014/
2016-05-18 09:14:39,432 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000002 is : 143
2016-05-18 09:14:39,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000003 is : 143
2016-05-18 09:14:39,837 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000005 is : 143
2016-05-18 09:14:40,581 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000006 is : 143
2016-05-18 09:14:40,679 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000004 is : 143
2016-05-18 09:14:46,410 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0013_01_000007 is : 143
2016-05-18 09:15:12,620 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000002 is : 143
2016-05-18 09:15:12,738 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000003 is : 143
2016-05-18 09:15:12,918 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000005 is : 143
2016-05-18 09:15:13,091 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000004 is : 143
2016-05-18 09:15:13,397 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000006 is : 143
2016-05-18 09:15:19,911 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0014_01_000007 is : 143
2016-05-18 09:15:21,070 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (6/6) ...HashJoinCoGroupAgain/join
2016-05-18 09:15:21,202 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0015
2016-05-18 09:15:21,203 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0015/
2016-05-18 09:15:40,157 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0015_01_000003 is : 143
2016-05-18 09:15:40,270 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0015_01_000002 is : 143
2016-05-18 09:15:47,007 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0015_01_000004 is : 143
2016-05-18 09:15:48,188 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join/_temporary
2016-05-18 09:15:48,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 03:09.611, using cpu time: 00:44.280
2016-05-18 09:15:48,226 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join
2016-05-18 09:15:48,281 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:15:48,282 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:15:48,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 09:15:48,354 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:15:48,355 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:15:48,377 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:15:48,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:15:48,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:15:48,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:15:48,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:15:48,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2016-05-18 09:15:48,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 09:15:48,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 1
2016-05-18 09:15:48,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 1
2016-05-18 09:15:48,381 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2016-05-18 09:15:48,522 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0016
2016-05-18 09:15:48,522 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0016/
2016-05-18 09:16:13,871 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000002 is : 143
2016-05-18 09:16:14,445 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000003 is : 143
2016-05-18 09:16:14,520 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000004 is : 143
2016-05-18 09:16:14,580 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000006 is : 143
2016-05-18 09:16:14,629 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000005 is : 143
2016-05-18 09:16:20,322 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0016_01_000007 is : 143
2016-05-18 09:16:21,544 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2016-05-18 09:16:21,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:33.161, using cpu time: 00:07.640
2016-05-18 09:16:21,582 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2016-05-18 09:16:21,619 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:16:21,619 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:16:21,698 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-05-18 09:16:21,699 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 09:16:21,700 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:16:21,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting
2016-05-18 09:16:21,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:16:21,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:16:21,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 09:16:21,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2016-05-18 09:16:21,736 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2016-05-18 09:16:21,736 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  parallel execution of steps is enabled: true
2016-05-18 09:16:21,736 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  executing total steps: 3
2016-05-18 09:16:21,736 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  allocating management threads: 3
2016-05-18 09:16:21,738 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (1/3)
2016-05-18 09:16:22,045 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463562504321_0017
2016-05-18 09:16:22,045 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0017/
2016-05-18 09:16:46,582 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000002 is : 143
2016-05-18 09:16:46,729 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000003 is : 143
2016-05-18 09:16:46,872 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000006 is : 143
2016-05-18 09:16:47,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000005 is : 143
2016-05-18 09:16:47,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000004 is : 143
2016-05-18 09:16:53,637 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0017_01_000007 is : 143
2016-05-18 09:16:54,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/lhs
2016-05-18 09:16:54,781 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/rhs
2016-05-18 09:16:54,961 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463562504321_0019
2016-05-18 09:16:54,961 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0019/
2016-05-18 09:16:55,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463562504321_0018
2016-05-18 09:16:55,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0018/
2016-05-18 09:17:13,072 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0018_01_000002 is : 143
2016-05-18 09:17:32,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0019_01_000002 is : 143
2016-05-18 09:17:33,249 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2016-05-18 09:17:33,250 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2016-05-18 09:17:33,252 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  completed in: 01:11.511, using cpu time: 00:09.080
2016-05-18 09:17:33,315 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2016-05-18 09:17:33,320 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2016-05-18 09:17:33,345 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:17:33,345 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:17:33,421 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 09:17:33,425 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:17:33,425 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:17:33,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:17:33,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:17:33,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:17:33,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:17:33,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:17:33,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2016-05-18 09:17:33,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 09:17:33,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 2
2016-05-18 09:17:33,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 2
2016-05-18 09:17:33,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 09:17:33,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0020
2016-05-18 09:17:33,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0020/
2016-05-18 09:17:59,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000002 is : 143
2016-05-18 09:17:59,126 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000003 is : 143
2016-05-18 09:17:59,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000004 is : 143
2016-05-18 09:17:59,402 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000006 is : 143
2016-05-18 09:17:59,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0020_01_000005 is : 143
2016-05-18 09:18:00,754 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2016-05-18 09:18:01,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0021
2016-05-18 09:18:01,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0021/
2016-05-18 09:18:26,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000003 is : 143
2016-05-18 09:18:26,524 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000005 is : 143
2016-05-18 09:18:26,645 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000006 is : 143
2016-05-18 09:18:26,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000002 is : 143
2016-05-18 09:18:26,997 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000004 is : 143
2016-05-18 09:18:33,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0021_01_000007 is : 143
2016-05-18 09:18:34,581 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2016-05-18 09:18:34,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 01:01.125, using cpu time: 00:13.540
2016-05-18 09:18:34,621 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2016-05-18 09:18:34,643 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:18:34,644 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:18:34,716 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 09:18:34,716 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:18:34,717 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:18:34,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:18:34,745 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:18:34,745 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:18:34,745 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:18:34,746 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:18:34,747 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2016-05-18 09:18:34,747 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 09:18:34,747 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 2
2016-05-18 09:18:34,748 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 2
2016-05-18 09:18:34,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 09:18:35,063 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0022
2016-05-18 09:18:35,064 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0022/
2016-05-18 09:19:00,657 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000006 is : 143
2016-05-18 09:19:00,959 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000005 is : 143
2016-05-18 09:19:01,172 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000003 is : 143
2016-05-18 09:19:01,260 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000004 is : 143
2016-05-18 09:19:01,314 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0022_01_000002 is : 143
2016-05-18 09:19:02,473 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2016-05-18 09:19:02,596 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0023
2016-05-18 09:19:02,596 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0023/
2016-05-18 09:19:29,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000005 is : 143
2016-05-18 09:19:29,402 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000002 is : 143
2016-05-18 09:19:29,478 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000004 is : 143
2016-05-18 09:19:29,524 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000003 is : 143
2016-05-18 09:19:29,688 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000006 is : 143
2016-05-18 09:19:36,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0023_01_000007 is : 143
2016-05-18 09:19:37,869 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2016-05-18 09:19:37,871 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 01:03.119, using cpu time: 00:14.950
2016-05-18 09:19:37,904 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2016-05-18 09:19:37,936 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:19:37,936 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:19:37,974 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 09:19:37,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:19:37,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:19:37,987 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:19:37,987 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:19:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:19:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2016-05-18 09:19:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:19:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:19:37,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:19:37,989 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2016-05-18 09:19:38,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0024
2016-05-18 09:19:38,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0024/
2016-05-18 09:20:03,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000006 is : 143
2016-05-18 09:20:03,859 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000002 is : 143
2016-05-18 09:20:04,182 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000005 is : 143
2016-05-18 09:20:04,214 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000003 is : 143
2016-05-18 09:20:04,374 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0024_01_000004 is : 143
2016-05-18 09:20:05,567 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2016-05-18 09:20:05,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:27.578, using cpu time: 00:09.020
2016-05-18 09:20:05,626 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2016-05-18 09:20:05,654 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:20:05,654 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:20:05,732 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-18 09:20:05,734 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:20:05,734 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:20:05,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting
2016-05-18 09:20:05,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:20:05,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:20:05,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 09:20:05,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2016-05-18 09:20:05,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  parallel execution of steps is enabled: true
2016-05-18 09:20:05,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  executing total steps: 2
2016-05-18 09:20:05,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  allocating management threads: 2
2016-05-18 09:20:05,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (1/2)
2016-05-18 09:20:05,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463562504321_0025
2016-05-18 09:20:05,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0025/
2016-05-18 09:20:31,015 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000003 is : 143
2016-05-18 09:20:31,439 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000002 is : 143
2016-05-18 09:20:31,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000004 is : 143
2016-05-18 09:20:37,627 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0025_01_000007 is : 143
2016-05-18 09:20:38,793 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2016-05-18 09:20:39,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463562504321_0026
2016-05-18 09:20:39,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0026/
2016-05-18 09:20:56,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0026_01_000002 is : 143
2016-05-18 09:20:57,873 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2016-05-18 09:20:57,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  completed in: 00:52.113, using cpu time: 00:08.430
2016-05-18 09:20:57,906 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2016-05-18 09:20:57,926 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:20:57,926 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:20:57,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 09:20:57,957 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:20:57,957 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:20:57,974 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 09:20:57,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:20:57,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:20:57,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross"]
2016-05-18 09:20:57,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 09:20:57,976 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 1
2016-05-18 09:20:57,976 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 1
2016-05-18 09:20:57,978 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-05-18 09:20:58,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463562504321_0027
2016-05-18 09:20:58,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0027/
2016-05-18 09:21:20,839 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000003 is : 143
2016-05-18 09:21:21,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000004 is : 143
2016-05-18 09:21:21,188 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000002 is : 143
2016-05-18 09:21:21,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0027_01_000005 is : 143
2016-05-18 09:21:22,389 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2016-05-18 09:21:22,391 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:24.413, using cpu time: 00:04.990
2016-05-18 09:21:22,442 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2016-05-18 09:21:22,467 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:21:22,467 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:21:22,499 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 09:21:22,501 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:21:22,501 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:21:22,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:21:22,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:21:22,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:21:22,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join"]
2016-05-18 09:21:22,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:21:22,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:21:22,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:21:22,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2016-05-18 09:21:22,626 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0028
2016-05-18 09:21:22,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0028/
2016-05-18 09:21:46,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000006 is : 143
2016-05-18 09:21:47,287 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000002 is : 143
2016-05-18 09:21:47,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000005 is : 143
2016-05-18 09:21:47,657 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000004 is : 143
2016-05-18 09:21:47,821 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0028_01_000003 is : 143
2016-05-18 09:21:49,007 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2016-05-18 09:21:49,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:26.494, using cpu time: 00:05.830
2016-05-18 09:21:49,052 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2016-05-18 09:21:49,081 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:21:49,082 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:21:49,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.106
2016-05-18 09:21:49,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 09:21:49,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:21:49,253 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 09:21:49,253 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:21:49,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:21:49,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:21:49,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2016-05-18 09:21:49,255 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2016-05-18 09:21:49,255 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 09:21:49,255 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 3
2016-05-18 09:21:49,255 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 3
2016-05-18 09:21:49,256 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 09:21:49,396 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0029
2016-05-18 09:21:49,396 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0029/
2016-05-18 09:22:13,736 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000002 is : 143
2016-05-18 09:22:14,079 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000003 is : 143
2016-05-18 09:22:14,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000004 is : 143
2016-05-18 09:22:14,695 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000005 is : 143
2016-05-18 09:22:14,850 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0029_01_000006 is : 143
2016-05-18 09:22:16,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/rhs
2016-05-18 09:22:16,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/lhs
2016-05-18 09:22:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0030
2016-05-18 09:22:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0030/
2016-05-18 09:22:16,194 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0031
2016-05-18 09:22:16,194 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0031/
2016-05-18 09:22:41,965 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000003 is : 143
2016-05-18 09:22:42,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000002 is : 143
2016-05-18 09:22:42,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000004 is : 143
2016-05-18 09:22:42,461 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000006 is : 143
2016-05-18 09:22:42,784 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000005 is : 143
2016-05-18 09:22:48,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0030_01_000007 is : 143
2016-05-18 09:23:12,891 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000003 is : 143
2016-05-18 09:23:13,129 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000005 is : 143
2016-05-18 09:23:13,250 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000002 is : 143
2016-05-18 09:23:13,310 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000004 is : 143
2016-05-18 09:23:19,567 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0031_01_000006 is : 143
2016-05-18 09:23:20,774 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2016-05-18 09:23:20,775 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2016-05-18 09:23:20,777 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 01:31.517, using cpu time: 00:19.620
2016-05-18 09:23:20,812 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2016-05-18 09:23:20,817 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2016-05-18 09:23:20,839 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:23:20,839 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:23:20,901 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-18 09:23:20,903 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:23:20,903 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:23:20,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting
2016-05-18 09:23:20,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:23:20,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:23:20,924 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:23:20,924 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:23:20,924 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2016-05-18 09:23:20,924 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  parallel execution of steps is enabled: true
2016-05-18 09:23:20,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  executing total steps: 1
2016-05-18 09:23:20,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  allocating management threads: 1
2016-05-18 09:23:20,926 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2016-05-18 09:23:21,247 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] submitted hadoop job: job_1463562504321_0032
2016-05-18 09:23:21,247 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0032/
2016-05-18 09:23:47,682 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000002 is : 143
2016-05-18 09:23:48,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000003 is : 143
2016-05-18 09:23:48,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000006 is : 143
2016-05-18 09:23:48,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000004 is : 143
2016-05-18 09:23:48,802 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000005 is : 143
2016-05-18 09:23:48,938 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000007 is : 143
2016-05-18 09:23:54,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0032_01_000008 is : 143
2016-05-18 09:23:56,100 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2016-05-18 09:23:56,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  completed in: 00:35.175, using cpu time: 00:08.720
2016-05-18 09:23:56,145 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2016-05-18 09:23:56,164 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:23:56,165 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:23:56,195 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 09:23:56,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:23:56,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:23:56,208 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:23:56,208 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:23:56,208 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:23:56,208 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2016-05-18 09:23:56,209 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:23:56,209 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:23:56,209 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:23:56,210 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2016-05-18 09:23:56,315 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0033
2016-05-18 09:23:56,315 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0033/
2016-05-18 09:24:21,459 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000006 is : 143
2016-05-18 09:24:21,477 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000003 is : 143
2016-05-18 09:24:21,601 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000004 is : 143
2016-05-18 09:24:21,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000002 is : 143
2016-05-18 09:24:21,836 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0033_01_000005 is : 143
2016-05-18 09:24:23,017 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2016-05-18 09:24:23,020 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:26.807, using cpu time: 00:05.910
2016-05-18 09:24:23,075 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2016-05-18 09:24:23,102 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:24:23,102 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:24:23,139 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 09:24:23,140 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:24:23,140 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:24:23,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 09:24:23,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:24:23,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:24:23,153 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:24:23,153 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2016-05-18 09:24:23,153 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 09:24:23,154 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  executing total steps: 1
2016-05-18 09:24:23,154 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  allocating management threads: 1
2016-05-18 09:24:23,155 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2016-05-18 09:24:23,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0034
2016-05-18 09:24:23,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0034/
2016-05-18 09:24:48,425 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000003 is : 143
2016-05-18 09:24:48,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000005 is : 143
2016-05-18 09:24:48,932 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000004 is : 143
2016-05-18 09:24:49,013 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000002 is : 143
2016-05-18 09:24:49,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0034_01_000006 is : 143
2016-05-18 09:24:50,511 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2016-05-18 09:24:50,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  completed in: 00:27.354, using cpu time: 00:06.100
2016-05-18 09:24:50,557 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2016-05-18 09:24:50,597 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:24:50,598 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:24:50,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 09:24:50,628 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:24:50,628 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:24:50,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:24:50,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:24:50,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:24:50,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone"]
2016-05-18 09:24:50,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:24:50,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:24:50,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:24:50,640 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-05-18 09:24:50,749 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0035
2016-05-18 09:24:50,749 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0035/
2016-05-18 09:25:15,438 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000005 is : 143
2016-05-18 09:25:15,600 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000003 is : 143
2016-05-18 09:25:15,647 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000004 is : 143
2016-05-18 09:25:15,894 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000002 is : 143
2016-05-18 09:25:15,984 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0035_01_000006 is : 143
2016-05-18 09:25:17,180 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-05-18 09:25:17,182 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:26.539, using cpu time: 00:05.880
2016-05-18 09:25:17,228 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2016-05-18 09:25:17,252 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:25:17,252 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:25:17,293 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 09:25:17,293 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:25:17,293 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:25:17,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:25:17,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:25:17,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:25:17,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself"]
2016-05-18 09:25:17,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:25:17,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 09:25:17,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 09:25:17,314 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 09:25:17,620 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0036
2016-05-18 09:25:17,621 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0036/
2016-05-18 09:25:42,402 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000002 is : 143
2016-05-18 09:25:42,554 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000005 is : 143
2016-05-18 09:25:42,655 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000004 is : 143
2016-05-18 09:25:43,177 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000003 is : 143
2016-05-18 09:25:43,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0036_01_000006 is : 143
2016-05-18 09:25:44,449 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2016-05-18 09:25:44,554 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0037
2016-05-18 09:25:44,555 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0037/
2016-05-18 09:26:10,205 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000003 is : 143
2016-05-18 09:26:10,289 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000006 is : 143
2016-05-18 09:26:10,532 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000004 is : 143
2016-05-18 09:26:10,670 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000002 is : 143
2016-05-18 09:26:11,266 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0037_01_000005 is : 143
2016-05-18 09:26:12,457 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2016-05-18 09:26:12,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:55.143, using cpu time: 00:11.820
2016-05-18 09:26:12,504 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2016-05-18 09:26:12,530 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:26:12,531 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:26:12,630 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.096
2016-05-18 09:26:12,632 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 8
2016-05-18 09:26:12,632 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:26:12,708 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting
2016-05-18 09:26:12,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:26:12,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink"]
2016-05-18 09:26:12,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2"]
2016-05-18 09:26:12,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  parallel execution of steps is enabled: true
2016-05-18 09:26:12,710 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  executing total steps: 5
2016-05-18 09:26:12,710 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  allocating management threads: 5
2016-05-18 09:26:12,711 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (1/5)
2016-05-18 09:26:12,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (2/5)
2016-05-18 09:26:12,960 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0038
2016-05-18 09:26:12,961 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0038/
2016-05-18 09:26:12,993 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0039
2016-05-18 09:26:12,993 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0039/
2016-05-18 09:26:17,656 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463562504321_0037_01_000001
2016-05-18 09:26:37,860 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000003 is : 143
2016-05-18 09:26:37,927 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000002 is : 143
2016-05-18 09:26:38,283 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000004 is : 143
2016-05-18 09:26:38,455 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000005 is : 143
2016-05-18 09:26:38,484 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000006 is : 143
2016-05-18 09:26:45,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0038_01_000007 is : 143
2016-05-18 09:26:46,322 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (3/5)
2016-05-18 09:26:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0040
2016-05-18 09:26:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0040/
2016-05-18 09:27:12,918 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000002 is : 143
2016-05-18 09:27:13,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000004 is : 143
2016-05-18 09:27:13,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000005 is : 143
2016-05-18 09:27:13,620 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000006 is : 143
2016-05-18 09:27:20,009 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0039_01_000007 is : 143
2016-05-18 09:27:21,147 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (4/5) ...undSplitGroupByJoin/sink2
2016-05-18 09:27:21,257 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0041
2016-05-18 09:27:21,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0041/
2016-05-18 09:27:39,220 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0040_01_000002 is : 143
2016-05-18 09:27:46,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0040_01_000003 is : 143
2016-05-18 09:27:47,204 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (5/5) ...oundSplitGroupByJoin/sink
2016-05-18 09:27:47,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463562504321_0042
2016-05-18 09:27:47,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0042/
2016-05-18 09:28:04,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0041_01_000002 is : 143
2016-05-18 09:28:23,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0042_01_000002 is : 143
2016-05-18 09:28:25,177 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2/_temporary
2016-05-18 09:28:25,178 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink/_temporary
2016-05-18 09:28:25,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  completed in: 02:12.459, using cpu time: 00:17.760
2016-05-18 09:28:25,216 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2
2016-05-18 09:28:25,220 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink
2016-05-18 09:28:25,240 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:28:25,240 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:28:25,298 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-05-18 09:28:25,299 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 09:28:25,300 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:28:25,330 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 09:28:25,330 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:28:25,330 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:28:25,330 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:28:25,330 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2016-05-18 09:28:25,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2016-05-18 09:28:25,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 09:28:25,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 3
2016-05-18 09:28:25,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 3
2016-05-18 09:28:25,334 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 09:28:25,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0043
2016-05-18 09:28:25,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0043/
2016-05-18 09:28:47,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000002 is : 143
2016-05-18 09:28:48,330 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000004 is : 143
2016-05-18 09:28:48,376 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000005 is : 143
2016-05-18 09:28:49,030 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0043_01_000003 is : 143
2016-05-18 09:28:50,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/lhs
2016-05-18 09:28:50,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/rhs
2016-05-18 09:28:50,344 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0045
2016-05-18 09:28:50,344 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0045/
2016-05-18 09:28:50,527 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0044
2016-05-18 09:28:50,527 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0044/
2016-05-18 09:29:13,424 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0044_01_000002 is : 143
2016-05-18 09:29:13,898 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0044_01_000005 is : 143
2016-05-18 09:29:14,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0044_01_000004 is : 143
2016-05-18 09:29:38,258 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000003 is : 143
2016-05-18 09:29:38,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000005 is : 143
2016-05-18 09:29:38,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000004 is : 143
2016-05-18 09:29:38,879 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0045_01_000002 is : 143
2016-05-18 09:29:40,082 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2016-05-18 09:29:40,083 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2016-05-18 09:29:40,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 01:14.749, using cpu time: 00:15.320
2016-05-18 09:29:40,132 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2016-05-18 09:29:40,143 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2016-05-18 09:29:40,171 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:29:40,171 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:29:40,217 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 09:29:40,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:29:40,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:29:40,238 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting
2016-05-18 09:29:40,238 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:29:40,239 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:29:40,239 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:29:40,240 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2016-05-18 09:29:40,241 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  parallel execution of steps is enabled: true
2016-05-18 09:29:40,241 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  executing total steps: 2
2016-05-18 09:29:40,241 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  allocating management threads: 2
2016-05-18 09:29:40,242 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (1/2)
2016-05-18 09:29:40,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463562504321_0046
2016-05-18 09:29:40,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0046/
2016-05-18 09:30:06,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000004 is : 143
2016-05-18 09:30:06,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000002 is : 143
2016-05-18 09:30:06,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000003 is : 143
2016-05-18 09:30:06,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000006 is : 143
2016-05-18 09:30:07,116 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0046_01_000005 is : 143
2016-05-18 09:30:08,275 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2016-05-18 09:30:08,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463562504321_0047
2016-05-18 09:30:08,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0047/
2016-05-18 09:30:32,230 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000002 is : 143
2016-05-18 09:30:33,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000005 is : 143
2016-05-18 09:30:33,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000004 is : 143
2016-05-18 09:30:33,461 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000006 is : 143
2016-05-18 09:30:33,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0047_01_000003 is : 143
2016-05-18 09:30:34,931 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2016-05-18 09:30:34,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  completed in: 00:54.690, using cpu time: 00:12.330
2016-05-18 09:30:34,977 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2016-05-18 09:30:35,003 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:30:35,003 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:30:35,079 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 09:30:35,081 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 09:30:35,081 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:30:35,132 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting
2016-05-18 09:30:35,133 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:30:35,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:30:35,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join"]
2016-05-18 09:30:35,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  parallel execution of steps is enabled: true
2016-05-18 09:30:35,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  executing total steps: 4
2016-05-18 09:30:35,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  allocating management threads: 4
2016-05-18 09:30:35,139 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (1/4)
2016-05-18 09:30:35,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (2/4)
2016-05-18 09:30:35,475 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0048
2016-05-18 09:30:35,475 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0048/
2016-05-18 09:30:35,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0049
2016-05-18 09:30:35,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0049/
2016-05-18 09:31:00,419 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000002 is : 143
2016-05-18 09:31:00,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000006 is : 143
2016-05-18 09:31:00,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000003 is : 143
2016-05-18 09:31:01,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000005 is : 143
2016-05-18 09:31:01,205 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000004 is : 143
2016-05-18 09:31:07,043 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0048_01_000007 is : 143
2016-05-18 09:31:34,982 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000006 is : 143
2016-05-18 09:31:35,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000004 is : 143
2016-05-18 09:31:35,381 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000002 is : 143
2016-05-18 09:31:35,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000005 is : 143
2016-05-18 09:31:41,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0049_01_000007 is : 143
2016-05-18 09:31:42,885 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (3/4)
2016-05-18 09:31:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0050
2016-05-18 09:31:43,019 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0050/
2016-05-18 09:32:02,109 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0050_01_000002 is : 143
2016-05-18 09:32:02,418 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0050_01_000003 is : 143
2016-05-18 09:32:08,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0050_01_000004 is : 143
2016-05-18 09:32:09,780 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (4/4) ...kCoGroupThenHashJoin/join
2016-05-18 09:32:09,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463562504321_0051
2016-05-18 09:32:09,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0051/
2016-05-18 09:32:35,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000002 is : 143
2016-05-18 09:32:35,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000003 is : 143
2016-05-18 09:32:35,803 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000006 is : 143
2016-05-18 09:32:36,235 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000004 is : 143
2016-05-18 09:32:36,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0051_01_000005 is : 143
2016-05-18 09:32:37,453 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join/_temporary
2016-05-18 09:32:37,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  completed in: 02:02.316, using cpu time: 00:30.950
2016-05-18 09:32:37,507 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join
2016-05-18 09:32:37,531 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:32:37,531 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:32:37,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 09:32:37,567 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:32:37,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:32:37,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:32:37,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:32:37,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join"]
2016-05-18 09:32:37,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:32:37,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 09:32:37,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 09:32:37,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 09:32:37,685 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0052
2016-05-18 09:32:37,685 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0052/
2016-05-18 09:33:03,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000004 is : 143
2016-05-18 09:33:04,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000002 is : 143
2016-05-18 09:33:04,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000003 is : 143
2016-05-18 09:33:04,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000005 is : 143
2016-05-18 09:33:04,629 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0052_01_000006 is : 143
2016-05-18 09:33:05,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testForkThenJoin/join
2016-05-18 09:33:05,885 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0053
2016-05-18 09:33:05,885 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0053/
2016-05-18 09:33:30,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000006 is : 143
2016-05-18 09:33:31,501 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000002 is : 143
2016-05-18 09:33:31,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000003 is : 143
2016-05-18 09:33:31,753 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000004 is : 143
2016-05-18 09:33:32,116 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0053_01_000005 is : 143
2016-05-18 09:33:33,301 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join/_temporary
2016-05-18 09:33:33,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:55.714, using cpu time: 00:15.830
2016-05-18 09:33:33,345 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join
2016-05-18 09:33:33,371 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:33:33,371 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:33:33,416 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 09:33:33,418 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:33:33,418 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:33:33,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:33:33,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:33:33,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:33:33,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2016-05-18 09:33:33,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:33:33,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 09:33:33,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 09:33:33,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 09:33:33,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0054
2016-05-18 09:33:33,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0054/
2016-05-18 09:33:38,451 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1080)) - Event EventType: KILL_CONTAINER sent to absent container container_1463562504321_0053_01_000001
2016-05-18 09:33:57,998 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000006 is : 143
2016-05-18 09:33:58,314 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000004 is : 143
2016-05-18 09:33:58,671 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000002 is : 143
2016-05-18 09:33:58,895 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000003 is : 143
2016-05-18 09:33:59,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000005 is : 143
2016-05-18 09:34:05,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0054_01_000007 is : 143
2016-05-18 09:34:06,239 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2016-05-18 09:34:06,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0055
2016-05-18 09:34:06,363 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0055/
2016-05-18 09:34:31,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000003 is : 143
2016-05-18 09:34:31,802 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000002 is : 143
2016-05-18 09:34:32,171 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000006 is : 143
2016-05-18 09:34:32,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000005 is : 143
2016-05-18 09:34:32,431 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0055_01_000004 is : 143
2016-05-18 09:34:33,664 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2016-05-18 09:34:33,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 01:00.223, using cpu time: 00:12.940
2016-05-18 09:34:33,709 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2016-05-18 09:34:33,733 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:34:33,734 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:34:33,808 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2016-05-18 09:34:33,809 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 09:34:33,810 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:34:33,841 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 09:34:33,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:34:33,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:34:33,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:34:33,843 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2016-05-18 09:34:33,844 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 09:34:33,844 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  executing total steps: 3
2016-05-18 09:34:33,845 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  allocating management threads: 3
2016-05-18 09:34:33,848 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/3)
2016-05-18 09:34:33,985 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0056
2016-05-18 09:34:33,985 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0056/
2016-05-18 09:34:58,449 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000002 is : 143
2016-05-18 09:34:58,871 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000003 is : 143
2016-05-18 09:34:58,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000006 is : 143
2016-05-18 09:34:59,332 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000005 is : 143
2016-05-18 09:34:59,609 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0056_01_000004 is : 143
2016-05-18 09:35:00,760 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (2/3)
2016-05-18 09:35:00,880 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0057
2016-05-18 09:35:00,881 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0057/
2016-05-18 09:35:26,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000002 is : 143
2016-05-18 09:35:26,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000006 is : 143
2016-05-18 09:35:27,009 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000003 is : 143
2016-05-18 09:35:27,284 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000004 is : 143
2016-05-18 09:35:27,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0057_01_000005 is : 143
2016-05-18 09:35:28,662 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2016-05-18 09:35:28,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463562504321_0058
2016-05-18 09:35:28,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0058/
2016-05-18 09:35:54,217 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000002 is : 143
2016-05-18 09:35:54,871 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000006 is : 143
2016-05-18 09:35:55,078 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000004 is : 143
2016-05-18 09:35:55,249 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0058_01_000005 is : 143
2016-05-18 09:35:56,445 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2016-05-18 09:35:56,447 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  completed in: 01:22.596, using cpu time: 00:18.540
2016-05-18 09:35:56,491 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2016-05-18 09:35:56,519 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:35:56,519 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:35:56,575 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 09:35:56,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:35:56,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:35:56,598 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 09:35:56,598 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:35:56,598 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:35:56,598 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:35:56,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:35:56,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2016-05-18 09:35:56,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 09:35:56,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 1
2016-05-18 09:35:56,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 1
2016-05-18 09:35:56,600 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2016-05-18 09:35:56,716 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463562504321_0059
2016-05-18 09:35:56,717 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0059/
2016-05-18 09:36:24,131 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000002 is : 143
2016-05-18 09:36:24,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000007 is : 143
2016-05-18 09:36:24,851 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000005 is : 143
2016-05-18 09:36:25,051 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000003 is : 143
2016-05-18 09:36:25,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000004 is : 143
2016-05-18 09:36:25,250 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000006 is : 143
2016-05-18 09:36:30,424 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0059_01_000008 is : 143
2016-05-18 09:36:31,632 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2016-05-18 09:36:31,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:35.031, using cpu time: 00:08.780
2016-05-18 09:36:31,666 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2016-05-18 09:36:31,711 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:36:31,711 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:36:31,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 09:36:31,737 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:36:31,737 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:36:31,752 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:36:31,753 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 09:36:31,753 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 09:36:31,753 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner"]
2016-05-18 09:36:31,753 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:36:31,753 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:36:31,754 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:36:31,754 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2016-05-18 09:36:31,870 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0060
2016-05-18 09:36:31,870 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0060/
2016-05-18 09:36:57,203 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000003 is : 143
2016-05-18 09:36:57,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000006 is : 143
2016-05-18 09:36:57,578 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000002 is : 143
2016-05-18 09:36:57,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000004 is : 143
2016-05-18 09:36:57,972 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0060_01_000005 is : 143
2016-05-18 09:36:59,152 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2016-05-18 09:36:59,154 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:27.398, using cpu time: 00:05.870
2016-05-18 09:36:59,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2016-05-18 09:36:59,222 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:36:59,222 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:36:59,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 09:36:59,272 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 09:36:59,273 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:36:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 09:36:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs.txt"]
2016-05-18 09:36:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs.txt"]
2016-05-18 09:36:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2016-05-18 09:36:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2016-05-18 09:36:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 09:36:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 2
2016-05-18 09:36:59,293 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 2
2016-05-18 09:36:59,297 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/2) ...latform/testJoinSplit/rhs
2016-05-18 09:36:59,297 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/2) ...latform/testJoinSplit/lhs
2016-05-18 09:36:59,457 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0062
2016-05-18 09:36:59,457 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0062/
2016-05-18 09:36:59,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463562504321_0061
2016-05-18 09:36:59,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0061/
2016-05-18 09:37:22,932 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0061_01_000004 is : 143
2016-05-18 09:37:22,980 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0061_01_000003 is : 143
2016-05-18 09:37:23,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0061_01_000002 is : 143
2016-05-18 09:37:47,619 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000004 is : 143
2016-05-18 09:37:47,850 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000002 is : 143
2016-05-18 09:37:47,999 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000005 is : 143
2016-05-18 09:37:48,093 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0062_01_000003 is : 143
2016-05-18 09:37:49,276 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2016-05-18 09:37:49,278 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2016-05-18 09:37:49,284 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:49.981, using cpu time: 00:09.910
2016-05-18 09:37:49,347 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2016-05-18 09:37:49,357 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2016-05-18 09:37:49,383 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:37:49,384 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:37:49,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-18 09:37:49,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 09:37:49,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:37:49,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 09:37:49,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:37:49,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2016-05-18 09:37:49,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 09:37:49,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 2
2016-05-18 09:37:49,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 2
2016-05-18 09:37:49,460 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/2)
2016-05-18 09:37:49,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463562504321_0063
2016-05-18 09:37:49,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0063/
2016-05-18 09:38:13,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000006 is : 143
2016-05-18 09:38:14,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000002 is : 143
2016-05-18 09:38:14,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000005 is : 143
2016-05-18 09:38:14,527 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000004 is : 143
2016-05-18 09:38:14,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000003 is : 143
2016-05-18 09:38:19,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0063_01_000007 is : 143
2016-05-18 09:38:20,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2016-05-18 09:38:20,878 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463562504321_0064
2016-05-18 09:38:20,878 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0064/
2016-05-18 09:38:45,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000002 is : 143
2016-05-18 09:38:45,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000006 is : 143
2016-05-18 09:38:45,927 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000003 is : 143
2016-05-18 09:38:46,178 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000005 is : 143
2016-05-18 09:38:46,785 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0064_01_000004 is : 143
2016-05-18 09:38:47,983 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2016-05-18 09:38:47,985 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:58.522, using cpu time: 00:13.160
2016-05-18 09:38:48,027 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2016-05-18 09:38:48,053 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:38:48,053 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:38:48,129 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2016-05-18 09:38:48,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 09:38:48,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:38:48,158 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 09:38:48,158 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:38:48,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:38:48,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2016-05-18 09:38:48,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 09:38:48,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  executing total steps: 3
2016-05-18 09:38:48,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  allocating management threads: 3
2016-05-18 09:38:48,161 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/3)
2016-05-18 09:38:48,161 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/3)
2016-05-18 09:38:48,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0066
2016-05-18 09:38:48,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0066/
2016-05-18 09:38:48,527 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0065
2016-05-18 09:38:48,527 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0065/
2016-05-18 09:39:13,527 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000002 is : 143
2016-05-18 09:39:13,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000003 is : 143
2016-05-18 09:39:14,065 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000005 is : 143
2016-05-18 09:39:14,110 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000006 is : 143
2016-05-18 09:39:14,299 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000004 is : 143
2016-05-18 09:39:20,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0065_01_000007 is : 143
2016-05-18 09:39:46,465 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000003 is : 143
2016-05-18 09:39:46,589 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000002 is : 143
2016-05-18 09:39:46,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000006 is : 143
2016-05-18 09:39:46,986 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000004 is : 143
2016-05-18 09:39:47,185 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000005 is : 143
2016-05-18 09:39:52,806 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0066_01_000007 is : 143
2016-05-18 09:39:54,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2016-05-18 09:39:54,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463562504321_0067
2016-05-18 09:39:54,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0067/
2016-05-18 09:40:11,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0067_01_000002 is : 143
2016-05-18 09:40:12,953 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2016-05-18 09:40:12,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  completed in: 01:24.791, using cpu time: 00:15.470
2016-05-18 09:40:12,987 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2016-05-18 09:40:13,028 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:40:13,028 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:40:13,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.034
2016-05-18 09:40:13,067 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 09:40:13,067 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2016-05-18 09:40:13,082 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:40:13,082 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:40:13,103 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 09:40:13,104 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:40:13,104 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:40:13,118 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 09:40:13,118 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:40:13,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2016-05-18 09:40:13,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  parallel execution of steps is enabled: true
2016-05-18 09:40:13,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  executing total steps: 1
2016-05-18 09:40:13,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  allocating management threads: 1
2016-05-18 09:40:13,121 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2016-05-18 09:40:13,224 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463562504321_0068
2016-05-18 09:40:13,224 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0068/
2016-05-18 09:40:38,252 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000005 is : 143
2016-05-18 09:40:38,353 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000003 is : 143
2016-05-18 09:40:38,580 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000006 is : 143
2016-05-18 09:40:38,635 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000004 is : 143
2016-05-18 09:40:38,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0068_01_000002 is : 143
2016-05-18 09:40:40,143 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2016-05-18 09:40:40,146 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  completed in: 00:27.023, using cpu time: 00:05.460
2016-05-18 09:40:40,190 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2016-05-18 09:40:40,225 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:40:40,225 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:40:40,245 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 09:40:40,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:40:40,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:40:40,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting
2016-05-18 09:40:40,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:40:40,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2016-05-18 09:40:40,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  parallel execution of steps is enabled: true
2016-05-18 09:40:40,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  executing total steps: 1
2016-05-18 09:40:40,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  allocating management threads: 1
2016-05-18 09:40:40,255 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2016-05-18 09:40:40,354 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] submitted hadoop job: job_1463562504321_0069
2016-05-18 09:40:40,354 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0069/
2016-05-18 09:41:04,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000005 is : 143
2016-05-18 09:41:05,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000003 is : 143
2016-05-18 09:41:05,334 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000002 is : 143
2016-05-18 09:41:05,493 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000006 is : 143
2016-05-18 09:41:05,946 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0069_01_000004 is : 143
2016-05-18 09:41:07,122 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2016-05-18 09:41:07,124 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  completed in: 00:26.866, using cpu time: 00:05.250
2016-05-18 09:41:07,180 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2016-05-18 09:41:07,205 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:41:07,205 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:41:07,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 09:41:07,237 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 09:41:07,237 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:41:07,251 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:41:07,252 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2016-05-18 09:41:07,360 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0070
2016-05-18 09:41:07,360 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0070/
2016-05-18 09:41:31,401 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000002 is : 143
2016-05-18 09:41:31,795 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000003 is : 143
2016-05-18 09:41:32,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000006 is : 143
2016-05-18 09:41:32,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000004 is : 143
2016-05-18 09:41:32,538 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000005 is : 143
2016-05-18 09:41:38,447 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0070_01_000007 is : 143
2016-05-18 09:41:39,698 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2016-05-18 09:41:39,700 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:32.445, using cpu time: 00:07.380
2016-05-18 09:41:39,733 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2016-05-18 09:41:39,752 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:41:39,753 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:41:39,819 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-18 09:41:39,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 6
2016-05-18 09:41:39,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:41:39,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting
2016-05-18 09:41:39,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:41:39,859 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink"]
2016-05-18 09:41:39,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  parallel execution of steps is enabled: true
2016-05-18 09:41:39,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  executing total steps: 4
2016-05-18 09:41:39,860 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  allocating management threads: 4
2016-05-18 09:41:39,862 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (1/4)
2016-05-18 09:41:39,976 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0071
2016-05-18 09:41:39,976 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0071/
2016-05-18 09:42:05,477 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000006 is : 143
2016-05-18 09:42:05,499 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000004 is : 143
2016-05-18 09:42:05,695 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000003 is : 143
2016-05-18 09:42:05,861 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000005 is : 143
2016-05-18 09:42:05,964 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000002 is : 143
2016-05-18 09:42:12,770 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0071_01_000007 is : 143
2016-05-18 09:42:13,910 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (2/4)
2016-05-18 09:42:14,215 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0072
2016-05-18 09:42:14,216 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0072/
2016-05-18 09:42:32,172 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0072_01_000002 is : 143
2016-05-18 09:42:33,354 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (3/4)
2016-05-18 09:42:33,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0073
2016-05-18 09:42:33,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0073/
2016-05-18 09:42:51,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0073_01_000002 is : 143
2016-05-18 09:42:57,938 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0073_01_000003 is : 143
2016-05-18 09:42:59,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (4/4) ...plitSplitGroupByJoin/sink
2016-05-18 09:42:59,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463562504321_0074
2016-05-18 09:42:59,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0074/
2016-05-18 09:43:16,461 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0074_01_000002 is : 143
2016-05-18 09:43:17,683 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink/_temporary
2016-05-18 09:43:17,687 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  completed in: 01:37.819, using cpu time: 00:10.940
2016-05-18 09:43:17,717 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink
2016-05-18 09:43:17,734 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:43:17,735 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:43:17,755 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 09:43:17,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:43:17,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:43:17,764 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 09:43:17,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:43:17,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2016-05-18 09:43:17,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  parallel execution of steps is enabled: true
2016-05-18 09:43:17,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  executing total steps: 1
2016-05-18 09:43:17,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  allocating management threads: 1
2016-05-18 09:43:17,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2016-05-18 09:43:17,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463562504321_0075
2016-05-18 09:43:17,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0075/
2016-05-18 09:43:43,814 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000004 is : 143
2016-05-18 09:43:44,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000006 is : 143
2016-05-18 09:43:44,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000005 is : 143
2016-05-18 09:43:44,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0075_01_000003 is : 143
2016-05-18 09:43:45,531 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2016-05-18 09:43:45,532 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  completed in: 00:27.764, using cpu time: 00:05.470
2016-05-18 09:43:45,586 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2016-05-18 09:43:45,611 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:43:45,612 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:43:45,684 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-05-18 09:43:45,691 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 09:43:45,691 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:43:45,732 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting
2016-05-18 09:43:45,732 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:43:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2016-05-18 09:43:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  parallel execution of steps is enabled: true
2016-05-18 09:43:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  executing total steps: 4
2016-05-18 09:43:45,733 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  allocating management threads: 4
2016-05-18 09:43:45,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (1/4)
2016-05-18 09:43:46,194 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0076
2016-05-18 09:43:46,194 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0076/
2016-05-18 09:44:11,000 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000006 is : 143
2016-05-18 09:44:11,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000003 is : 143
2016-05-18 09:44:11,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000002 is : 143
2016-05-18 09:44:11,768 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000004 is : 143
2016-05-18 09:44:12,080 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000005 is : 143
2016-05-18 09:44:17,895 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0076_01_000007 is : 143
2016-05-18 09:44:19,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (2/4)
2016-05-18 09:44:19,383 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0077
2016-05-18 09:44:19,383 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0077/
2016-05-18 09:44:36,622 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0077_01_000002 is : 143
2016-05-18 09:44:43,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0077_01_000003 is : 143
2016-05-18 09:44:44,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (3/4)
2016-05-18 09:44:44,879 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0078
2016-05-18 09:44:44,879 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0078/
2016-05-18 09:45:02,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0078_01_000002 is : 143
2016-05-18 09:45:10,035 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0078_01_000003 is : 143
2016-05-18 09:45:11,176 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2016-05-18 09:45:11,290 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463562504321_0079
2016-05-18 09:45:11,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0079/
2016-05-18 09:45:28,506 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0079_01_000002 is : 143
2016-05-18 09:45:29,724 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2016-05-18 09:45:29,726 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  completed in: 01:43.987, using cpu time: 00:12.390
2016-05-18 09:45:29,766 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2016-05-18 09:45:29,786 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:45:29,786 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:45:29,811 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 09:45:29,812 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:45:29,812 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:45:29,823 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:45:29,823 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 09:45:29,823 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 09:45:29,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3 | String, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2016-05-18 09:45:29,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:45:29,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:45:29,825 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:45:29,825 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2016-05-18 09:45:29,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0080
2016-05-18 09:45:29,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0080/
2016-05-18 09:45:54,831 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000002 is : 143
2016-05-18 09:45:54,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000003 is : 143
2016-05-18 09:45:55,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000005 is : 143
2016-05-18 09:45:55,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000004 is : 143
2016-05-18 09:45:55,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0080_01_000006 is : 143
2016-05-18 09:45:56,864 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2016-05-18 09:45:56,866 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:27.039, using cpu time: 00:05.990
2016-05-18 09:45:56,921 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2016-05-18 09:45:56,947 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 09:45:56,947 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 09:45:56,973 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 09:45:56,977 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 09:45:56,978 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 09:45:56,990 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 09:45:56,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/upper.txt"]
2016-05-18 09:45:56,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/lower.txt"]
2016-05-18 09:45:56,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2016-05-18 09:45:56,992 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 09:45:56,992 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 09:45:56,993 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 09:45:56,994 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2016-05-18 09:45:57,104 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463562504321_0081
2016-05-18 09:45:57,104 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:47674/proxy/application_1463562504321_0081/
2016-05-18 09:46:22,252 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000003 is : 143
2016-05-18 09:46:22,762 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000004 is : 143
2016-05-18 09:46:22,826 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000005 is : 143
2016-05-18 09:46:23,095 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463562504321_0081_01_000002 is : 143
2016-05-18 09:46:24,276 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2016-05-18 09:46:24,277 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:27.284, using cpu time: 00:05.810
2016-05-18 09:46:24,320 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields

Standard error

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