Class cascading.JoinFieldedPipesPlatformTest

all > cascading > JoinFieldedPipesPlatformTest

tests

failures

ignored

27m44.60s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testCross	18.019s	passed
testForkCoGroupThenHashJoin	1m28.08s	passed
testForkCoGroupThenHashJoinCoGroupAgain	2m16.18s	passed
testForkThenJoin	41.843s	passed
testGroupBySplitAroundSplitGroupByJoin	1m22.37s	passed
testGroupBySplitGroupByJoin	1m15.80s	passed
testGroupBySplitJoins	44.920s	passed
testGroupBySplitSplitGroupByJoin	1m7.74s	passed
testJoin	20.422s	passed
testJoinAfterEvery	57.486s	passed
testJoinAroundJoinLeftMost	42.119s	passed
testJoinAroundJoinRightMost	20.707s	passed
testJoinAroundJoinRightMostSwapped	40.842s	passed
testJoinDiffFields	21.412s	passed
testJoinFilteredBranch	46.922s	passed
testJoinGroupBy	26.065s	passed
testJoinGroupByJoin	37.980s	passed
testJoinInner	20.136s	passed
testJoinInnerOuter	20.207s	passed
testJoinInnerSingleField	44.990s	passed
testJoinMergeGroupBy	0.085s	passed
testJoinMixed	0s	passed
testJoinNone	20.287s	passed
testJoinOuter	0s	passed
testJoinOuterInner	0.001s	passed
testJoinSamePipe	20.559s	passed
testJoinSamePipe2	20.163s	passed
testJoinSamePipe3	20.337s	passed
testJoinSamePipeAroundGroupBy	46.383s	passed
testJoinSamePipeName	20.579s	passed
testJoinSameSourceIntoJoin	1m0.93s	passed
testJoinSameSourceIntoJoinSimple	42.028s	passed
testJoinSameSourceOverGroupByIntoJoinSimple	56.428s	passed
testJoinSelf	40.733s	passed
testJoinSplit	31.614s	passed
testJoinSplitBeforeJoin	1m3.23s	passed
testJoinWithHasher	21.138s	passed
testJoinWithUnknowns	19.951s	passed
testJoinsIntoCoGroup	28.415s	passed
testJoinsIntoCoGroupLhs	46.532s	passed
testJoinsIntoCoGroupLhsSwappedJoin	25.231s	passed
testJoinsIntoCoGroupRhs	46.355s	passed
testJoinsIntoGroupBy	29.427s	passed
testSameSourceJoinSplitIntoJoin	49.953s	passed

Standard output

