Class cascading.JoinFieldedPipesPlatformTest

44

tests

0

failures

0

ignored

27m27.32s

duration

100%

successful

Tests

Test Duration Result
testCross 18.279s passed
testForkCoGroupThenHashJoin 1m26.76s passed
testForkCoGroupThenHashJoinCoGroupAgain 2m10.57s passed
testForkThenJoin 41.725s passed
testGroupBySplitAroundSplitGroupByJoin 1m20.64s passed
testGroupBySplitGroupByJoin 1m13.33s passed
testGroupBySplitJoins 44.044s passed
testGroupBySplitSplitGroupByJoin 1m7.78s passed
testJoin 20.740s passed
testJoinAfterEvery 56.278s passed
testJoinAroundJoinLeftMost 41.355s passed
testJoinAroundJoinRightMost 20.545s passed
testJoinAroundJoinRightMostSwapped 41.314s passed
testJoinDiffFields 20.990s passed
testJoinFilteredBranch 46.153s passed
testJoinGroupBy 25.133s passed
testJoinGroupByJoin 36.926s passed
testJoinInner 20.111s passed
testJoinInnerOuter 20.854s passed
testJoinInnerSingleField 44.426s passed
testJoinMergeGroupBy 0.074s passed
testJoinMixed 0s passed
testJoinNone 20.908s passed
testJoinOuter 0s passed
testJoinOuterInner 0s passed
testJoinSamePipe 20.119s passed
testJoinSamePipe2 20.025s passed
testJoinSamePipe3 20.252s passed
testJoinSamePipeAroundGroupBy 45.358s passed
testJoinSamePipeName 21.321s passed
testJoinSameSourceIntoJoin 1m1.70s passed
testJoinSameSourceIntoJoinSimple 40.895s passed
testJoinSameSourceOverGroupByIntoJoinSimple 55.921s passed
testJoinSelf 40.587s passed
testJoinSplit 31.291s passed
testJoinSplitBeforeJoin 1m2.04s passed
testJoinWithHasher 21.215s passed
testJoinWithUnknowns 21.242s passed
testJoinsIntoCoGroup 27.526s passed
testJoinsIntoCoGroupLhs 46.831s passed
testJoinsIntoCoGroupLhsSwappedJoin 26.627s passed
testJoinsIntoCoGroupRhs 46.352s passed
testJoinsIntoGroupBy 29.355s passed
testSameSourceJoinSplitIntoJoin 49.732s passed

Standard output

2016-05-18 01:12:57,190 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 01:12:57,219 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 01:12:57,261 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 01:12:58,073 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 01:12:58,668 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 01:12:59,240 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(162)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 01:13:02,311 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 01:13:02,459 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 01:13:02,565 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 01:13:02,676 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 01:13:19,748 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 01:13:19,877 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:13:19,878 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 01:13:19,946 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 348898A743EE4B018DA1C5A8F6081085
2016-05-18 01:13:20,087 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.100
2016-05-18 01:13:20,091 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:13:20,092 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 01:13:20,227 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 01:13:20,228 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:13:20,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:13:20,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 01:13:20,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2016-05-18 01:13:20,232 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:13:20,232 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:13:20,232 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:13:20,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2016-05-18 01:13:21,090 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0001
2016-05-18 01:13:21,090 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0001/
2016-05-18 01:13:39,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0001_01_000002 is : 143
2016-05-18 01:13:39,954 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0001_01_000006 is : 143
2016-05-18 01:13:40,014 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0001_01_000004 is : 143
2016-05-18 01:13:40,213 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0001_01_000005 is : 143
2016-05-18 01:13:41,560 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2016-05-18 01:13:41,561 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:21.327, using cpu time: 00:06.430
2016-05-18 01:13:41,662 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2016-05-18 01:13:41,708 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:13:41,708 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 01:13:41,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-05-18 01:13:41,807 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 01:13:41,807 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 01:13:41,871 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 01:13:41,871 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:13:41,871 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:13:41,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2016-05-18 01:13:41,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 01:13:41,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  executing total steps: 2
2016-05-18 01:13:41,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  allocating management threads: 2
2016-05-18 01:13:41,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/2)
2016-05-18 01:13:42,083 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463533994246_0002
2016-05-18 01:13:42,083 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0002/
2016-05-18 01:13:59,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0002_01_000003 is : 143
2016-05-18 01:14:00,514 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0002_01_000004 is : 143
2016-05-18 01:14:00,829 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0002_01_000005 is : 143
2016-05-18 01:14:00,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0002_01_000006 is : 143
2016-05-18 01:14:02,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2016-05-18 01:14:02,308 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463533994246_0003
2016-05-18 01:14:02,308 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0003/
2016-05-18 01:14:20,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0003_01_000006 is : 143
2016-05-18 01:14:20,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0003_01_000003 is : 143
2016-05-18 01:14:20,450 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0003_01_000002 is : 143
2016-05-18 01:14:20,984 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0003_01_000005 is : 143
2016-05-18 01:14:21,229 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0003_01_000004 is : 143
2016-05-18 01:14:22,505 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2016-05-18 01:14:22,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  completed in: 00:40.628, using cpu time: 00:14.780
2016-05-18 01:14:22,568 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2016-05-18 01:14:22,616 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:14:22,617 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 01:14:22,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-05-18 01:14:22,708 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 01:14:22,708 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 01:14:22,738 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting
2016-05-18 01:14:22,739 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:14:22,739 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:14:22,739 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:14:22,739 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2016-05-18 01:14:22,740 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  parallel execution of steps is enabled: true
2016-05-18 01:14:22,740 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  executing total steps: 2
2016-05-18 01:14:22,741 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  allocating management threads: 2
2016-05-18 01:14:22,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (1/2)
2016-05-18 01:14:22,910 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463533994246_0004
2016-05-18 01:14:22,910 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0004/
2016-05-18 01:14:41,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0004_01_000003 is : 143
2016-05-18 01:14:41,155 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0004_01_000002 is : 143
2016-05-18 01:14:41,873 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0004_01_000004 is : 143
2016-05-18 01:14:42,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0004_01_000005 is : 143
2016-05-18 01:14:43,255 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2016-05-18 01:14:43,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463533994246_0005
2016-05-18 01:14:43,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0005/
2016-05-18 01:15:01,373 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0005_01_000003 is : 143
2016-05-18 01:15:01,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0005_01_000002 is : 143
2016-05-18 01:15:02,100 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0005_01_000006 is : 143
2016-05-18 01:15:02,538 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0005_01_000005 is : 143
2016-05-18 01:15:02,577 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0005_01_000004 is : 143
2016-05-18 01:15:03,871 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2016-05-18 01:15:03,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  completed in: 00:41.125, using cpu time: 00:14.930
2016-05-18 01:15:03,924 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2016-05-18 01:15:03,954 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:15:03,954 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 01:15:04,000 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 01:15:04,002 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:15:04,002 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 01:15:04,016 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting
2016-05-18 01:15:04,016 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:15:04,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:15:04,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2016-05-18 01:15:04,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  parallel execution of steps is enabled: true
2016-05-18 01:15:04,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  executing total steps: 1
2016-05-18 01:15:04,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  allocating management threads: 1
2016-05-18 01:15:04,018 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-05-18 01:15:04,095 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(309)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-05-18 01:15:04,162 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] submitted hadoop job: job_1463533994246_0006
2016-05-18 01:15:04,162 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0006/
2016-05-18 01:15:22,127 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0006_01_000006 is : 143
2016-05-18 01:15:22,453 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0006_01_000005 is : 143
2016-05-18 01:15:22,709 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0006_01_000003 is : 143
2016-05-18 01:15:22,793 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0006_01_000002 is : 143
2016-05-18 01:15:23,941 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0006_01_000004 is : 143
2016-05-18 01:15:25,190 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2016-05-18 01:15:25,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  completed in: 00:21.172, using cpu time: 00:07.380
2016-05-18 01:15:25,246 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2016-05-18 01:15:25,280 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:15:25,280 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 01:15:25,392 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.103
2016-05-18 01:15:25,394 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 01:15:25,395 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 01:15:25,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:15:25,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:15:25,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:15:25,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2016-05-18 01:15:25,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:15:25,442 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 3
2016-05-18 01:15:25,442 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 3
2016-05-18 01:15:25,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 01:15:25,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 01:15:25,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0007
2016-05-18 01:15:25,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0007/
2016-05-18 01:15:25,647 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0008
2016-05-18 01:15:25,648 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0008/
2016-05-18 01:15:45,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0007_01_000004 is : 143
2016-05-18 01:15:46,422 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0007_01_000005 is : 143
2016-05-18 01:15:47,020 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0007_01_000003 is : 143
2016-05-18 01:15:47,879 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0007_01_000002 is : 143
2016-05-18 01:15:47,960 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0007_01_000006 is : 143
2016-05-18 01:16:00,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0008_01_000006 is : 143
2016-05-18 01:16:01,005 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0008_01_000002 is : 143
2016-05-18 01:16:01,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0008_01_000004 is : 143
2016-05-18 01:16:01,579 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0008_01_000005 is : 143
2016-05-18 01:16:01,762 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0008_01_000003 is : 143
2016-05-18 01:16:02,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0007_01_000007 is : 143
2016-05-18 01:16:07,757 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0008_01_000007 is : 143
2016-05-18 01:16:08,941 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2016-05-18 01:16:09,147 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0009
2016-05-18 01:16:09,147 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0009/
2016-05-18 01:16:20,262 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0009_01_000002 is : 143
2016-05-18 01:16:21,499 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2016-05-18 01:16:21,501 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:56.052, using cpu time: 00:14.830
2016-05-18 01:16:21,531 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2016-05-18 01:16:21,658 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:16:21,658 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 01:16:21,915 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.252
2016-05-18 01:16:21,919 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 6, nodes: 12
2016-05-18 01:16:21,919 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 01:16:22,076 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 01:16:22,077 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:16:22,077 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:16:22,077 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join"]
2016-05-18 01:16:22,077 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 01:16:22,078 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 6
2016-05-18 01:16:22,078 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 6
2016-05-18 01:16:22,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/6)
2016-05-18 01:16:22,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/6)
2016-05-18 01:16:22,284 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0010
2016-05-18 01:16:22,284 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0010/
2016-05-18 01:16:22,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0011
2016-05-18 01:16:22,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0011/
2016-05-18 01:16:43,539 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0010_01_000005 is : 143
2016-05-18 01:16:43,822 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0010_01_000004 is : 143
2016-05-18 01:16:44,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0010_01_000003 is : 143
2016-05-18 01:16:45,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0010_01_000006 is : 143
2016-05-18 01:16:45,411 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0010_01_000002 is : 143
2016-05-18 01:16:59,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0011_01_000005 is : 143
2016-05-18 01:16:59,793 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0011_01_000004 is : 143
2016-05-18 01:17:00,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0011_01_000006 is : 143
2016-05-18 01:17:00,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0011_01_000003 is : 143
2016-05-18 01:17:00,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0011_01_000002 is : 143
2016-05-18 01:17:00,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0010_01_000007 is : 143
2016-05-18 01:17:06,078 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0011_01_000007 is : 143
2016-05-18 01:17:07,282 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (3/6)
2016-05-18 01:17:07,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0012
2016-05-18 01:17:07,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0012/
2016-05-18 01:17:19,720 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0012_01_000002 is : 143
2016-05-18 01:17:19,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0012_01_000003 is : 143
2016-05-18 01:17:26,215 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0012_01_000004 is : 143
2016-05-18 01:17:27,383 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (4/6)
2016-05-18 01:17:27,383 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (5/6)
2016-05-18 01:17:27,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0013
2016-05-18 01:17:27,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0013/
2016-05-18 01:17:27,591 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0014
2016-05-18 01:17:27,591 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0014/
2016-05-18 01:17:48,056 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0013_01_000006 is : 143
2016-05-18 01:17:49,352 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0013_01_000004 is : 143
2016-05-18 01:17:49,430 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0013_01_000003 is : 143
2016-05-18 01:17:49,478 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0013_01_000002 is : 143
2016-05-18 01:17:49,722 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0013_01_000005 is : 143
2016-05-18 01:18:03,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0014_01_000004 is : 143
2016-05-18 01:18:04,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0014_01_000002 is : 143
2016-05-18 01:18:04,761 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0014_01_000003 is : 143
2016-05-18 01:18:04,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0014_01_000005 is : 143
2016-05-18 01:18:05,033 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0014_01_000006 is : 143
2016-05-18 01:18:05,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0013_01_000007 is : 143
2016-05-18 01:18:09,812 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0014_01_000007 is : 143
2016-05-18 01:18:11,005 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (6/6) ...HashJoinCoGroupAgain/join
2016-05-18 01:18:11,164 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0015
2016-05-18 01:18:11,164 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0015/
2016-05-18 01:18:24,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0015_01_000002 is : 143
2016-05-18 01:18:24,256 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0015_01_000003 is : 143
2016-05-18 01:18:30,844 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0015_01_000004 is : 143
2016-05-18 01:18:32,071 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join/_temporary
2016-05-18 01:18:32,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 02:09.983, using cpu time: 00:45.760
2016-05-18 01:18:32,104 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join
2016-05-18 01:18:32,155 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:18:32,156 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 01:18:32,218 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-18 01:18:32,220 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 01:18:32,220 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 01:18:32,239 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 01:18:32,240 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:18:32,240 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:18:32,240 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:18:32,240 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:18:32,241 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2016-05-18 01:18:32,241 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 01:18:32,241 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 1
2016-05-18 01:18:32,242 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 1
2016-05-18 01:18:32,243 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2016-05-18 01:18:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0016
2016-05-18 01:18:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0016/
2016-05-18 01:18:50,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0016_01_000002 is : 143
2016-05-18 01:18:50,685 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0016_01_000005 is : 143
2016-05-18 01:18:50,776 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0016_01_000006 is : 143
2016-05-18 01:18:51,066 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0016_01_000004 is : 143
2016-05-18 01:18:57,439 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0016_01_000007 is : 143
2016-05-18 01:18:58,701 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2016-05-18 01:18:58,702 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:26.460, using cpu time: 00:07.340
2016-05-18 01:18:58,732 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2016-05-18 01:18:58,769 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:18:58,769 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 01:18:58,840 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 01:18:58,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 01:18:58,842 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 01:18:58,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting
2016-05-18 01:18:58,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:18:58,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:18:58,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 01:18:58,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2016-05-18 01:18:58,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2016-05-18 01:18:58,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  parallel execution of steps is enabled: true
2016-05-18 01:18:58,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  executing total steps: 3
2016-05-18 01:18:58,874 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  allocating management threads: 3
2016-05-18 01:18:58,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (1/3)
2016-05-18 01:18:59,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463533994246_0017
2016-05-18 01:18:59,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0017/
2016-05-18 01:19:16,312 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0017_01_000003 is : 143
2016-05-18 01:19:16,514 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0017_01_000002 is : 143
2016-05-18 01:19:16,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0017_01_000006 is : 143
2016-05-18 01:19:16,902 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0017_01_000005 is : 143
2016-05-18 01:19:16,931 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0017_01_000004 is : 143
2016-05-18 01:19:22,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0017_01_000007 is : 143
2016-05-18 01:19:23,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/lhs
2016-05-18 01:19:23,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/rhs
2016-05-18 01:19:23,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463533994246_0018
2016-05-18 01:19:23,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0018/
2016-05-18 01:19:23,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463533994246_0019
2016-05-18 01:19:23,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0019/
2016-05-18 01:19:36,399 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0018_01_000002 is : 143
2016-05-18 01:19:41,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0019_01_000002 is : 143
2016-05-18 01:19:42,707 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2016-05-18 01:19:42,709 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2016-05-18 01:19:42,711 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  completed in: 00:43.830, using cpu time: 00:09.530
2016-05-18 01:19:42,771 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2016-05-18 01:19:42,776 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2016-05-18 01:19:42,799 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:19:42,800 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 01:19:42,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2016-05-18 01:19:42,869 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 01:19:42,869 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 01:19:42,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 01:19:42,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:19:42,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:19:42,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:19:42,906 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:19:42,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2016-05-18 01:19:42,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 01:19:42,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 2
2016-05-18 01:19:42,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 2
2016-05-18 01:19:42,914 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 01:19:43,038 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0020
2016-05-18 01:19:43,039 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0020/
2016-05-18 01:20:01,113 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0020_01_000006 is : 143
2016-05-18 01:20:01,763 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0020_01_000005 is : 143
2016-05-18 01:20:02,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0020_01_000003 is : 143
2016-05-18 01:20:02,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0020_01_000004 is : 143
2016-05-18 01:20:02,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0020_01_000002 is : 143
2016-05-18 01:20:03,522 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2016-05-18 01:20:03,659 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0021
2016-05-18 01:20:03,659 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0021/
2016-05-18 01:20:21,618 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0021_01_000003 is : 143
2016-05-18 01:20:21,741 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0021_01_000002 is : 143
2016-05-18 01:20:21,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0021_01_000004 is : 143
2016-05-18 01:20:22,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0021_01_000005 is : 143
2016-05-18 01:20:22,264 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0021_01_000006 is : 143
2016-05-18 01:20:28,325 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0021_01_000007 is : 143
2016-05-18 01:20:29,572 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2016-05-18 01:20:29,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:46.658, using cpu time: 00:15.040
2016-05-18 01:20:29,607 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2016-05-18 01:20:29,627 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:20:29,627 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 01:20:29,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2016-05-18 01:20:29,697 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 01:20:29,697 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 01:20:29,723 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 01:20:29,723 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:20:29,724 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:20:29,724 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:20:29,724 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:20:29,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2016-05-18 01:20:29,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 01:20:29,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 2
2016-05-18 01:20:29,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 2
2016-05-18 01:20:29,727 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 01:20:29,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0022
2016-05-18 01:20:29,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0022/
2016-05-18 01:20:47,361 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0022_01_000003 is : 143
2016-05-18 01:20:47,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0022_01_000002 is : 143
2016-05-18 01:20:48,607 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0022_01_000006 is : 143
2016-05-18 01:20:48,675 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0022_01_000005 is : 143
2016-05-18 01:20:48,978 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0022_01_000004 is : 143
2016-05-18 01:20:50,161 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2016-05-18 01:20:50,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0023
2016-05-18 01:20:50,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0023/
2016-05-18 01:21:08,062 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0023_01_000004 is : 143
2016-05-18 01:21:08,117 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0023_01_000005 is : 143
2016-05-18 01:21:08,251 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0023_01_000002 is : 143
2016-05-18 01:21:08,583 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0023_01_000006 is : 143
2016-05-18 01:21:08,769 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0023_01_000003 is : 143
2016-05-18 01:21:14,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0023_01_000007 is : 143
2016-05-18 01:21:15,911 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2016-05-18 01:21:15,913 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:46.184, using cpu time: 00:14.640
2016-05-18 01:21:15,947 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2016-05-18 01:21:15,979 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:21:15,979 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 01:21:16,010 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 01:21:16,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:21:16,011 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 01:21:16,022 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:21:16,023 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:21:16,023 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:21:16,023 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2016-05-18 01:21:16,023 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:21:16,023 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:21:16,023 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:21:16,024 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2016-05-18 01:21:16,160 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0024
2016-05-18 01:21:16,160 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0024/
2016-05-18 01:21:34,604 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0024_01_000003 is : 143
2016-05-18 01:21:34,686 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0024_01_000002 is : 143
2016-05-18 01:21:35,363 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0024_01_000006 is : 143
2016-05-18 01:21:35,510 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0024_01_000005 is : 143
2016-05-18 01:21:35,872 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0024_01_000004 is : 143
2016-05-18 01:21:37,126 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2016-05-18 01:21:37,127 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:21.098, using cpu time: 00:10.390
2016-05-18 01:21:37,168 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2016-05-18 01:21:37,193 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:21:37,193 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 01:21:37,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 01:21:37,249 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 01:21:37,249 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 01:21:37,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting
2016-05-18 01:21:37,271 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:21:37,271 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:21:37,271 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.4.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 01:21:37,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2016-05-18 01:21:37,272 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  parallel execution of steps is enabled: true
2016-05-18 01:21:37,272 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  executing total steps: 2
2016-05-18 01:21:37,273 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  allocating management threads: 2
2016-05-18 01:21:37,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (1/2)
2016-05-18 01:21:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463533994246_0025
2016-05-18 01:21:37,397 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0025/
2016-05-18 01:21:54,496 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0025_01_000002 is : 143
2016-05-18 01:21:55,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0025_01_000003 is : 143
2016-05-18 01:21:55,123 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0025_01_000004 is : 143
2016-05-18 01:21:55,202 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0025_01_000005 is : 143
2016-05-18 01:21:55,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0025_01_000006 is : 143
2016-05-18 01:22:00,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0025_01_000007 is : 143
2016-05-18 01:22:02,041 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2016-05-18 01:22:02,206 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463533994246_0026
2016-05-18 01:22:02,206 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0026/
2016-05-18 01:22:12,813 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0026_01_000002 is : 143
2016-05-18 01:22:14,061 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2016-05-18 01:22:14,063 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  completed in: 00:36.786, using cpu time: 00:08.370
2016-05-18 01:22:14,100 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2016-05-18 01:22:14,118 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:22:14,118 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 01:22:14,144 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 01:22:14,145 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:22:14,146 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 01:22:14,155 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 01:22:14,155 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.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:22:14,156 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.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:22:14,156 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross"]
2016-05-18 01:22:14,156 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 01:22:14,156 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 1
2016-05-18 01:22:14,156 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 1
2016-05-18 01:22:14,157 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-05-18 01:22:14,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463533994246_0027
2016-05-18 01:22:14,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0027/
2016-05-18 01:22:30,546 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0027_01_000003 is : 143
2016-05-18 01:22:30,829 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0027_01_000005 is : 143
2016-05-18 01:22:30,969 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0027_01_000002 is : 143
2016-05-18 01:22:31,078 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0027_01_000004 is : 143
2016-05-18 01:22:32,332 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2016-05-18 01:22:32,334 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:18.175, using cpu time: 00:06.190
2016-05-18 01:22:32,375 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2016-05-18 01:22:32,398 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:22:32,398 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 01:22:32,427 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 01:22:32,429 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:22:32,429 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 01:22:32,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:22:32,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:22:32,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:22:32,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join"]
2016-05-18 01:22:32,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:22:32,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:22:32,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:22:32,442 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2016-05-18 01:22:32,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0028
2016-05-18 01:22:32,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0028/
2016-05-18 01:22:50,738 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0028_01_000002 is : 143
2016-05-18 01:22:50,795 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0028_01_000003 is : 143
2016-05-18 01:22:51,362 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0028_01_000004 is : 143
2016-05-18 01:22:51,705 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0028_01_000006 is : 143
2016-05-18 01:22:51,825 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0028_01_000005 is : 143
2016-05-18 01:22:53,071 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2016-05-18 01:22:53,073 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.625, using cpu time: 00:07.120
2016-05-18 01:22:53,115 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2016-05-18 01:22:53,141 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:22:53,142 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 01:22:53,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-05-18 01:22:53,223 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 01:22:53,223 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 01:22:53,263 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 01:22:53,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:22:53,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:22:53,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:22:53,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2016-05-18 01:22:53,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2016-05-18 01:22:53,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 01:22:53,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 3
2016-05-18 01:22:53,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 3
2016-05-18 01:22:53,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 01:22:53,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0029
2016-05-18 01:22:53,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0029/
2016-05-18 01:23:10,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0029_01_000006 is : 143
2016-05-18 01:23:11,687 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0029_01_000002 is : 143
2016-05-18 01:23:12,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0029_01_000004 is : 143
2016-05-18 01:23:12,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0029_01_000003 is : 143
2016-05-18 01:23:13,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0029_01_000005 is : 143
2016-05-18 01:23:14,261 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/rhs
2016-05-18 01:23:14,263 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/lhs
2016-05-18 01:23:14,450 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0030
2016-05-18 01:23:14,450 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0030/
2016-05-18 01:23:14,465 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0031
2016-05-18 01:23:14,465 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0031/
2016-05-18 01:23:34,803 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0030_01_000002 is : 143
2016-05-18 01:23:35,220 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0030_01_000003 is : 143
2016-05-18 01:23:35,257 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0030_01_000004 is : 143
2016-05-18 01:23:35,870 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0030_01_000006 is : 143
2016-05-18 01:23:36,089 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0030_01_000005 is : 143
2016-05-18 01:23:47,580 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0031_01_000004 is : 143
2016-05-18 01:23:47,747 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0031_01_000003 is : 143
2016-05-18 01:23:47,881 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0031_01_000002 is : 143
2016-05-18 01:23:47,993 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0031_01_000005 is : 143
2016-05-18 01:23:48,973 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0030_01_000007 is : 143
2016-05-18 01:23:53,873 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0031_01_000006 is : 143
2016-05-18 01:23:55,118 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2016-05-18 01:23:55,119 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2016-05-18 01:23:55,122 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 01:01.850, using cpu time: 00:21.420
2016-05-18 01:23:55,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2016-05-18 01:23:55,158 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2016-05-18 01:23:55,177 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:23:55,177 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 01:23:55,245 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 01:23:55,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 01:23:55,246 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 01:23:55,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting
2016-05-18 01:23:55,264 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:23:55,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:23:55,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:23:55,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:23:55,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2016-05-18 01:23:55,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  parallel execution of steps is enabled: true
2016-05-18 01:23:55,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  executing total steps: 1
2016-05-18 01:23:55,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  allocating management threads: 1
2016-05-18 01:23:55,268 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2016-05-18 01:23:55,415 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] submitted hadoop job: job_1463533994246_0032
2016-05-18 01:23:55,416 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0032/
2016-05-18 01:24:16,372 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000003 is : 143
2016-05-18 01:24:16,487 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000002 is : 143
2016-05-18 01:24:16,982 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000006 is : 143
2016-05-18 01:24:17,058 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000004 is : 143
2016-05-18 01:24:17,292 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000007 is : 143
2016-05-18 01:24:17,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000005 is : 143
2016-05-18 01:24:23,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0032_01_000008 is : 143
2016-05-18 01:24:24,473 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2016-05-18 01:24:24,474 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  completed in: 00:29.206, using cpu time: 00:08.500
2016-05-18 01:24:24,512 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2016-05-18 01:24:24,529 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:24:24,530 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 01:24:24,558 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 01:24:24,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:24:24,560 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 01:24:24,570 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:24:24,570 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:24:24,570 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:24:24,570 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2016-05-18 01:24:24,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:24:24,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:24:24,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:24:24,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2016-05-18 01:24:24,693 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0033
2016-05-18 01:24:24,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0033/
2016-05-18 01:24:41,504 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0033_01_000006 is : 143
2016-05-18 01:24:42,901 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0033_01_000003 is : 143
2016-05-18 01:24:43,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0033_01_000004 is : 143
2016-05-18 01:24:43,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0033_01_000005 is : 143
2016-05-18 01:24:44,448 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0033_01_000002 is : 143
2016-05-18 01:24:45,707 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2016-05-18 01:24:45,708 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:21.134, using cpu time: 00:07.250
2016-05-18 01:24:45,749 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2016-05-18 01:24:45,773 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:24:45,773 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 01:24:45,808 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 01:24:45,811 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:24:45,812 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 01:24:45,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 01:24:45,825 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:24:45,825 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:24:45,825 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:24:45,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2016-05-18 01:24:45,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 01:24:45,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  executing total steps: 1
2016-05-18 01:24:45,827 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  allocating management threads: 1
2016-05-18 01:24:45,828 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2016-05-18 01:24:45,969 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463533994246_0034
2016-05-18 01:24:45,970 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0034/
2016-05-18 01:25:03,998 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0034_01_000003 is : 143
2016-05-18 01:25:04,238 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0034_01_000002 is : 143
2016-05-18 01:25:04,455 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0034_01_000006 is : 143
2016-05-18 01:25:04,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0034_01_000004 is : 143
2016-05-18 01:25:05,015 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0034_01_000005 is : 143
2016-05-18 01:25:06,243 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2016-05-18 01:25:06,244 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  completed in: 00:20.416, using cpu time: 00:06.130
2016-05-18 01:25:06,290 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2016-05-18 01:25:06,326 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:25:06,327 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 01:25:06,356 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 01:25:06,357 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:25:06,357 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 01:25:06,372 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:25:06,372 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:25:06,373 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:25:06,373 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone"]
2016-05-18 01:25:06,373 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:25:06,374 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:25:06,374 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:25:06,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-05-18 01:25:06,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0035
2016-05-18 01:25:06,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0035/
2016-05-18 01:25:24,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0035_01_000003 is : 143
2016-05-18 01:25:24,990 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0035_01_000002 is : 143
2016-05-18 01:25:25,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0035_01_000006 is : 143
2016-05-18 01:25:25,836 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0035_01_000005 is : 143
2016-05-18 01:25:25,884 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0035_01_000004 is : 143
2016-05-18 01:25:27,157 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-05-18 01:25:27,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.783, using cpu time: 00:06.990
2016-05-18 01:25:27,204 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2016-05-18 01:25:27,227 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:25:27,227 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 01:25:27,270 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 01:25:27,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 01:25:27,271 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 01:25:27,294 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:25:27,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:25:27,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:25:27,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself"]
2016-05-18 01:25:27,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:25:27,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 01:25:27,296 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 01:25:27,298 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 01:25:27,431 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0036
2016-05-18 01:25:27,431 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0036/
2016-05-18 01:25:44,969 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0036_01_000006 is : 143
2016-05-18 01:25:45,093 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0036_01_000002 is : 143
2016-05-18 01:25:45,353 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0036_01_000003 is : 143
2016-05-18 01:25:45,968 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0036_01_000005 is : 143
2016-05-18 01:25:46,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0036_01_000004 is : 143
2016-05-18 01:25:47,317 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2016-05-18 01:25:47,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0037
2016-05-18 01:25:47,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0037/
2016-05-18 01:26:05,085 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0037_01_000006 is : 143
2016-05-18 01:26:05,981 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0037_01_000004 is : 143
2016-05-18 01:26:06,121 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0037_01_000003 is : 143
2016-05-18 01:26:06,308 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0037_01_000002 is : 143
2016-05-18 01:26:06,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0037_01_000005 is : 143
2016-05-18 01:26:07,749 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2016-05-18 01:26:07,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:40.450, using cpu time: 00:14.880
2016-05-18 01:26:07,792 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2016-05-18 01:26:07,817 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:26:07,817 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 01:26:07,950 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.130
2016-05-18 01:26:07,952 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 8
2016-05-18 01:26:07,953 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 01:26:08,031 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting
2016-05-18 01:26:08,032 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:26:08,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink"]
2016-05-18 01:26:08,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2"]
2016-05-18 01:26:08,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  parallel execution of steps is enabled: true
2016-05-18 01:26:08,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  executing total steps: 5
2016-05-18 01:26:08,033 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  allocating management threads: 5
2016-05-18 01:26:08,036 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (1/5)
2016-05-18 01:26:08,036 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (2/5)
2016-05-18 01:26:08,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463533994246_0038
2016-05-18 01:26:08,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0038/
2016-05-18 01:26:08,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463533994246_0039
2016-05-18 01:26:08,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0039/
2016-05-18 01:26:27,852 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0038_01_000005 is : 143
2016-05-18 01:26:28,871 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0038_01_000004 is : 143
2016-05-18 01:26:29,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0038_01_000003 is : 143
2016-05-18 01:26:29,708 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0038_01_000002 is : 143
2016-05-18 01:26:29,794 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0038_01_000006 is : 143
2016-05-18 01:26:42,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0039_01_000004 is : 143
2016-05-18 01:26:42,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0039_01_000003 is : 143
2016-05-18 01:26:43,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0039_01_000005 is : 143
2016-05-18 01:26:43,493 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0039_01_000006 is : 143
2016-05-18 01:26:43,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0039_01_000002 is : 143
2016-05-18 01:26:44,465 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0038_01_000007 is : 143
2016-05-18 01:26:45,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (3/5) ...undSplitGroupByJoin/sink2
2016-05-18 01:26:45,829 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463533994246_0040
2016-05-18 01:26:45,829 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0040/
2016-05-18 01:26:49,208 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0039_01_000007 is : 143
2016-05-18 01:26:50,386 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (4/5)
2016-05-18 01:26:50,520 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463533994246_0041
2016-05-18 01:26:50,520 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0041/
2016-05-18 01:27:03,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0040_01_000002 is : 143
2016-05-18 01:27:08,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0041_01_000002 is : 143
2016-05-18 01:27:15,074 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0041_01_000003 is : 143
2016-05-18 01:27:16,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (5/5) ...oundSplitGroupByJoin/sink
2016-05-18 01:27:16,408 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463533994246_0042
2016-05-18 01:27:16,408 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0042/
2016-05-18 01:27:27,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0042_01_000002 is : 143
2016-05-18 01:27:28,385 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2/_temporary
2016-05-18 01:27:28,388 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink/_temporary
2016-05-18 01:27:28,394 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  completed in: 01:20.347, using cpu time: 00:18.280
2016-05-18 01:27:28,437 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2
2016-05-18 01:27:28,441 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink
2016-05-18 01:27:28,460 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:27:28,461 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 01:27:28,519 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-05-18 01:27:28,520 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 01:27:28,521 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 01:27:28,543 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 01:27:28,543 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 3
2016-05-18 01:27:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 3
2016-05-18 01:27:28,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 01:27:28,673 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0043
2016-05-18 01:27:28,673 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0043/
2016-05-18 01:27:45,002 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0043_01_000002 is : 143
2016-05-18 01:27:45,290 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0043_01_000003 is : 143
2016-05-18 01:27:45,544 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0043_01_000004 is : 143
2016-05-18 01:27:45,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0043_01_000005 is : 143
2016-05-18 01:27:46,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/lhs
2016-05-18 01:27:46,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/rhs
2016-05-18 01:27:47,064 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0044
2016-05-18 01:27:47,065 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0044/
2016-05-18 01:27:47,106 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0045
2016-05-18 01:27:47,106 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0045/
2016-05-18 01:28:05,921 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0044_01_000003 is : 143
2016-05-18 01:28:06,403 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0044_01_000005 is : 143
2016-05-18 01:28:07,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0044_01_000004 is : 143
2016-05-18 01:28:16,239 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0045_01_000003 is : 143
2016-05-18 01:28:16,671 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0045_01_000004 is : 143
2016-05-18 01:28:16,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0045_01_000002 is : 143
2016-05-18 01:28:16,839 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0045_01_000005 is : 143
2016-05-18 01:28:18,112 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2016-05-18 01:28:18,113 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2016-05-18 01:28:18,115 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:49.565, using cpu time: 00:19.520
2016-05-18 01:28:18,158 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2016-05-18 01:28:18,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2016-05-18 01:28:18,192 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:28:18,192 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 01:28:18,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 01:28:18,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 01:28:18,236 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 01:28:18,253 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting
2016-05-18 01:28:18,253 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:28:18,253 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:28:18,253 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:28:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2016-05-18 01:28:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  parallel execution of steps is enabled: true
2016-05-18 01:28:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  executing total steps: 2
2016-05-18 01:28:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  allocating management threads: 2
2016-05-18 01:28:18,256 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (1/2)
2016-05-18 01:28:18,382 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463533994246_0046
2016-05-18 01:28:18,382 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0046/
2016-05-18 01:28:35,727 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0046_01_000003 is : 143
2016-05-18 01:28:36,570 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0046_01_000002 is : 143
2016-05-18 01:28:36,815 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0046_01_000004 is : 143
2016-05-18 01:28:37,100 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0046_01_000006 is : 143
2016-05-18 01:28:37,332 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0046_01_000005 is : 143
2016-05-18 01:28:38,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2016-05-18 01:28:38,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463533994246_0047
2016-05-18 01:28:38,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0047/
2016-05-18 01:28:57,067 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0047_01_000003 is : 143
2016-05-18 01:28:57,256 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0047_01_000004 is : 143
2016-05-18 01:28:57,328 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0047_01_000002 is : 143
2016-05-18 01:28:57,565 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0047_01_000005 is : 143
2016-05-18 01:28:58,161 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0047_01_000006 is : 143
2016-05-18 01:28:59,436 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2016-05-18 01:28:59,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  completed in: 00:41.178, using cpu time: 00:15.330
2016-05-18 01:28:59,482 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2016-05-18 01:28:59,516 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:28:59,516 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 01:28:59,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-05-18 01:28:59,590 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 01:28:59,591 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 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting
2016-05-18 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join"]
2016-05-18 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  parallel execution of steps is enabled: true
2016-05-18 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  executing total steps: 4
2016-05-18 01:28:59,631 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  allocating management threads: 4
2016-05-18 01:28:59,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (1/4)
2016-05-18 01:28:59,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (2/4)
2016-05-18 01:28:59,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463533994246_0048
2016-05-18 01:28:59,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0048/
2016-05-18 01:28:59,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463533994246_0049
2016-05-18 01:28:59,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0049/
2016-05-18 01:29:20,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0048_01_000002 is : 143
2016-05-18 01:29:21,955 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0048_01_000005 is : 143
2016-05-18 01:29:22,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0048_01_000006 is : 143
2016-05-18 01:29:22,524 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0048_01_000004 is : 143
2016-05-18 01:29:36,492 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0049_01_000004 is : 143
2016-05-18 01:29:36,552 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0049_01_000003 is : 143
2016-05-18 01:29:36,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0049_01_000006 is : 143
2016-05-18 01:29:36,804 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0049_01_000002 is : 143
2016-05-18 01:29:37,065 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0049_01_000005 is : 143
2016-05-18 01:29:38,023 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0048_01_000007 is : 143
2016-05-18 01:29:43,526 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0049_01_000007 is : 143
2016-05-18 01:29:44,689 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (3/4)
2016-05-18 01:29:44,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463533994246_0050
2016-05-18 01:29:44,826 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0050/
2016-05-18 01:29:57,192 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0050_01_000003 is : 143
2016-05-18 01:29:57,412 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0050_01_000002 is : 143
2016-05-18 01:30:04,052 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0050_01_000004 is : 143
2016-05-18 01:30:05,232 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (4/4) ...kCoGroupThenHashJoin/join
2016-05-18 01:30:05,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463533994246_0051
2016-05-18 01:30:05,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0051/
2016-05-18 01:30:23,872 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0051_01_000005 is : 143
2016-05-18 01:30:24,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0051_01_000002 is : 143
2016-05-18 01:30:24,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0051_01_000003 is : 143
2016-05-18 01:30:24,929 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0051_01_000004 is : 143
2016-05-18 01:30:24,940 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0051_01_000006 is : 143
2016-05-18 01:30:26,194 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join/_temporary
2016-05-18 01:30:26,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  completed in: 01:26.554, using cpu time: 00:32.290
2016-05-18 01:30:26,246 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join
2016-05-18 01:30:26,267 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:30:26,267 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 01:30:26,301 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 01:30:26,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 01:30:26,302 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 01:30:26,315 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:30:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:30:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join"]
2016-05-18 01:30:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:30:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 01:30:26,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 01:30:26,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 01:30:26,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0052
2016-05-18 01:30:26,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0052/
2016-05-18 01:30:45,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0052_01_000006 is : 143
2016-05-18 01:30:45,359 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0052_01_000002 is : 143
2016-05-18 01:30:45,751 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0052_01_000005 is : 143
2016-05-18 01:30:45,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0052_01_000003 is : 143
2016-05-18 01:30:46,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0052_01_000004 is : 143
2016-05-18 01:30:47,342 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testForkThenJoin/join
2016-05-18 01:30:47,489 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0053
2016-05-18 01:30:47,489 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0053/
2016-05-18 01:31:05,773 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0053_01_000003 is : 143
2016-05-18 01:31:05,840 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0053_01_000002 is : 143
2016-05-18 01:31:06,586 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0053_01_000005 is : 143
2016-05-18 01:31:06,627 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0053_01_000004 is : 143
2016-05-18 01:31:06,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0053_01_000006 is : 143
2016-05-18 01:31:07,929 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join/_temporary
2016-05-18 01:31:07,931 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:41.609, using cpu time: 00:19.170
2016-05-18 01:31:07,970 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join
2016-05-18 01:31:08,003 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:31:08,004 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 01:31:08,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 01:31:08,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 01:31:08,044 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 01:31:08,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:31:08,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:31:08,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:31:08,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2016-05-18 01:31:08,066 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:31:08,067 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 01:31:08,067 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 01:31:08,069 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 01:31:08,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0054
2016-05-18 01:31:08,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0054/
2016-05-18 01:31:25,950 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0054_01_000002 is : 143
2016-05-18 01:31:26,046 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0054_01_000005 is : 143
2016-05-18 01:31:26,120 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0054_01_000006 is : 143
2016-05-18 01:31:26,246 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0054_01_000003 is : 143
2016-05-18 01:31:26,296 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0054_01_000004 is : 143
2016-05-18 01:31:32,671 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0054_01_000007 is : 143
2016-05-18 01:31:33,853 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2016-05-18 01:31:33,974 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0055
2016-05-18 01:31:33,974 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0055/
2016-05-18 01:31:51,410 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0055_01_000003 is : 143
2016-05-18 01:31:51,831 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0055_01_000006 is : 143
2016-05-18 01:31:52,609 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0055_01_000004 is : 143
2016-05-18 01:31:52,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0055_01_000002 is : 143
2016-05-18 01:31:52,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0055_01_000005 is : 143
2016-05-18 01:31:54,083 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2016-05-18 01:31:54,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:46.014, using cpu time: 00:14.000
2016-05-18 01:31:54,124 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2016-05-18 01:31:54,148 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:31:54,148 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 01:31:54,199 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-05-18 01:31:54,201 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 01:31:54,201 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 01:31:54,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 01:31:54,222 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:31:54,222 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:31:54,222 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.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:31:54,223 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2016-05-18 01:31:54,223 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 01:31:54,223 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  executing total steps: 3
2016-05-18 01:31:54,224 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  allocating management threads: 3
2016-05-18 01:31:54,225 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/3)
2016-05-18 01:31:54,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463533994246_0056
2016-05-18 01:31:54,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0056/
2016-05-18 01:32:11,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0056_01_000002 is : 143
2016-05-18 01:32:12,300 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0056_01_000003 is : 143
2016-05-18 01:32:12,532 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0056_01_000004 is : 143
2016-05-18 01:32:12,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0056_01_000005 is : 143
2016-05-18 01:32:13,282 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0056_01_000006 is : 143
2016-05-18 01:32:14,501 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (2/3)
2016-05-18 01:32:14,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463533994246_0057
2016-05-18 01:32:14,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0057/
2016-05-18 01:32:32,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0057_01_000003 is : 143
2016-05-18 01:32:32,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0057_01_000006 is : 143
2016-05-18 01:32:33,426 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0057_01_000005 is : 143
2016-05-18 01:32:33,680 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0057_01_000002 is : 143
2016-05-18 01:32:34,441 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0057_01_000004 is : 143
2016-05-18 01:32:35,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2016-05-18 01:32:35,794 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463533994246_0058
2016-05-18 01:32:35,794 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0058/
2016-05-18 01:32:53,850 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0058_01_000005 is : 143
2016-05-18 01:32:53,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0058_01_000006 is : 143
2016-05-18 01:32:54,097 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0058_01_000004 is : 143
2016-05-18 01:32:54,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0058_01_000002 is : 143
2016-05-18 01:32:54,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0058_01_000003 is : 143
2016-05-18 01:32:55,778 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2016-05-18 01:32:55,781 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  completed in: 01:01.544, using cpu time: 00:23.280
2016-05-18 01:32:55,824 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2016-05-18 01:32:55,860 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:32:55,860 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 01:32:55,932 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-18 01:32:55,936 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 01:32:55,936 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 01:32:55,955 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 1
2016-05-18 01:32:55,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 1
2016-05-18 01:32:55,957 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2016-05-18 01:32:56,100 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463533994246_0059
2016-05-18 01:32:56,100 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0059/
2016-05-18 01:33:16,207 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000003 is : 143
2016-05-18 01:33:16,699 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000002 is : 143
2016-05-18 01:33:16,767 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000004 is : 143
2016-05-18 01:33:16,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000007 is : 143
2016-05-18 01:33:16,825 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000005 is : 143
2016-05-18 01:33:17,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000006 is : 143
2016-05-18 01:33:22,080 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0059_01_000008 is : 143
2016-05-18 01:33:23,326 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2016-05-18 01:33:23,327 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:27.368, using cpu time: 00:08.620
2016-05-18 01:33:23,356 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2016-05-18 01:33:23,404 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:33:23,405 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 01:33:23,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 01:33:23,429 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:33:23,429 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 01:33:23,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:33:23,444 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.4.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 01:33:23,444 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.4.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 01:33:23,444 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.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner"]
2016-05-18 01:33:23,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:33:23,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:33:23,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:33:23,445 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2016-05-18 01:33:23,573 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0060
2016-05-18 01:33:23,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0060/
2016-05-18 01:33:41,466 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0060_01_000002 is : 143
2016-05-18 01:33:41,659 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0060_01_000003 is : 143
2016-05-18 01:33:41,965 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0060_01_000006 is : 143
2016-05-18 01:33:41,988 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0060_01_000005 is : 143
2016-05-18 01:33:42,179 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0060_01_000004 is : 143
2016-05-18 01:33:43,423 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2016-05-18 01:33:43,425 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:19.978, using cpu time: 00:06.790
2016-05-18 01:33:43,463 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2016-05-18 01:33:43,488 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:33:43,489 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 01:33:43,526 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 01:33:43,527 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 01:33:43,527 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 01:33:43,544 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 01:33:43,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/rhs.txt"]
2016-05-18 01:33:43,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lhs.txt"]
2016-05-18 01:33:43,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2016-05-18 01:33:43,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2016-05-18 01:33:43,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 01:33:43,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 2
2016-05-18 01:33:43,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 2
2016-05-18 01:33:43,550 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/2) ...latform/testJoinSplit/lhs
2016-05-18 01:33:43,550 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/2) ...latform/testJoinSplit/rhs
2016-05-18 01:33:43,724 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0061
2016-05-18 01:33:43,724 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0061/
2016-05-18 01:33:43,730 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463533994246_0062
2016-05-18 01:33:43,730 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0062/
2016-05-18 01:34:02,870 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0061_01_000005 is : 143
2016-05-18 01:34:02,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0061_01_000003 is : 143
2016-05-18 01:34:03,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0061_01_000002 is : 143
2016-05-18 01:34:03,137 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0061_01_000004 is : 143
2016-05-18 01:34:12,848 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0062_01_000002 is : 143
2016-05-18 01:34:13,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0062_01_000004 is : 143
2016-05-18 01:34:13,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0062_01_000005 is : 143
2016-05-18 01:34:13,425 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0062_01_000003 is : 143
2016-05-18 01:34:14,675 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2016-05-18 01:34:14,677 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2016-05-18 01:34:14,683 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:31.130, using cpu time: 00:12.680
2016-05-18 01:34:14,748 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2016-05-18 01:34:14,757 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2016-05-18 01:34:14,777 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:34:14,777 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 01:34:14,825 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 01:34:14,825 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 01:34:14,826 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 01:34:14,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 01:34:14,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:34:14,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2016-05-18 01:34:14,855 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 01:34:14,855 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 2
2016-05-18 01:34:14,855 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 2
2016-05-18 01:34:14,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/2)
2016-05-18 01:34:15,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463533994246_0063
2016-05-18 01:34:15,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0063/
2016-05-18 01:34:32,036 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0063_01_000002 is : 143
2016-05-18 01:34:32,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0063_01_000003 is : 143
2016-05-18 01:34:32,622 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0063_01_000006 is : 143
2016-05-18 01:34:32,820 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0063_01_000004 is : 143
2016-05-18 01:34:32,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0063_01_000005 is : 143
2016-05-18 01:34:38,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0063_01_000007 is : 143
2016-05-18 01:34:39,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2016-05-18 01:34:39,688 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463533994246_0064
2016-05-18 01:34:39,688 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0064/
2016-05-18 01:34:57,687 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0064_01_000002 is : 143
2016-05-18 01:34:57,844 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0064_01_000003 is : 143
2016-05-18 01:34:58,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0064_01_000006 is : 143
2016-05-18 01:34:58,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0064_01_000005 is : 143
2016-05-18 01:34:58,822 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0064_01_000004 is : 143
2016-05-18 01:35:00,072 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2016-05-18 01:35:00,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:45.213, using cpu time: 00:13.680
2016-05-18 01:35:00,113 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2016-05-18 01:35:00,136 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:35:00,136 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 01:35:00,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-18 01:35:00,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 01:35:00,185 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 01:35:00,210 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 01:35:00,210 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:35:00,210 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:35:00,211 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2016-05-18 01:35:00,211 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 01:35:00,211 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  executing total steps: 3
2016-05-18 01:35:00,211 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  allocating management threads: 3
2016-05-18 01:35:00,213 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/3)
2016-05-18 01:35:00,215 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/3)
2016-05-18 01:35:00,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463533994246_0065
2016-05-18 01:35:00,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0065/
2016-05-18 01:35:00,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463533994246_0066
2016-05-18 01:35:00,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0066/
2016-05-18 01:35:20,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0065_01_000006 is : 143
2016-05-18 01:35:21,670 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0065_01_000005 is : 143
2016-05-18 01:35:21,814 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0065_01_000003 is : 143
2016-05-18 01:35:21,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0065_01_000004 is : 143
2016-05-18 01:35:35,045 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0066_01_000006 is : 143
2016-05-18 01:35:36,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0066_01_000005 is : 143
2016-05-18 01:35:36,345 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0066_01_000003 is : 143
2016-05-18 01:35:36,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0066_01_000004 is : 143
2016-05-18 01:35:37,201 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0065_01_000007 is : 143
2016-05-18 01:35:42,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0066_01_000007 is : 143
2016-05-18 01:35:43,270 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2016-05-18 01:35:43,400 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463533994246_0067
2016-05-18 01:35:43,400 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0067/
2016-05-18 01:35:54,762 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0067_01_000002 is : 143
2016-05-18 01:35:56,010 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2016-05-18 01:35:56,012 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  completed in: 00:55.794, using cpu time: 00:14.940
2016-05-18 01:35:56,039 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2016-05-18 01:35:56,085 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:35:56,085 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 01:35:56,117 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.029
2016-05-18 01:35:56,117 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 01:35:56,118 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2016-05-18 01:35:56,139 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:35:56,139 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 01:35:56,158 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 01:35:56,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:35:56,159 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 01:35:56,166 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 01:35:56,167 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:35:56,167 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2016-05-18 01:35:56,167 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  parallel execution of steps is enabled: true
2016-05-18 01:35:56,167 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  executing total steps: 1
2016-05-18 01:35:56,168 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  allocating management threads: 1
2016-05-18 01:35:56,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2016-05-18 01:35:56,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463533994246_0068
2016-05-18 01:35:56,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0068/
2016-05-18 01:36:14,221 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0068_01_000004 is : 143
2016-05-18 01:36:14,352 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0068_01_000002 is : 143
2016-05-18 01:36:14,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0068_01_000005 is : 143
2016-05-18 01:36:14,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0068_01_000003 is : 143
2016-05-18 01:36:14,837 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0068_01_000006 is : 143
2016-05-18 01:36:16,095 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2016-05-18 01:36:16,096 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  completed in: 00:19.927, using cpu time: 00:06.810
2016-05-18 01:36:16,134 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2016-05-18 01:36:16,156 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:36:16,156 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 01:36:16,174 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 01:36:16,176 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:36:16,176 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 01:36:16,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting
2016-05-18 01:36:16,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:36:16,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2016-05-18 01:36:16,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  parallel execution of steps is enabled: true
2016-05-18 01:36:16,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  executing total steps: 1
2016-05-18 01:36:16,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  allocating management threads: 1
2016-05-18 01:36:16,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2016-05-18 01:36:16,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] submitted hadoop job: job_1463533994246_0069
2016-05-18 01:36:16,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0069/
2016-05-18 01:36:34,000 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0069_01_000002 is : 143
2016-05-18 01:36:34,306 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0069_01_000006 is : 143
2016-05-18 01:36:34,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0069_01_000003 is : 143
2016-05-18 01:36:34,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0069_01_000004 is : 143
2016-05-18 01:36:35,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0069_01_000005 is : 143
2016-05-18 01:36:36,346 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2016-05-18 01:36:36,348 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  completed in: 00:20.161, using cpu time: 00:06.660
2016-05-18 01:36:36,386 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2016-05-18 01:36:36,409 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:36:36,410 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 01:36:36,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 01:36:36,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 01:36:36,439 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 01:36:36,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:36:36,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:36:36,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:36:36,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2016-05-18 01:36:36,451 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:36:36,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:36:36,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:36:36,452 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2016-05-18 01:36:36,582 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0070
2016-05-18 01:36:36,582 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0070/
2016-05-18 01:36:53,948 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0070_01_000002 is : 143
2016-05-18 01:36:54,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0070_01_000003 is : 143
2016-05-18 01:36:54,528 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0070_01_000006 is : 143
2016-05-18 01:36:54,782 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0070_01_000005 is : 143
2016-05-18 01:36:54,863 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0070_01_000004 is : 143
2016-05-18 01:37:00,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0070_01_000007 is : 143
2016-05-18 01:37:01,496 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2016-05-18 01:37:01,497 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:25.042, using cpu time: 00:06.920
2016-05-18 01:37:01,525 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2016-05-18 01:37:01,543 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:37:01,543 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 01:37:01,602 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-05-18 01:37:01,603 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 6
2016-05-18 01:37:01,604 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 01:37:01,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting
2016-05-18 01:37:01,634 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.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:37:01,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink"]
2016-05-18 01:37:01,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  parallel execution of steps is enabled: true
2016-05-18 01:37:01,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  executing total steps: 4
2016-05-18 01:37:01,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  allocating management threads: 4
2016-05-18 01:37:01,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (1/4)
2016-05-18 01:37:01,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463533994246_0071
2016-05-18 01:37:01,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0071/
2016-05-18 01:37:19,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0071_01_000003 is : 143
2016-05-18 01:37:19,472 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0071_01_000002 is : 143
2016-05-18 01:37:19,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0071_01_000005 is : 143
2016-05-18 01:37:19,709 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0071_01_000004 is : 143
2016-05-18 01:37:20,276 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0071_01_000006 is : 143
2016-05-18 01:37:25,716 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0071_01_000007 is : 143
2016-05-18 01:37:26,892 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (2/4)
2016-05-18 01:37:27,037 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463533994246_0072
2016-05-18 01:37:27,037 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0072/
2016-05-18 01:37:37,596 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0072_01_000002 is : 143
2016-05-18 01:37:38,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (3/4)
2016-05-18 01:37:38,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463533994246_0073
2016-05-18 01:37:38,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0073/
2016-05-18 01:37:49,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0073_01_000002 is : 143
2016-05-18 01:37:56,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0073_01_000003 is : 143
2016-05-18 01:37:57,373 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (4/4) ...plitSplitGroupByJoin/sink
2016-05-18 01:37:57,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463533994246_0074
2016-05-18 01:37:57,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0074/
2016-05-18 01:38:08,032 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0074_01_000002 is : 143
2016-05-18 01:38:09,274 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink/_temporary
2016-05-18 01:38:09,277 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  completed in: 01:07.627, using cpu time: 00:11.140
2016-05-18 01:38:09,305 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink
2016-05-18 01:38:09,322 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:38:09,322 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 01:38:09,342 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 01:38:09,343 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:38:09,343 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 01:38:09,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 01:38:09,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:38:09,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2016-05-18 01:38:09,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  parallel execution of steps is enabled: true
2016-05-18 01:38:09,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  executing total steps: 1
2016-05-18 01:38:09,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  allocating management threads: 1
2016-05-18 01:38:09,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2016-05-18 01:38:09,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463533994246_0075
2016-05-18 01:38:09,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0075/
2016-05-18 01:38:27,207 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0075_01_000006 is : 143
2016-05-18 01:38:27,528 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0075_01_000002 is : 143
2016-05-18 01:38:27,758 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0075_01_000004 is : 143
2016-05-18 01:38:27,814 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0075_01_000005 is : 143
2016-05-18 01:38:28,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0075_01_000003 is : 143
2016-05-18 01:38:29,378 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2016-05-18 01:38:29,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  completed in: 00:20.025, using cpu time: 00:06.670
2016-05-18 01:38:29,420 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2016-05-18 01:38:29,442 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:38:29,442 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 01:38:29,517 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-05-18 01:38:29,518 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 01:38:29,518 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 01:38:29,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting
2016-05-18 01:38:29,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:38:29,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2016-05-18 01:38:29,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  parallel execution of steps is enabled: true
2016-05-18 01:38:29,553 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  executing total steps: 4
2016-05-18 01:38:29,553 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  allocating management threads: 4
2016-05-18 01:38:29,554 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (1/4)
2016-05-18 01:38:29,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463533994246_0076
2016-05-18 01:38:29,679 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0076/
2016-05-18 01:38:47,375 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0076_01_000002 is : 143
2016-05-18 01:38:47,819 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0076_01_000006 is : 143
2016-05-18 01:38:47,891 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0076_01_000005 is : 143
2016-05-18 01:38:47,943 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0076_01_000003 is : 143
2016-05-18 01:38:48,162 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0076_01_000004 is : 143
2016-05-18 01:38:53,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0076_01_000007 is : 143
2016-05-18 01:38:54,450 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (2/4)
2016-05-18 01:38:54,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463533994246_0077
2016-05-18 01:38:54,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0077/
2016-05-18 01:39:05,128 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0077_01_000002 is : 143
2016-05-18 01:39:11,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0077_01_000003 is : 143
2016-05-18 01:39:12,492 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (3/4)
2016-05-18 01:39:12,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463533994246_0078
2016-05-18 01:39:12,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0078/
2016-05-18 01:39:23,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0078_01_000002 is : 143
2016-05-18 01:39:29,251 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0078_01_000003 is : 143
2016-05-18 01:39:30,421 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2016-05-18 01:39:30,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463533994246_0079
2016-05-18 01:39:30,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0079/
2016-05-18 01:39:41,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0079_01_000002 is : 143
2016-05-18 01:39:42,719 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2016-05-18 01:39:42,722 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  completed in: 01:13.159, using cpu time: 00:12.360
2016-05-18 01:39:42,750 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2016-05-18 01:39:42,768 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:39:42,768 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 01:39:42,790 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 01:39:42,791 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:39:42,791 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 01:39:42,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:39:42,801 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.4.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 01:39:42,801 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.4.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 01:39:42,801 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.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2016-05-18 01:39:42,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:39:42,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:39:42,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:39:42,802 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2016-05-18 01:39:42,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0080
2016-05-18 01:39:42,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0080/
2016-05-18 01:40:00,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0080_01_000003 is : 143
2016-05-18 01:40:00,841 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0080_01_000002 is : 143
2016-05-18 01:40:01,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0080_01_000006 is : 143
2016-05-18 01:40:01,521 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0080_01_000004 is : 143
2016-05-18 01:40:02,300 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0080_01_000005 is : 143
2016-05-18 01:40:03,544 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2016-05-18 01:40:03,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.738, using cpu time: 00:07.610
2016-05-18 01:40:03,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2016-05-18 01:40:03,621 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 01:40:03,622 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 01:40:03,646 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 01:40:03,648 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 01:40:03,648 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 01:40:03,662 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 01:40:03,662 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/upper.txt"]
2016-05-18 01:40:03,662 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/classes/test/data/lower.txt"]
2016-05-18 01:40:03,663 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2016-05-18 01:40:03,663 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 01:40:03,663 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 01:40:03,663 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 01:40:03,664 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2016-05-18 01:40:03,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463533994246_0081
2016-05-18 01:40:03,784 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:37356/proxy/application_1463533994246_0081/
2016-05-18 01:40:20,918 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0081_01_000006 is : 143
2016-05-18 01:40:21,779 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0081_01_000002 is : 143
2016-05-18 01:40:22,246 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0081_01_000004 is : 143
2016-05-18 01:40:22,818 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0081_01_000005 is : 143
2016-05-18 01:40:23,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463533994246_0081_01_000003 is : 143
2016-05-18 01:40:24,544 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2016-05-18 01:40:24,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.879, using cpu time: 00:07.850
2016-05-18 01:40:24,588 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.4.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields

Standard error

May 18, 2016 1:13:14 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 1:13:14 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 1:13:14 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 1:13:14 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 1:13:14 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 1:13:15 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 1:13:15 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 1:13:15 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 1:13:15 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 1:13:15 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 1:13:15 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 1:13:15 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 1:13:15 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 1:13:16 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 1:13:16 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 1:13:16 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 1:13:16 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 1:13:16 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 1:13:16 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 1:13:16 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 1:13:16 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 1:13:16 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 1:13:17 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 1:13:17 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 1:13:17 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 1:13:17 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 1:13:17 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 1:13:17 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 1:13:17 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 1:13:17 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 1:13:18 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 1:13:18 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 1:13:18 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 1:13:18 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
May 18, 2016 1:13:18 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 1:13:18 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 1:13:18 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 1:13:18 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 1:13:19 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 1:13:19 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.