2016-05-18 03:40:02,822 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 03:40:02,843 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-05-18 03:40:02,882 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-05-18 03:40:03,704 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 03:40:04,391 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 03:40:04,982 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 03:40:08,000 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 03:40:08,149 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 03:40:08,265 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 03:40:08,380 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 03:40:20,203 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 03:40:21,120 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 03:40:21,120 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-05-18 03:40:25,460 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 03:40:25,685 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:40:25,686 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 03:40:25,758 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 3BDF04B56D4E4CD0BBC65A49E7B2C84F
2016-05-18 03:40:25,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2016-05-18 03:40:25,894 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:40:25,895 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 03:40:26,026 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 03:40:26,029 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:40:26,029 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:40:26,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower-offset.txt"]
2016-05-18 03:40:26,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2016-05-18 03:40:26,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:40:26,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 03:40:26,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 03:40:26,032 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2016-05-18 03:40:26,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0001
2016-05-18 03:40:26,925 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0001/
2016-05-18 03:40:45,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0001_01_000002 is : 143
2016-05-18 03:40:45,573 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0001_01_000003 is : 143
2016-05-18 03:40:46,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0001_01_000006 is : 143
2016-05-18 03:40:46,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0001_01_000004 is : 143
2016-05-18 03:40:46,439 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0001_01_000005 is : 143
2016-05-18 03:40:47,763 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2016-05-18 03:40:47,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:21.730, using cpu time: 00:05.330
2016-05-18 03:40:47,852 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2016-05-18 03:40:47,898 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:40:47,899 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 03:40:48,034 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.123
2016-05-18 03:40:48,038 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:40:48,039 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 03:40:48,083 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 03:40:48,083 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:40:48,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:40:48,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2016-05-18 03:40:48,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 03:40:48,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  executing total steps: 2
2016-05-18 03:40:48,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  allocating management threads: 2
2016-05-18 03:40:48,095 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/2)
2016-05-18 03:40:48,385 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463542819959_0002
2016-05-18 03:40:48,385 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0002/
2016-05-18 03:41:06,790 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0002_01_000006 is : 143
2016-05-18 03:41:07,205 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0002_01_000005 is : 143
2016-05-18 03:41:07,257 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0002_01_000003 is : 143
2016-05-18 03:41:07,337 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0002_01_000002 is : 143
2016-05-18 03:41:07,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0002_01_000004 is : 143
2016-05-18 03:41:08,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2016-05-18 03:41:09,116 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463542819959_0003
2016-05-18 03:41:09,116 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0003/
2016-05-18 03:41:27,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0003_01_000002 is : 143
2016-05-18 03:41:27,719 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0003_01_000003 is : 143
2016-05-18 03:41:28,469 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0003_01_000005 is : 143
2016-05-18 03:41:28,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0003_01_000006 is : 143
2016-05-18 03:41:28,568 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0003_01_000004 is : 143
2016-05-18 03:41:29,827 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2016-05-18 03:41:29,829 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  completed in: 00:41.738, using cpu time: 00:11.870
2016-05-18 03:41:29,884 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2016-05-18 03:41:29,940 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:41:29,940 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 03:41:30,037 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-18 03:41:30,038 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:41:30,038 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 03:41:30,065 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting
2016-05-18 03:41:30,066 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:41:30,067 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:41:30,067 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:41:30,067 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2016-05-18 03:41:30,069 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  parallel execution of steps is enabled: true
2016-05-18 03:41:30,069 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  executing total steps: 2
2016-05-18 03:41:30,069 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  allocating management threads: 2
2016-05-18 03:41:30,079 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (1/2)
2016-05-18 03:41:30,237 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463542819959_0004
2016-05-18 03:41:30,237 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0004/
2016-05-18 03:41:48,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0004_01_000005 is : 143
2016-05-18 03:41:48,913 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0004_01_000003 is : 143
2016-05-18 03:41:48,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0004_01_000004 is : 143
2016-05-18 03:41:49,418 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0004_01_000006 is : 143
2016-05-18 03:41:49,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0004_01_000002 is : 143
2016-05-18 03:41:50,883 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2016-05-18 03:41:51,101 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] submitted hadoop job: job_1463542819959_0005
2016-05-18 03:41:51,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0005/
2016-05-18 03:42:09,928 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0005_01_000003 is : 143
2016-05-18 03:42:09,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0005_01_000002 is : 143
2016-05-18 03:42:10,235 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0005_01_000006 is : 143
2016-05-18 03:42:10,514 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0005_01_000004 is : 143
2016-05-18 03:42:10,680 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0005_01_000005 is : 143
2016-05-18 03:42:11,944 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2016-05-18 03:42:11,946 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2*lower]  completed in: 00:41.875, using cpu time: 00:11.820
2016-05-18 03:42:12,007 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2016-05-18 03:42:12,040 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:42:12,041 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 03:42:12,114 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 03:42:12,118 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:42:12,118 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 03:42:12,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting
2016-05-18 03:42:12,135 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:42:12,135 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:42:12,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2016-05-18 03:42:12,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  parallel execution of steps is enabled: true
2016-05-18 03:42:12,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  executing total steps: 1
2016-05-18 03:42:12,137 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  allocating management threads: 1
2016-05-18 03:42:12,138 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-05-18 03:42:12,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] submitted hadoop job: job_1463542819959_0006
2016-05-18 03:42:12,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0006/
2016-05-18 03:42:30,499 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0006_01_000003 is : 143
2016-05-18 03:42:30,694 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0006_01_000002 is : 143
2016-05-18 03:42:31,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0006_01_000004 is : 143
2016-05-18 03:42:31,289 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0006_01_000005 is : 143
2016-05-18 03:42:31,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0006_01_000006 is : 143
2016-05-18 03:42:32,534 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2016-05-18 03:42:32,536 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [tail]  completed in: 00:20.398, using cpu time: 00:05.700
2016-05-18 03:42:32,586 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2016-05-18 03:42:32,623 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:42:32,623 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 03:42:32,714 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.087
2016-05-18 03:42:32,717 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 03:42:32,717 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 03:42:32,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:42:32,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:42:32,767 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:42:32,767 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2016-05-18 03:42:32,767 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:42:32,767 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 3
2016-05-18 03:42:32,768 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 3
2016-05-18 03:42:32,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/3)
2016-05-18 03:42:32,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/3)
2016-05-18 03:42:32,999 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0007
2016-05-18 03:42:33,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0007/
2016-05-18 03:42:33,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0008
2016-05-18 03:42:33,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0008/
2016-05-18 03:42:54,708 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0007_01_000002 is : 143
2016-05-18 03:42:55,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0007_01_000003 is : 143
2016-05-18 03:42:56,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0007_01_000006 is : 143
2016-05-18 03:42:56,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0007_01_000005 is : 143
2016-05-18 03:42:57,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0007_01_000004 is : 143
2016-05-18 03:43:08,316 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0008_01_000002 is : 143
2016-05-18 03:43:09,175 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0008_01_000003 is : 143
2016-05-18 03:43:10,077 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0008_01_000004 is : 143
2016-05-18 03:43:10,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0008_01_000005 is : 143
2016-05-18 03:43:10,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0008_01_000006 is : 143
2016-05-18 03:43:11,399 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0007_01_000007 is : 143
2016-05-18 03:43:15,384 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0008_01_000007 is : 143
2016-05-18 03:43:16,581 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2016-05-18 03:43:16,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0009
2016-05-18 03:43:16,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0009/
2016-05-18 03:43:28,811 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0009_01_000002 is : 143
2016-05-18 03:43:30,045 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2016-05-18 03:43:30,047 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:57.273, using cpu time: 00:14.560
2016-05-18 03:43:30,081 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2016-05-18 03:43:30,240 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:43:30,241 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 03:43:30,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.236
2016-05-18 03:43:30,485 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 6, nodes: 12
2016-05-18 03:43:30,486 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 03:43:30,640 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 03:43:30,640 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:43:30,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:43:30,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join"]
2016-05-18 03:43:30,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 03:43:30,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 6
2016-05-18 03:43:30,642 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 6
2016-05-18 03:43:30,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/6)
2016-05-18 03:43:30,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/6)
2016-05-18 03:43:30,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0010
2016-05-18 03:43:30,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0010/
2016-05-18 03:43:30,823 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0011
2016-05-18 03:43:30,823 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0011/
2016-05-18 03:43:52,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0010_01_000006 is : 143
2016-05-18 03:43:53,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0010_01_000004 is : 143
2016-05-18 03:43:53,934 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0010_01_000002 is : 143
2016-05-18 03:43:54,033 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0010_01_000005 is : 143
2016-05-18 03:44:09,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0011_01_000003 is : 143
2016-05-18 03:44:09,504 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0011_01_000002 is : 143
2016-05-18 03:44:09,556 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0011_01_000005 is : 143
2016-05-18 03:44:09,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0011_01_000006 is : 143
2016-05-18 03:44:10,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0011_01_000004 is : 143
2016-05-18 03:44:10,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0010_01_000007 is : 143
2016-05-18 03:44:16,485 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0011_01_000007 is : 143
2016-05-18 03:44:17,726 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (3/6)
2016-05-18 03:44:17,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0012
2016-05-18 03:44:17,875 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0012/
2016-05-18 03:44:30,343 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0012_01_000003 is : 143
2016-05-18 03:44:30,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0012_01_000002 is : 143
2016-05-18 03:44:36,957 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0012_01_000004 is : 143
2016-05-18 03:44:38,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (5/6)
2016-05-18 03:44:38,136 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (4/6)
2016-05-18 03:44:38,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0013
2016-05-18 03:44:38,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0013/
2016-05-18 03:44:38,328 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0014
2016-05-18 03:44:38,328 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0014/
2016-05-18 03:44:58,883 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0013_01_000002 is : 143
2016-05-18 03:44:59,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0013_01_000004 is : 143
2016-05-18 03:44:59,041 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0013_01_000006 is : 143
2016-05-18 03:44:59,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0013_01_000003 is : 143
2016-05-18 03:44:59,543 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0013_01_000005 is : 143
2016-05-18 03:45:12,659 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0013_01_000007 is : 143
2016-05-18 03:45:17,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0014_01_000004 is : 143
2016-05-18 03:45:17,643 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0014_01_000003 is : 143
2016-05-18 03:45:18,213 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0014_01_000007 is : 143
2016-05-18 03:45:18,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0014_01_000006 is : 143
2016-05-18 03:45:18,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0014_01_000005 is : 143
2016-05-18 03:45:24,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0014_01_000008 is : 143
2016-05-18 03:45:26,109 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (6/6) ...HashJoinCoGroupAgain/join
2016-05-18 03:45:26,250 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0015
2016-05-18 03:45:26,250 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0015/
2016-05-18 03:45:38,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0015_01_000002 is : 143
2016-05-18 03:45:38,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0015_01_000003 is : 143
2016-05-18 03:45:45,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0015_01_000004 is : 143
2016-05-18 03:45:46,217 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join/_temporary
2016-05-18 03:45:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 02:15.565, using cpu time: 00:46.330
2016-05-18 03:45:46,259 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoinCoGroupAgain/join
2016-05-18 03:45:46,313 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:45:46,314 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 03:45:46,385 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 03:45:46,388 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:45:46,388 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 03:45:46,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 03:45:46,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:45:46,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:45:46,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:45:46,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:45:46,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2016-05-18 03:45:46,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 03:45:46,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 1
2016-05-18 03:45:46,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 1
2016-05-18 03:45:46,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2016-05-18 03:45:46,557 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0016
2016-05-18 03:45:46,557 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0016/
2016-05-18 03:46:04,072 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0016_01_000003 is : 143
2016-05-18 03:46:05,012 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0016_01_000006 is : 143
2016-05-18 03:46:05,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0016_01_000005 is : 143
2016-05-18 03:46:05,268 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0016_01_000004 is : 143
2016-05-18 03:46:10,205 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0016_01_000007 is : 143
2016-05-18 03:46:11,458 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2016-05-18 03:46:11,460 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:25.045, using cpu time: 00:07.510
2016-05-18 03:46:11,491 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2016-05-18 03:46:11,529 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:46:11,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 03:46:11,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-05-18 03:46:11,600 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-05-18 03:46:11,601 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 03:46:11,632 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting
2016-05-18 03:46:11,632 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:46:11,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:46:11,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 03:46:11,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2016-05-18 03:46:11,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2016-05-18 03:46:11,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  parallel execution of steps is enabled: true
2016-05-18 03:46:11,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  executing total steps: 3
2016-05-18 03:46:11,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  allocating management threads: 3
2016-05-18 03:46:11,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (1/3)
2016-05-18 03:46:11,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463542819959_0017
2016-05-18 03:46:11,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0017/
2016-05-18 03:46:30,161 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0017_01_000004 is : 143
2016-05-18 03:46:30,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0017_01_000006 is : 143
2016-05-18 03:46:30,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0017_01_000002 is : 143
2016-05-18 03:46:30,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0017_01_000003 is : 143
2016-05-18 03:46:30,679 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0017_01_000005 is : 143
2016-05-18 03:46:36,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0017_01_000007 is : 143
2016-05-18 03:46:37,722 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/lhs
2016-05-18 03:46:37,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/rhs
2016-05-18 03:46:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463542819959_0018
2016-05-18 03:46:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0018/
2016-05-18 03:46:37,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_1463542819959_0019
2016-05-18 03:46:37,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0019/
2016-05-18 03:46:50,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0018_01_000002 is : 143
2016-05-18 03:46:55,105 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0019_01_000002 is : 143
2016-05-18 03:46:56,343 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2016-05-18 03:46:56,344 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2016-05-18 03:46:56,347 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  completed in: 00:44.706, using cpu time: 00:08.940
2016-05-18 03:46:56,406 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2016-05-18 03:46:56,411 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2016-05-18 03:46:56,441 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:46:56,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 03:46:56,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-18 03:46:56,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 03:46:56,516 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 03:46:56,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 03:46:56,545 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:46:56,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:46:56,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:46:56,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:46:56,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2016-05-18 03:46:56,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 03:46:56,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 2
2016-05-18 03:46:56,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 2
2016-05-18 03:46:56,552 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 03:46:56,690 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0020
2016-05-18 03:46:56,690 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0020/
2016-05-18 03:47:14,881 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0020_01_000006 is : 143
2016-05-18 03:47:15,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0020_01_000002 is : 143
2016-05-18 03:47:15,673 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0020_01_000004 is : 143
2016-05-18 03:47:15,835 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0020_01_000005 is : 143
2016-05-18 03:47:15,928 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0020_01_000003 is : 143
2016-05-18 03:47:17,122 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2016-05-18 03:47:17,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0021
2016-05-18 03:47:17,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0021/
2016-05-18 03:47:35,340 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0021_01_000005 is : 143
2016-05-18 03:47:35,674 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0021_01_000003 is : 143
2016-05-18 03:47:35,859 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0021_01_000002 is : 143
2016-05-18 03:47:35,898 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0021_01_000006 is : 143
2016-05-18 03:47:35,900 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0021_01_000004 is : 143
2016-05-18 03:47:41,634 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0021_01_000007 is : 143
2016-05-18 03:47:42,910 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2016-05-18 03:47:42,915 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:46.358, using cpu time: 00:13.420
2016-05-18 03:47:42,945 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2016-05-18 03:47:42,964 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:47:42,965 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 03:47:43,030 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-18 03:47:43,031 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 03:47:43,031 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 03:47:43,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 03:47:43,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:47:43,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:47:43,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:47:43,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:47:43,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2016-05-18 03:47:43,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 03:47:43,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 2
2016-05-18 03:47:43,057 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 2
2016-05-18 03:47:43,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/2)
2016-05-18 03:47:43,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0022
2016-05-18 03:47:43,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0022/
2016-05-18 03:48:01,026 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0022_01_000006 is : 143
2016-05-18 03:48:01,325 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0022_01_000004 is : 143
2016-05-18 03:48:01,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0022_01_000002 is : 143
2016-05-18 03:48:01,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0022_01_000003 is : 143
2016-05-18 03:48:02,117 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0022_01_000005 is : 143
2016-05-18 03:48:03,305 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2016-05-18 03:48:03,464 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0023
2016-05-18 03:48:03,464 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0023/
2016-05-18 03:48:21,693 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0023_01_000005 is : 143
2016-05-18 03:48:21,780 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0023_01_000004 is : 143
2016-05-18 03:48:21,929 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0023_01_000002 is : 143
2016-05-18 03:48:22,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0023_01_000003 is : 143
2016-05-18 03:48:22,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0023_01_000006 is : 143
2016-05-18 03:48:28,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0023_01_000007 is : 143
2016-05-18 03:48:29,268 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2016-05-18 03:48:29,269 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:46.207, using cpu time: 00:13.180
2016-05-18 03:48:29,300 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2016-05-18 03:48:29,319 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:48:29,319 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 03:48:29,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 03:48:29,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:48:29,353 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 03:48:29,364 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:48:29,365 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:48:29,365 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:48:29,366 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2016-05-18 03:48:29,366 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:48:29,366 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 03:48:29,366 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 03:48:29,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2016-05-18 03:48:29,488 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0024
2016-05-18 03:48:29,488 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0024/
2016-05-18 03:48:48,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0024_01_000002 is : 143
2016-05-18 03:48:48,779 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0024_01_000006 is : 143
2016-05-18 03:48:48,938 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0024_01_000005 is : 143
2016-05-18 03:48:49,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0024_01_000003 is : 143
2016-05-18 03:48:49,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0024_01_000004 is : 143
2016-05-18 03:48:50,387 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2016-05-18 03:48:50,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:21.018, using cpu time: 00:09.260
2016-05-18 03:48:50,431 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2016-05-18 03:48:50,456 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:48:50,456 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 03:48:50,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-05-18 03:48:50,518 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 03:48:50,518 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 03:48:50,540 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting
2016-05-18 03:48:50,541 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:48:50,541 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:48:50,541 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.5.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 03:48:50,541 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2016-05-18 03:48:50,542 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  parallel execution of steps is enabled: true
2016-05-18 03:48:50,542 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  executing total steps: 2
2016-05-18 03:48:50,542 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  allocating management threads: 2
2016-05-18 03:48:50,543 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (1/2)
2016-05-18 03:48:50,671 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463542819959_0025
2016-05-18 03:48:50,671 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0025/
2016-05-18 03:49:09,115 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0025_01_000002 is : 143
2016-05-18 03:49:09,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0025_01_000006 is : 143
2016-05-18 03:49:09,600 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0025_01_000004 is : 143
2016-05-18 03:49:09,641 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0025_01_000003 is : 143
2016-05-18 03:49:09,684 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0025_01_000005 is : 143
2016-05-18 03:49:15,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0025_01_000007 is : 143
2016-05-18 03:49:16,590 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2016-05-18 03:49:16,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] submitted hadoop job: job_1463542819959_0026
2016-05-18 03:49:16,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0026/
2016-05-18 03:49:27,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0026_01_000002 is : 143
2016-05-18 03:49:28,387 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2016-05-18 03:49:28,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper*joined]  completed in: 00:37.844, using cpu time: 00:08.120
2016-05-18 03:49:28,418 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2016-05-18 03:49:28,436 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:49:28,436 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 03:49:28,463 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 03:49:28,465 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:49:28,465 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 03:49:28,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 03:49:28,479 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.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:49:28,480 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.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:49:28,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross"]
2016-05-18 03:49:28,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 03:49:28,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 1
2016-05-18 03:49:28,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 1
2016-05-18 03:49:28,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-05-18 03:49:28,600 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463542819959_0027
2016-05-18 03:49:28,600 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0027/
2016-05-18 03:49:44,474 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0027_01_000005 is : 143
2016-05-18 03:49:44,683 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0027_01_000002 is : 143
2016-05-18 03:49:44,855 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0027_01_000003 is : 143
2016-05-18 03:49:45,147 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0027_01_000004 is : 143
2016-05-18 03:49:46,380 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2016-05-18 03:49:46,381 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:17.899, using cpu time: 00:04.710
2016-05-18 03:49:46,432 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2016-05-18 03:49:46,455 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:49:46,455 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 03:49:46,485 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 03:49:46,493 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:49:46,493 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 03:49:46,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:49:46,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:49:46,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:49:46,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join"]
2016-05-18 03:49:46,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:49:46,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 03:49:46,504 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 03:49:46,506 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2016-05-18 03:49:46,629 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0028
2016-05-18 03:49:46,630 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0028/
2016-05-18 03:50:04,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0028_01_000006 is : 143
2016-05-18 03:50:05,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0028_01_000002 is : 143
2016-05-18 03:50:05,229 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0028_01_000005 is : 143
2016-05-18 03:50:05,381 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0028_01_000003 is : 143
2016-05-18 03:50:05,580 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0028_01_000004 is : 143
2016-05-18 03:50:06,808 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2016-05-18 03:50:06,809 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.303, using cpu time: 00:05.660
2016-05-18 03:50:06,852 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2016-05-18 03:50:06,881 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:50:06,881 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 03:50:06,972 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.087
2016-05-18 03:50:06,973 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 03:50:06,973 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 03:50:07,041 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 03:50:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:50:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:50:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:50:07,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2016-05-18 03:50:07,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2016-05-18 03:50:07,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 03:50:07,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 3
2016-05-18 03:50:07,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 3
2016-05-18 03:50:07,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 03:50:07,207 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0029
2016-05-18 03:50:07,207 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0029/
2016-05-18 03:50:25,529 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0029_01_000006 is : 143
2016-05-18 03:50:25,913 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0029_01_000004 is : 143
2016-05-18 03:50:26,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0029_01_000003 is : 143
2016-05-18 03:50:26,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0029_01_000002 is : 143
2016-05-18 03:50:27,344 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/lhs
2016-05-18 03:50:27,344 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/rhs
2016-05-18 03:50:27,439 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-05-18 03:50:27,465 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(313)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-05-18 03:50:27,528 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0030
2016-05-18 03:50:27,528 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0030/
2016-05-18 03:50:27,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0031
2016-05-18 03:50:27,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0031/
2016-05-18 03:50:46,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0030_01_000004 is : 143
2016-05-18 03:50:47,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0030_01_000002 is : 143
2016-05-18 03:50:47,386 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0030_01_000005 is : 143
2016-05-18 03:50:47,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0030_01_000003 is : 143
2016-05-18 03:51:01,662 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0031_01_000006 is : 143
2016-05-18 03:51:02,036 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0031_01_000005 is : 143
2016-05-18 03:51:02,343 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0031_01_000003 is : 143
2016-05-18 03:51:03,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0030_01_000006 is : 143
2016-05-18 03:51:08,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0031_01_000007 is : 143
2016-05-18 03:51:10,048 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2016-05-18 03:51:10,050 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2016-05-18 03:51:10,052 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 01:03.003, using cpu time: 00:19.620
2016-05-18 03:51:10,084 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2016-05-18 03:51:10,088 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2016-05-18 03:51:10,108 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:10,109 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 03:51:10,167 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 03:51:10,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 03:51:10,169 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 03:51:10,187 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting
2016-05-18 03:51:10,187 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:51:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:51:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:51:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:51:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2016-05-18 03:51:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  parallel execution of steps is enabled: true
2016-05-18 03:51:10,189 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  executing total steps: 1
2016-05-18 03:51:10,189 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  allocating management threads: 1
2016-05-18 03:51:10,190 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2016-05-18 03:51:10,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] submitted hadoop job: job_1463542819959_0032
2016-05-18 03:51:10,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0032/
2016-05-18 03:51:31,447 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000003 is : 143
2016-05-18 03:51:31,915 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000005 is : 143
2016-05-18 03:51:32,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000002 is : 143
2016-05-18 03:51:32,049 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000004 is : 143
2016-05-18 03:51:32,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000006 is : 143
2016-05-18 03:51:32,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000007 is : 143
2016-05-18 03:51:38,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0032_01_000008 is : 143
2016-05-18 03:51:39,483 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2016-05-18 03:51:39,485 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [merging]  completed in: 00:29.295, using cpu time: 00:08.460
2016-05-18 03:51:39,515 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2016-05-18 03:51:39,533 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:39,533 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 03:51:39,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 03:51:39,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:51:39,574 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 03:51:39,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:51:39,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:51:39,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:51:39,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2016-05-18 03:51:39,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:51:39,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 03:51:39,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 03:51:39,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2016-05-18 03:51:39,726 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0033
2016-05-18 03:51:39,726 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0033/
2016-05-18 03:51:57,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0033_01_000006 is : 143
2016-05-18 03:51:57,567 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0033_01_000004 is : 143
2016-05-18 03:51:57,811 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0033_01_000003 is : 143
2016-05-18 03:51:58,115 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0033_01_000002 is : 143
2016-05-18 03:51:58,181 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0033_01_000005 is : 143
2016-05-18 03:51:59,418 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2016-05-18 03:51:59,419 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:19.832, using cpu time: 00:05.650
2016-05-18 03:51:59,461 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2016-05-18 03:51:59,488 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:51:59,488 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 03:51:59,524 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 03:51:59,525 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:51:59,526 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 03:51:59,536 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 03:51:59,537 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:51:59,537 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:51:59,537 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:51:59,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2016-05-18 03:51:59,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 03:51:59,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  executing total steps: 1
2016-05-18 03:51:59,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  allocating management threads: 1
2016-05-18 03:51:59,538 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2016-05-18 03:51:59,666 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463542819959_0034
2016-05-18 03:51:59,667 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0034/
2016-05-18 03:52:18,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0034_01_000003 is : 143
2016-05-18 03:52:18,341 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0034_01_000005 is : 143
2016-05-18 03:52:18,442 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0034_01_000002 is : 143
2016-05-18 03:52:18,783 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0034_01_000004 is : 143
2016-05-18 03:52:18,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0034_01_000006 is : 143
2016-05-18 03:52:20,111 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2016-05-18 03:52:20,112 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  completed in: 00:20.571, using cpu time: 00:05.850
2016-05-18 03:52:20,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2016-05-18 03:52:20,191 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:52:20,191 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 03:52:20,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 03:52:20,222 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 03:52:20,222 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 03:52:20,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:52:20,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:52:20,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:52:20,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone"]
2016-05-18 03:52:20,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:52:20,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 03:52:20,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 03:52:20,237 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-05-18 03:52:20,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0035
2016-05-18 03:52:20,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0035/
2016-05-18 03:52:38,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0035_01_000006 is : 143
2016-05-18 03:52:39,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0035_01_000004 is : 143
2016-05-18 03:52:39,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0035_01_000002 is : 143
2016-05-18 03:52:39,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0035_01_000003 is : 143
2016-05-18 03:52:39,191 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0035_01_000005 is : 143
2016-05-18 03:52:40,412 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-05-18 03:52:40,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.175, using cpu time: 00:05.730
2016-05-18 03:52:40,454 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2016-05-18 03:52:40,477 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:52:40,477 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 03:52:40,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 03:52:40,514 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:52:40,514 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 03:52:40,532 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:52:40,533 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:52:40,533 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:52:40,534 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself"]
2016-05-18 03:52:40,534 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:52:40,535 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 03:52:40,535 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 03:52:40,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 03:52:40,696 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0036
2016-05-18 03:52:40,696 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0036/
2016-05-18 03:52:59,021 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0036_01_000003 is : 143
2016-05-18 03:52:59,335 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0036_01_000005 is : 143
2016-05-18 03:52:59,458 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0036_01_000006 is : 143
2016-05-18 03:52:59,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0036_01_000002 is : 143
2016-05-18 03:53:00,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2016-05-18 03:53:00,989 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0037
2016-05-18 03:53:00,990 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0037/
2016-05-18 03:53:19,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0037_01_000006 is : 143
2016-05-18 03:53:19,585 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0037_01_000004 is : 143
2016-05-18 03:53:19,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0037_01_000005 is : 143
2016-05-18 03:53:19,710 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0037_01_000003 is : 143
2016-05-18 03:53:19,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0037_01_000002 is : 143
2016-05-18 03:53:21,147 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2016-05-18 03:53:21,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:40.610, using cpu time: 00:11.740
2016-05-18 03:53:21,189 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2016-05-18 03:53:21,218 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:53:21,219 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 03:53:21,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.129
2016-05-18 03:53:21,353 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 8
2016-05-18 03:53:21,353 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 03:53:21,424 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting
2016-05-18 03:53:21,424 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:53:21,425 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink"]
2016-05-18 03:53:21,425 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2"]
2016-05-18 03:53:21,426 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  parallel execution of steps is enabled: true
2016-05-18 03:53:21,427 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  executing total steps: 5
2016-05-18 03:53:21,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  allocating management threads: 5
2016-05-18 03:53:21,429 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (1/5)
2016-05-18 03:53:21,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (2/5)
2016-05-18 03:53:21,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463542819959_0038
2016-05-18 03:53:21,637 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0038/
2016-05-18 03:53:21,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463542819959_0039
2016-05-18 03:53:21,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0039/
2016-05-18 03:53:42,127 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0038_01_000003 is : 143
2016-05-18 03:53:42,509 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0038_01_000002 is : 143
2016-05-18 03:53:43,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0038_01_000004 is : 143
2016-05-18 03:53:43,568 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0038_01_000006 is : 143
2016-05-18 03:53:43,888 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0038_01_000005 is : 143
2016-05-18 03:53:57,432 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0039_01_000002 is : 143
2016-05-18 03:53:58,342 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0039_01_000005 is : 143
2016-05-18 03:53:58,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0039_01_000006 is : 143
2016-05-18 03:53:58,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0039_01_000004 is : 143
2016-05-18 03:53:58,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0039_01_000003 is : 143
2016-05-18 03:53:59,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0038_01_000007 is : 143
2016-05-18 03:54:00,772 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (3/5) ...undSplitGroupByJoin/sink2
2016-05-18 03:54:00,962 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463542819959_0040
2016-05-18 03:54:00,962 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0040/
2016-05-18 03:54:04,226 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0039_01_000007 is : 143
2016-05-18 03:54:05,439 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (4/5)
2016-05-18 03:54:05,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463542819959_0041
2016-05-18 03:54:05,589 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0041/
2016-05-18 03:54:18,808 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0040_01_000002 is : 143
2016-05-18 03:54:23,412 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0041_01_000002 is : 143
2016-05-18 03:54:30,072 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0041_01_000003 is : 143
2016-05-18 03:54:31,238 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] starting step: (5/5) ...oundSplitGroupByJoin/sink
2016-05-18 03:54:31,369 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] submitted hadoop job: job_1463542819959_0042
2016-05-18 03:54:31,369 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0042/
2016-05-18 03:54:42,276 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0042_01_000002 is : 143
2016-05-18 03:54:43,517 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2/_temporary
2016-05-18 03:54:43,520 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink/_temporary
2016-05-18 03:54:43,526 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [second*first*third]  completed in: 01:22.087, using cpu time: 00:17.470
2016-05-18 03:54:43,565 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink
2016-05-18 03:54:43,569 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitAroundSplitGroupByJoin/sink2
2016-05-18 03:54:43,588 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:54:43,588 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 03:54:43,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-05-18 03:54:43,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 03:54:43,645 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 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 03:54:43,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 3
2016-05-18 03:54:43,671 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 3
2016-05-18 03:54:43,673 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/3)
2016-05-18 03:54:43,810 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0043
2016-05-18 03:54:43,810 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0043/
2016-05-18 03:54:59,913 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0043_01_000003 is : 143
2016-05-18 03:55:00,199 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0043_01_000002 is : 143
2016-05-18 03:55:00,268 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0043_01_000004 is : 143
2016-05-18 03:55:00,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0043_01_000005 is : 143
2016-05-18 03:55:01,594 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/lhs
2016-05-18 03:55:01,594 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/rhs
2016-05-18 03:55:01,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0044
2016-05-18 03:55:01,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0044/
2016-05-18 03:55:01,793 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0045
2016-05-18 03:55:01,793 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0045/
2016-05-18 03:55:21,157 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0044_01_000005 is : 143
2016-05-18 03:55:21,277 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0044_01_000003 is : 143
2016-05-18 03:55:21,344 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0044_01_000004 is : 143
2016-05-18 03:55:21,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0044_01_000002 is : 143
2016-05-18 03:55:31,557 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0045_01_000002 is : 143
2016-05-18 03:55:31,902 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0045_01_000003 is : 143
2016-05-18 03:55:32,002 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0045_01_000005 is : 143
2016-05-18 03:55:32,232 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0045_01_000004 is : 143
2016-05-18 03:55:33,450 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2016-05-18 03:55:33,451 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2016-05-18 03:55:33,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:49.775, using cpu time: 00:15.210
2016-05-18 03:55:33,508 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2016-05-18 03:55:33,517 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2016-05-18 03:55:33,540 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:55:33,540 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 03:55:33,584 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 03:55:33,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:55:33,586 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 03:55:33,603 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting
2016-05-18 03:55:33,603 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:55:33,603 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:55:33,603 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:55:33,603 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2016-05-18 03:55:33,604 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  parallel execution of steps is enabled: true
2016-05-18 03:55:33,604 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  executing total steps: 2
2016-05-18 03:55:33,604 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  allocating management threads: 2
2016-05-18 03:55:33,605 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (1/2)
2016-05-18 03:55:33,737 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463542819959_0046
2016-05-18 03:55:33,737 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0046/
2016-05-18 03:55:52,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0046_01_000006 is : 143
2016-05-18 03:55:52,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0046_01_000003 is : 143
2016-05-18 03:55:52,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0046_01_000004 is : 143
2016-05-18 03:55:52,727 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0046_01_000002 is : 143
2016-05-18 03:55:53,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2016-05-18 03:55:54,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] submitted hadoop job: job_1463542819959_0047
2016-05-18 03:55:54,056 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0047/
2016-05-18 03:56:12,109 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0047_01_000006 is : 143
2016-05-18 03:56:12,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0047_01_000005 is : 143
2016-05-18 03:56:12,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0047_01_000004 is : 143
2016-05-18 03:56:12,692 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0047_01_000003 is : 143
2016-05-18 03:56:13,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0047_01_000002 is : 143
2016-05-18 03:56:14,316 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2016-05-18 03:56:14,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper2*lower*upper1]  completed in: 00:40.709, using cpu time: 00:12.370
2016-05-18 03:56:14,358 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2016-05-18 03:56:14,382 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:56:14,382 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 03:56:14,462 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-05-18 03:56:14,463 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 03:56:14,464 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 03:56:14,514 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting
2016-05-18 03:56:14,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:56:14,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:56:14,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join"]
2016-05-18 03:56:14,515 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  parallel execution of steps is enabled: true
2016-05-18 03:56:14,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  executing total steps: 4
2016-05-18 03:56:14,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  allocating management threads: 4
2016-05-18 03:56:14,519 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (1/4)
2016-05-18 03:56:14,521 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (2/4)
2016-05-18 03:56:14,701 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463542819959_0048
2016-05-18 03:56:14,701 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0048/
2016-05-18 03:56:14,713 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463542819959_0049
2016-05-18 03:56:14,713 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0049/
2016-05-18 03:56:36,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0048_01_000003 is : 143
2016-05-18 03:56:37,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0048_01_000002 is : 143
2016-05-18 03:56:37,484 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0048_01_000006 is : 143
2016-05-18 03:56:38,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0048_01_000004 is : 143
2016-05-18 03:56:38,334 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0048_01_000005 is : 143
2016-05-18 03:56:52,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0049_01_000003 is : 143
2016-05-18 03:56:53,459 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0049_01_000005 is : 143
2016-05-18 03:56:53,504 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0049_01_000006 is : 143
2016-05-18 03:56:53,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0049_01_000002 is : 143
2016-05-18 03:56:54,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0048_01_000007 is : 143
2016-05-18 03:56:58,329 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0049_01_000007 is : 143
2016-05-18 03:56:59,493 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (3/4)
2016-05-18 03:56:59,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463542819959_0050
2016-05-18 03:56:59,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0050/
2016-05-18 03:57:13,747 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0050_01_000002 is : 143
2016-05-18 03:57:13,799 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0050_01_000003 is : 143
2016-05-18 03:57:20,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0050_01_000004 is : 143
2016-05-18 03:57:21,341 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] starting step: (4/4) ...kCoGroupThenHashJoin/join
2016-05-18 03:57:21,465 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] submitted hadoop job: job_1463542819959_0051
2016-05-18 03:57:21,465 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0051/
2016-05-18 03:57:40,069 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0051_01_000006 is : 143
2016-05-18 03:57:40,313 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0051_01_000005 is : 143
2016-05-18 03:57:40,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0051_01_000004 is : 143
2016-05-18 03:57:40,809 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0051_01_000002 is : 143
2016-05-18 03:57:41,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0051_01_000003 is : 143
2016-05-18 03:57:42,390 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join/_temporary
2016-05-18 03:57:42,393 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [sourceLower*middleCoGroup]  completed in: 01:27.868, using cpu time: 00:31.150
2016-05-18 03:57:42,435 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkCoGroupThenHashJoin/join
2016-05-18 03:57:42,458 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:57:42,458 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 03:57:42,492 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 03:57:42,493 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 03:57:42,493 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 03:57:42,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:57:42,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:57:42,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join"]
2016-05-18 03:57:42,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:57:42,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 03:57:42,508 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 03:57:42,510 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 03:57:42,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0052
2016-05-18 03:57:42,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0052/
2016-05-18 03:58:00,955 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0052_01_000002 is : 143
2016-05-18 03:58:01,637 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0052_01_000003 is : 143
2016-05-18 03:58:01,719 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0052_01_000004 is : 143
2016-05-18 03:58:02,120 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0052_01_000005 is : 143
2016-05-18 03:58:02,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0052_01_000006 is : 143
2016-05-18 03:58:03,360 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...orm/testForkThenJoin/join
2016-05-18 03:58:03,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0053
2016-05-18 03:58:03,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0053/
2016-05-18 03:58:22,399 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0053_01_000003 is : 143
2016-05-18 03:58:22,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0053_01_000005 is : 143
2016-05-18 03:58:22,896 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0053_01_000002 is : 143
2016-05-18 03:58:23,006 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0053_01_000004 is : 143
2016-05-18 03:58:24,237 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join/_temporary
2016-05-18 03:58:24,239 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:41.725, using cpu time: 00:15.930
2016-05-18 03:58:24,280 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testForkThenJoin/join
2016-05-18 03:58:24,304 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:58:24,305 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 03:58:24,354 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-05-18 03:58:24,357 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 03:58:24,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 03:58:24,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 03:58:24,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:58:24,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:58:24,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2016-05-18 03:58:24,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 03:58:24,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 2
2016-05-18 03:58:24,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 2
2016-05-18 03:58:24,381 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/2)
2016-05-18 03:58:24,499 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0054
2016-05-18 03:58:24,500 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0054/
2016-05-18 03:58:42,522 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0054_01_000006 is : 143
2016-05-18 03:58:42,638 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0054_01_000003 is : 143
2016-05-18 03:58:42,700 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0054_01_000004 is : 143
2016-05-18 03:58:42,934 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0054_01_000005 is : 143
2016-05-18 03:58:43,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0054_01_000002 is : 143
2016-05-18 03:58:49,012 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0054_01_000007 is : 143
2016-05-18 03:58:50,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2016-05-18 03:58:50,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0055
2016-05-18 03:58:50,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0055/
2016-05-18 03:59:08,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0055_01_000002 is : 143
2016-05-18 03:59:09,115 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0055_01_000006 is : 143
2016-05-18 03:59:09,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0055_01_000004 is : 143
2016-05-18 03:59:09,939 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0055_01_000005 is : 143
2016-05-18 03:59:11,162 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2016-05-18 03:59:11,164 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:46.778, using cpu time: 00:12.730
2016-05-18 03:59:11,203 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2016-05-18 03:59:11,236 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 03:59:11,236 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 03:59:11,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 03:59:11,294 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-05-18 03:59:11,295 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 03:59:11,319 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting
2016-05-18 03:59:11,320 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 03:59:11,320 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:59:11,320 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.5.x/build/classes/test/data/upper.txt"]
2016-05-18 03:59:11,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2016-05-18 03:59:11,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 03:59:11,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  executing total steps: 3
2016-05-18 03:59:11,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  allocating management threads: 3
2016-05-18 03:59:11,324 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (1/3)
2016-05-18 03:59:11,463 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463542819959_0056
2016-05-18 03:59:11,463 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0056/
2016-05-18 03:59:29,485 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0056_01_000005 is : 143
2016-05-18 03:59:29,872 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0056_01_000003 is : 143
2016-05-18 03:59:29,918 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0056_01_000002 is : 143
2016-05-18 03:59:30,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0056_01_000006 is : 143
2016-05-18 03:59:30,237 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0056_01_000004 is : 143
2016-05-18 03:59:31,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (2/3)
2016-05-18 03:59:31,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463542819959_0057
2016-05-18 03:59:31,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0057/
2016-05-18 03:59:50,036 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0057_01_000005 is : 143
2016-05-18 03:59:50,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0057_01_000006 is : 143
2016-05-18 03:59:50,207 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0057_01_000004 is : 143
2016-05-18 03:59:50,420 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0057_01_000003 is : 143
2016-05-18 03:59:50,508 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0057_01_000002 is : 143
2016-05-18 03:59:51,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2016-05-18 03:59:51,851 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] submitted hadoop job: job_1463542819959_0058
2016-05-18 03:59:51,851 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0058/
2016-05-18 04:00:10,202 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0058_01_000006 is : 143
2016-05-18 04:00:10,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0058_01_000005 is : 143
2016-05-18 04:00:10,543 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0058_01_000002 is : 143
2016-05-18 04:00:10,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0058_01_000004 is : 143
2016-05-18 04:00:10,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0058_01_000003 is : 143
2016-05-18 04:00:12,091 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2016-05-18 04:00:12,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper1*upper2]  completed in: 01:00.765, using cpu time: 00:18.360
2016-05-18 04:00:12,133 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2016-05-18 04:00:12,158 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:00:12,158 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 04:00:12,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-05-18 04:00:12,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:00:12,237 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 04:00:12,257 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting
2016-05-18 04:00:12,257 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:00:12,257 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:00:12,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 04:00:12,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 04:00:12,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2016-05-18 04:00:12,258 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  parallel execution of steps is enabled: true
2016-05-18 04:00:12,259 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  executing total steps: 1
2016-05-18 04:00:12,259 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  allocating management threads: 1
2016-05-18 04:00:12,260 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2016-05-18 04:00:12,385 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] submitted hadoop job: job_1463542819959_0059
2016-05-18 04:00:12,385 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0059/
2016-05-18 04:00:32,894 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000003 is : 143
2016-05-18 04:00:33,341 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000004 is : 143
2016-05-18 04:00:33,395 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000002 is : 143
2016-05-18 04:00:33,548 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000005 is : 143
2016-05-18 04:00:33,592 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000006 is : 143
2016-05-18 04:00:33,872 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000007 is : 143
2016-05-18 04:00:39,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0059_01_000008 is : 143
2016-05-18 04:00:40,523 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2016-05-18 04:00:40,524 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [cogrouping]  completed in: 00:28.261, using cpu time: 00:08.480
2016-05-18 04:00:40,554 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2016-05-18 04:00:40,602 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:00:40,602 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 04:00:40,625 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 04:00:40,626 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:00:40,626 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 04:00:40,642 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:00:40,642 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.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:00:40,642 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.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:00:40,642 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.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner"]
2016-05-18 04:00:40,642 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 04:00:40,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 04:00:40,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 04:00:40,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2016-05-18 04:00:40,771 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0060
2016-05-18 04:00:40,771 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0060/
2016-05-18 04:00:58,842 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0060_01_000003 is : 143
2016-05-18 04:00:58,943 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0060_01_000002 is : 143
2016-05-18 04:00:59,064 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0060_01_000006 is : 143
2016-05-18 04:00:59,304 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0060_01_000005 is : 143
2016-05-18 04:00:59,373 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0060_01_000004 is : 143
2016-05-18 04:01:00,640 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2016-05-18 04:01:00,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:19.997, using cpu time: 00:05.580
2016-05-18 04:01:00,686 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2016-05-18 04:01:00,712 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:01:00,712 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 04:01:00,749 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 04:01:00,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-05-18 04:01:00,751 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 04:01:00,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting
2016-05-18 04:01:00,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/rhs.txt"]
2016-05-18 04:01:00,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-05-18 04:01:00,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2016-05-18 04:01:00,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2016-05-18 04:01:00,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  parallel execution of steps is enabled: true
2016-05-18 04:01:00,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  executing total steps: 2
2016-05-18 04:01:00,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  allocating management threads: 2
2016-05-18 04:01:00,773 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (2/2) ...latform/testJoinSplit/lhs
2016-05-18 04:01:00,773 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] starting step: (1/2) ...latform/testJoinSplit/rhs
2016-05-18 04:01:00,961 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0061
2016-05-18 04:01:00,961 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0061/
2016-05-18 04:01:00,968 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] submitted hadoop job: job_1463542819959_0062
2016-05-18 04:01:00,968 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0062/
2016-05-18 04:01:20,217 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0061_01_000002 is : 143
2016-05-18 04:01:20,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0061_01_000004 is : 143
2016-05-18 04:01:20,431 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0061_01_000005 is : 143
2016-05-18 04:01:20,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0061_01_000003 is : 143
2016-05-18 04:01:29,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0062_01_000002 is : 143
2016-05-18 04:01:30,116 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0062_01_000005 is : 143
2016-05-18 04:01:30,146 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0062_01_000004 is : 143
2016-05-18 04:01:30,998 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0062_01_000003 is : 143
2016-05-18 04:01:32,219 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2016-05-18 04:01:32,220 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2016-05-18 04:01:32,226 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - []  completed in: 00:31.448, using cpu time: 00:09.940
2016-05-18 04:01:32,293 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2016-05-18 04:01:32,302 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2016-05-18 04:01:32,323 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:01:32,323 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 04:01:32,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 04:01:32,370 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-05-18 04:01:32,370 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 04:01:32,388 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 04:01:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:01:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2016-05-18 04:01:32,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-05-18 04:01:32,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 2
2016-05-18 04:01:32,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 2
2016-05-18 04:01:32,392 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/2)
2016-05-18 04:01:32,711 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463542819959_0063
2016-05-18 04:01:32,711 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0063/
2016-05-18 04:01:50,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0063_01_000006 is : 143
2016-05-18 04:01:50,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0063_01_000003 is : 143
2016-05-18 04:01:50,881 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0063_01_000002 is : 143
2016-05-18 04:01:51,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0063_01_000004 is : 143
2016-05-18 04:01:51,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0063_01_000005 is : 143
2016-05-18 04:01:57,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0063_01_000007 is : 143
2016-05-18 04:01:58,238 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2016-05-18 04:01:58,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_1463542819959_0064
2016-05-18 04:01:58,375 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0064/
2016-05-18 04:02:16,482 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0064_01_000002 is : 143
2016-05-18 04:02:16,939 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0064_01_000003 is : 143
2016-05-18 04:02:17,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0064_01_000004 is : 143
2016-05-18 04:02:17,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0064_01_000006 is : 143
2016-05-18 04:02:17,386 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0064_01_000005 is : 143
2016-05-18 04:02:18,633 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2016-05-18 04:02:18,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:46.240, using cpu time: 00:12.670
2016-05-18 04:02:18,684 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2016-05-18 04:02:18,707 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:02:18,707 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 04:02:18,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 04:02:18,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-05-18 04:02:18,760 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 04:02:18,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting
2016-05-18 04:02:18,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:02:18,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:02:18,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2016-05-18 04:02:18,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-05-18 04:02:18,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  executing total steps: 3
2016-05-18 04:02:18,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  allocating management threads: 3
2016-05-18 04:02:18,794 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (1/3)
2016-05-18 04:02:18,796 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (2/3)
2016-05-18 04:02:18,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463542819959_0065
2016-05-18 04:02:18,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0065/
2016-05-18 04:02:19,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463542819959_0066
2016-05-18 04:02:19,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0066/
2016-05-18 04:02:40,067 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0065_01_000005 is : 143
2016-05-18 04:02:40,280 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0065_01_000003 is : 143
2016-05-18 04:02:40,436 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0065_01_000006 is : 143
2016-05-18 04:02:40,487 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0065_01_000002 is : 143
2016-05-18 04:02:40,663 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0065_01_000004 is : 143
2016-05-18 04:02:54,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0066_01_000004 is : 143
2016-05-18 04:02:54,757 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0066_01_000003 is : 143
2016-05-18 04:02:55,220 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0066_01_000005 is : 143
2016-05-18 04:02:55,237 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0066_01_000002 is : 143
2016-05-18 04:02:55,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0066_01_000006 is : 143
2016-05-18 04:02:56,495 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0065_01_000007 is : 143
2016-05-18 04:03:01,181 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0066_01_000007 is : 143
2016-05-18 04:03:02,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2016-05-18 04:03:02,518 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] submitted hadoop job: job_1463542819959_0067
2016-05-18 04:03:02,518 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0067/
2016-05-18 04:03:13,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0067_01_000002 is : 143
2016-05-18 04:03:15,086 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2016-05-18 04:03:15,090 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [upper1*upper2]  completed in: 00:56.295, using cpu time: 00:14.500
2016-05-18 04:03:15,118 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2016-05-18 04:03:15,163 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:03:15,163 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 04:03:15,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.031
2016-05-18 04:03:15,206 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 04:03:15,206 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2016-05-18 04:03:15,220 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:03:15,220 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 04:03:15,239 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 04:03:15,240 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:03:15,241 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 04:03:15,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 04:03:15,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:03:15,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2016-05-18 04:03:15,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  parallel execution of steps is enabled: true
2016-05-18 04:03:15,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  executing total steps: 1
2016-05-18 04:03:15,249 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  allocating management threads: 1
2016-05-18 04:03:15,249 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2016-05-18 04:03:15,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463542819959_0068
2016-05-18 04:03:15,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0068/
2016-05-18 04:03:33,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0068_01_000006 is : 143
2016-05-18 04:03:33,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0068_01_000003 is : 143
2016-05-18 04:03:33,846 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0068_01_000004 is : 143
2016-05-18 04:03:34,088 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0068_01_000002 is : 143
2016-05-18 04:03:35,318 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2016-05-18 04:03:35,319 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  completed in: 00:20.068, using cpu time: 00:05.170
2016-05-18 04:03:35,360 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2016-05-18 04:03:35,383 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:03:35,383 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 04:03:35,402 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 04:03:35,403 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:03:35,403 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 04:03:35,410 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting
2016-05-18 04:03:35,410 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:03:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2016-05-18 04:03:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  parallel execution of steps is enabled: true
2016-05-18 04:03:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  executing total steps: 1
2016-05-18 04:03:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  allocating management threads: 1
2016-05-18 04:03:35,412 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2016-05-18 04:03:35,535 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] submitted hadoop job: job_1463542819959_0069
2016-05-18 04:03:35,535 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0069/
2016-05-18 04:03:53,372 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0069_01_000006 is : 143
2016-05-18 04:03:54,035 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0069_01_000005 is : 143
2016-05-18 04:03:54,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0069_01_000004 is : 143
2016-05-18 04:03:54,195 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0069_01_000002 is : 143
2016-05-18 04:03:54,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0069_01_000003 is : 143
2016-05-18 04:03:55,656 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2016-05-18 04:03:55,657 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs]  completed in: 00:20.244, using cpu time: 00:05.200
2016-05-18 04:03:55,697 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2016-05-18 04:03:55,721 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:03:55,722 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 04:03:55,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 04:03:55,752 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:03:55,752 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 04:03:55,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:03:55,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:03:55,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:03:55,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2016-05-18 04:03:55,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 04:03:55,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 04:03:55,766 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 04:03:55,767 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2016-05-18 04:03:55,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0070
2016-05-18 04:03:55,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0070/
2016-05-18 04:04:13,936 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0070_01_000003 is : 143
2016-05-18 04:04:14,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0070_01_000002 is : 143
2016-05-18 04:04:14,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0070_01_000004 is : 143
2016-05-18 04:04:14,592 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0070_01_000005 is : 143
2016-05-18 04:04:14,625 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0070_01_000006 is : 143
2016-05-18 04:04:20,512 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0070_01_000007 is : 143
2016-05-18 04:04:21,737 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2016-05-18 04:04:21,738 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:25.970, using cpu time: 00:06.950
2016-05-18 04:04:21,768 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2016-05-18 04:04:21,786 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:04:21,786 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:04:21,850 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-18 04:04:21,851 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 6
2016-05-18 04:04:21,851 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 04:04:21,884 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting
2016-05-18 04:04:21,884 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.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:04:21,884 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink"]
2016-05-18 04:04:21,884 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  parallel execution of steps is enabled: true
2016-05-18 04:04:21,884 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  executing total steps: 4
2016-05-18 04:04:21,884 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  allocating management threads: 4
2016-05-18 04:04:21,887 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (1/4)
2016-05-18 04:04:22,016 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463542819959_0071
2016-05-18 04:04:22,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0071/
2016-05-18 04:04:39,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0071_01_000002 is : 143
2016-05-18 04:04:40,069 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0071_01_000003 is : 143
2016-05-18 04:04:40,296 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0071_01_000006 is : 143
2016-05-18 04:04:40,608 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0071_01_000004 is : 143
2016-05-18 04:04:40,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0071_01_000005 is : 143
2016-05-18 04:04:45,683 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0071_01_000007 is : 143
2016-05-18 04:04:46,866 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (2/4)
2016-05-18 04:04:46,996 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463542819959_0072
2016-05-18 04:04:46,996 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0072/
2016-05-18 04:04:57,541 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0072_01_000002 is : 143
2016-05-18 04:04:58,725 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (3/4)
2016-05-18 04:04:58,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463542819959_0073
2016-05-18 04:04:58,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0073/
2016-05-18 04:05:09,668 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0073_01_000002 is : 143
2016-05-18 04:05:16,267 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0073_01_000003 is : 143
2016-05-18 04:05:17,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] starting step: (4/4) ...plitSplitGroupByJoin/sink
2016-05-18 04:05:17,614 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] submitted hadoop job: job_1463542819959_0074
2016-05-18 04:05:17,615 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0074/
2016-05-18 04:05:28,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0074_01_000002 is : 143
2016-05-18 04:05:29,467 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink/_temporary
2016-05-18 04:05:29,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second*second]  completed in: 01:07.576, using cpu time: 00:10.530
2016-05-18 04:05:29,510 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitSplitGroupByJoin/sink
2016-05-18 04:05:29,526 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:05:29,526 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 04:05:29,546 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 04:05:29,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:05:29,548 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 04:05:29,555 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 04:05:29,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:05:29,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2016-05-18 04:05:29,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  parallel execution of steps is enabled: true
2016-05-18 04:05:29,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  executing total steps: 1
2016-05-18 04:05:29,557 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  allocating management threads: 1
2016-05-18 04:05:29,558 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2016-05-18 04:05:29,677 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted hadoop job: job_1463542819959_0075
2016-05-18 04:05:29,678 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0075/
2016-05-18 04:05:48,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0075_01_000004 is : 143
2016-05-18 04:05:48,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0075_01_000002 is : 143
2016-05-18 04:05:48,746 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0075_01_000006 is : 143
2016-05-18 04:05:48,779 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0075_01_000003 is : 143
2016-05-18 04:05:50,006 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2016-05-18 04:05:50,007 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower]  completed in: 00:20.449, using cpu time: 00:05.460
2016-05-18 04:05:50,064 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2016-05-18 04:05:50,087 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:05:50,087 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 04:05:50,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-05-18 04:05:50,149 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-05-18 04:05:50,150 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 04:05:50,185 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting
2016-05-18 04:05:50,186 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:05:50,186 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2016-05-18 04:05:50,186 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  parallel execution of steps is enabled: true
2016-05-18 04:05:50,186 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  executing total steps: 4
2016-05-18 04:05:50,187 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  allocating management threads: 4
2016-05-18 04:05:50,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (1/4)
2016-05-18 04:05:50,323 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463542819959_0076
2016-05-18 04:05:50,323 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0076/
2016-05-18 04:06:08,894 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0076_01_000002 is : 143
2016-05-18 04:06:09,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0076_01_000003 is : 143
2016-05-18 04:06:09,047 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0076_01_000006 is : 143
2016-05-18 04:06:09,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0076_01_000005 is : 143
2016-05-18 04:06:09,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0076_01_000004 is : 143
2016-05-18 04:06:15,733 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0076_01_000007 is : 143
2016-05-18 04:06:16,942 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (2/4)
2016-05-18 04:06:17,062 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463542819959_0077
2016-05-18 04:06:17,062 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0077/
2016-05-18 04:06:27,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0077_01_000002 is : 143
2016-05-18 04:06:34,462 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0077_01_000003 is : 143
2016-05-18 04:06:35,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (3/4)
2016-05-18 04:06:35,792 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463542819959_0078
2016-05-18 04:06:35,792 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0078/
2016-05-18 04:06:46,194 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0078_01_000002 is : 143
2016-05-18 04:06:52,500 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0078_01_000003 is : 143
2016-05-18 04:06:53,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2016-05-18 04:06:53,806 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] submitted hadoop job: job_1463542819959_0079
2016-05-18 04:06:53,806 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0079/
2016-05-18 04:07:04,598 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0079_01_000002 is : 143
2016-05-18 04:07:05,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2016-05-18 04:07:05,839 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [first*second]  completed in: 01:15.643, using cpu time: 00:12.140
2016-05-18 04:07:05,867 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2016-05-18 04:07:05,884 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:07:05,885 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 04:07:05,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 04:07:05,911 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:07:05,911 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 04:07:05,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:07:05,921 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.5.x/build/classes/test/data/rhs-sparse.txt"]
2016-05-18 04:07:05,922 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.5.x/build/classes/test/data/lhs-sparse.txt"]
2016-05-18 04:07:05,922 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.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2016-05-18 04:07:05,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 04:07:05,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 04:07:05,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 04:07:05,924 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2016-05-18 04:07:06,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0080
2016-05-18 04:07:06,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0080/
2016-05-18 04:07:24,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0080_01_000006 is : 143
2016-05-18 04:07:24,511 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0080_01_000005 is : 143
2016-05-18 04:07:24,613 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0080_01_000002 is : 143
2016-05-18 04:07:24,706 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0080_01_000004 is : 143
2016-05-18 04:07:24,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0080_01_000003 is : 143
2016-05-18 04:07:26,026 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2016-05-18 04:07:26,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:20.104, using cpu time: 00:05.950
2016-05-18 04:07:26,068 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2016-05-18 04:07:26,102 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:07:26,102 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 04:07:26,126 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 04:07:26,128 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:07:26,128 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 04:07:26,140 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:07:26,140 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-05-18 04:07:26,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-05-18 04:07:26,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2016-05-18 04:07:26,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: true
2016-05-18 04:07:26,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-18 04:07:26,142 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-18 04:07:26,143 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2016-05-18 04:07:26,267 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_1463542819959_0081
2016-05-18 04:07:26,267 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://ip-10-158-37-203:54555/proxy/application_1463542819959_0081/
2016-05-18 04:07:44,525 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0081_01_000006 is : 143
2016-05-18 04:07:44,943 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0081_01_000005 is : 143
2016-05-18 04:07:45,066 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0081_01_000003 is : 143
2016-05-18 04:07:45,194 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0081_01_000004 is : 143
2016-05-18 04:07:46,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1463542819959_0081_01_000002 is : 143
2016-05-18 04:07:47,434 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2016-05-18 04:07:47,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:21.292, using cpu time: 00:05.720
2016-05-18 04:07:47,481 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields

Standard error

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