Class cascading.JoinFieldedPipesPlatformTest

39

tests

0

failures

0

ignored

20m15.98s

duration

100%

successful

Tests

Test Duration Result
testCross 17.250s passed
testGroupBySplitGroupByJoin 1m13.63s passed
testGroupBySplitJoins 44.296s passed
testJoin 19.779s passed
testJoinAfterEvery 55.376s passed
testJoinAroundJoinLeftMost 40.335s passed
testJoinAroundJoinRightMost 19.924s passed
testJoinAroundJoinRightMostSwapped 39.838s passed
testJoinDiffFields 19.767s passed
testJoinFilteredBranch 44.941s passed
testJoinGroupBy 25.383s passed
testJoinGroupByJoin 37.137s passed
testJoinInner 19.603s passed
testJoinInnerOuter 19.947s passed
testJoinInnerSingleField 44.614s passed
testJoinMergeGroupBy 0.078s passed
testJoinMixed 0s passed
testJoinNone 20.225s passed
testJoinOuter 0s passed
testJoinOuterInner 0s passed
testJoinSamePipe 20.035s passed
testJoinSamePipe2 20.328s passed
testJoinSamePipe3 19.574s passed
testJoinSamePipeAroundGroupBy 44.945s passed
testJoinSamePipeName 19.682s passed
testJoinSameSourceIntoJoin 59.511s passed
testJoinSameSourceIntoJoinSimple 41.630s passed
testJoinSameSourceOverGroupByIntoJoinSimple 55.573s passed
testJoinSelf 40.711s passed
testJoinSplit 30.766s passed
testJoinSplitBeforeJoin 1m1.71s passed
testJoinWithHasher 20.409s passed
testJoinWithUnknowns 19.753s passed
testJoinsIntoCoGroup 27.834s passed
testJoinsIntoCoGroupLhs 45.131s passed
testJoinsIntoCoGroupLhsSwappedJoin 25.383s passed
testJoinsIntoCoGroupRhs 45.270s passed
testJoinsIntoGroupBy 26.560s passed
testSameSourceJoinSplitIntoJoin 49.049s passed

Standard output

2016-01-14 17:20:01,409 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 17:20:01,441 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2016-01-14 17:20:01,487 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2016-01-14 17:20:02,335 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-01-14 17:20:02,918 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 17:20:03,494 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:20:06,362 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 17:20:06,511 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 17:20:06,625 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 17:20:06,737 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(114)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 17:20:23,811 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 17:20:23,944 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:20:23,945 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:20:24,010 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5D28DB9725E8433ABD9D5E1B89F1B4AB
2016-01-14 17:20:24,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.111
2016-01-14 17:20:24,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:20:24,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:20:24,288 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 17:20:24,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:20:24,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:20:24,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 17:20:24,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2016-01-14 17:20:24,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:20:24,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:20:24,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:20:24,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2016-01-14 17:20:25,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0001
2016-01-14 17:20:25,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0001/
2016-01-14 17:20:43,940 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0001_01_000006 is : 143
2016-01-14 17:20:43,989 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0001_01_000004 is : 143
2016-01-14 17:20:44,151 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0001_01_000002 is : 143
2016-01-14 17:20:44,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0001_01_000005 is : 143
2016-01-14 17:20:44,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0001_01_000003 is : 143
2016-01-14 17:20:45,984 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2016-01-14 17:20:45,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:21.691, using cpu time: 00:05.410
2016-01-14 17:20:46,076 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2016-01-14 17:20:46,124 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:20:46,125 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:20:46,228 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-01-14 17:20:46,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 17:20:46,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:20:46,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2016-01-14 17:20:46,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:20:46,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:20:46,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2016-01-14 17:20:46,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-01-14 17:20:46,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  executing total steps: 2
2016-01-14 17:20:46,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  allocating management threads: 2
2016-01-14 17:20:46,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/2)
2016-01-14 17:20:46,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1452792018308_0002
2016-01-14 17:20:46,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0002/
2016-01-14 17:21:04,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0002_01_000002 is : 143
2016-01-14 17:21:04,404 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0002_01_000006 is : 143
2016-01-14 17:21:04,764 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0002_01_000004 is : 143
2016-01-14 17:21:04,815 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0002_01_000005 is : 143
2016-01-14 17:21:05,344 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0002_01_000003 is : 143
2016-01-14 17:21:06,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2016-01-14 17:21:06,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1452792018308_0003
2016-01-14 17:21:06,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0003/
2016-01-14 17:21:24,560 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0003_01_000003 is : 143
2016-01-14 17:21:24,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0003_01_000006 is : 143
2016-01-14 17:21:25,118 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0003_01_000002 is : 143
2016-01-14 17:21:25,335 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0003_01_000005 is : 143
2016-01-14 17:21:25,983 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0003_01_000004 is : 143
2016-01-14 17:21:27,658 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2016-01-14 17:21:27,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  completed in: 00:41.371, using cpu time: 00:11.480
2016-01-14 17:21:27,715 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2016-01-14 17:21:27,768 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:21:27,768 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:21:27,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2016-01-14 17:21:27,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 17:21:27,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:21:27,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting
2016-01-14 17:21:27,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:21:27,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:21:27,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:21:27,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2016-01-14 17:21:27,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  parallel execution of steps is enabled: true
2016-01-14 17:21:27,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  executing total steps: 2
2016-01-14 17:21:27,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  allocating management threads: 2
2016-01-14 17:21:27,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (1/2)
2016-01-14 17:21:28,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_1452792018308_0004
2016-01-14 17:21:28,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0004/
2016-01-14 17:21:45,722 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0004_01_000006 is : 143
2016-01-14 17:21:46,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0004_01_000002 is : 143
2016-01-14 17:21:46,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0004_01_000004 is : 143
2016-01-14 17:21:46,425 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0004_01_000003 is : 143
2016-01-14 17:21:46,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0004_01_000005 is : 143
2016-01-14 17:21:47,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2016-01-14 17:21:48,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_1452792018308_0005
2016-01-14 17:21:48,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0005/
2016-01-14 17:22:05,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0005_01_000003 is : 143
2016-01-14 17:22:06,137 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0005_01_000006 is : 143
2016-01-14 17:22:06,394 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0005_01_000004 is : 143
2016-01-14 17:22:06,485 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0005_01_000005 is : 143
2016-01-14 17:22:06,748 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0005_01_000002 is : 143
2016-01-14 17:22:07,995 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2016-01-14 17:22:07,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower]  completed in: 00:40.093, using cpu time: 00:11.930
2016-01-14 17:22:08,051 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2016-01-14 17:22:08,096 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:22:08,097 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:22:08,142 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 17:22:08,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:22:08,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:22:08,164 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2016-01-14 17:22:08,164 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:22:08,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:22:08,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2016-01-14 17:22:08,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  parallel execution of steps is enabled: true
2016-01-14 17:22:08,166 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  executing total steps: 1
2016-01-14 17:22:08,166 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  allocating management threads: 1
2016-01-14 17:22:08,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2016-01-14 17:22:08,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_1452792018308_0006
2016-01-14 17:22:08,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0006/
2016-01-14 17:22:25,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0006_01_000002 is : 143
2016-01-14 17:22:25,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0006_01_000003 is : 143
2016-01-14 17:22:25,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0006_01_000004 is : 143
2016-01-14 17:22:26,153 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0006_01_000005 is : 143
2016-01-14 17:22:26,436 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0006_01_000006 is : 143
2016-01-14 17:22:27,677 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2016-01-14 17:22:27,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  completed in: 00:19.511, using cpu time: 00:05.410
2016-01-14 17:22:27,731 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2016-01-14 17:22:27,766 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:22:27,766 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:22:27,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.118
2016-01-14 17:22:27,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 17:22:27,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:22:27,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:22:27,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:22:27,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:22:27,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2016-01-14 17:22:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:22:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2016-01-14 17:22:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2016-01-14 17:22:27,944 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2016-01-14 17:22:27,944 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2016-01-14 17:22:28,139 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0007
2016-01-14 17:22:28,139 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0007/
2016-01-14 17:22:28,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0008
2016-01-14 17:22:28,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0008/
2016-01-14 17:22:47,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0007_01_000003 is : 143
2016-01-14 17:22:48,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0007_01_000002 is : 143
2016-01-14 17:22:49,540 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0007_01_000005 is : 143
2016-01-14 17:22:49,596 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0007_01_000004 is : 143
2016-01-14 17:22:49,865 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0007_01_000006 is : 143
2016-01-14 17:23:02,999 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0008_01_000004 is : 143
2016-01-14 17:23:03,791 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0007_01_000007 is : 143
2016-01-14 17:23:03,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0008_01_000003 is : 143
2016-01-14 17:23:04,458 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0008_01_000006 is : 143
2016-01-14 17:23:04,844 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0008_01_000002 is : 143
2016-01-14 17:23:05,101 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0008_01_000005 is : 143
2016-01-14 17:23:09,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0008_01_000007 is : 143
2016-01-14 17:23:11,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2016-01-14 17:23:11,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0009
2016-01-14 17:23:11,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0009/
2016-01-14 17:23:21,855 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0009_01_000002 is : 143
2016-01-14 17:23:23,086 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2016-01-14 17:23:23,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:55.142, using cpu time: 00:13.710
2016-01-14 17:23:23,119 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2016-01-14 17:23:23,171 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:23:23,172 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:23:23,252 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.076
2016-01-14 17:23:23,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:23:23,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:23:23,284 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 17:23:23,284 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 1
2016-01-14 17:23:23,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 1
2016-01-14 17:23:23,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2016-01-14 17:23:23,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1452792018308_0010
2016-01-14 17:23:23,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0010/
2016-01-14 17:23:41,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0010_01_000003 is : 143
2016-01-14 17:23:41,448 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0010_01_000006 is : 143
2016-01-14 17:23:41,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0010_01_000002 is : 143
2016-01-14 17:23:41,592 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0010_01_000004 is : 143
2016-01-14 17:23:41,847 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0010_01_000005 is : 143
2016-01-14 17:23:47,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0010_01_000007 is : 143
2016-01-14 17:23:48,471 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2016-01-14 17:23:48,473 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 00:25.181, using cpu time: 00:06.940
2016-01-14 17:23:48,503 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2016-01-14 17:23:48,541 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:23:48,541 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:23:48,638 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-01-14 17:23:48,640 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2016-01-14 17:23:48,640 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:23:48,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2016-01-14 17:23:48,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:23:48,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:23:48,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 17:23:48,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2016-01-14 17:23:48,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2016-01-14 17:23:48,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  parallel execution of steps is enabled: true
2016-01-14 17:23:48,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  executing total steps: 3
2016-01-14 17:23:48,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  allocating management threads: 3
2016-01-14 17:23:48,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/3)
2016-01-14 17:23:48,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1452792018308_0011
2016-01-14 17:23:48,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0011/
2016-01-14 17:24:06,275 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0011_01_000002 is : 143
2016-01-14 17:24:06,434 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0011_01_000003 is : 143
2016-01-14 17:24:06,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0011_01_000004 is : 143
2016-01-14 17:24:06,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0011_01_000006 is : 143
2016-01-14 17:24:06,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0011_01_000005 is : 143
2016-01-14 17:24:12,856 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0011_01_000007 is : 143
2016-01-14 17:24:14,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/lhs
2016-01-14 17:24:14,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/rhs
2016-01-14 17:24:14,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1452792018308_0012
2016-01-14 17:24:14,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0012/
2016-01-14 17:24:14,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1452792018308_0013
2016-01-14 17:24:14,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0013/
2016-01-14 17:24:26,557 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0012_01_000002 is : 143
2016-01-14 17:24:31,501 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0013_01_000002 is : 143
2016-01-14 17:24:32,722 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2016-01-14 17:24:32,724 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2016-01-14 17:24:32,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  completed in: 00:44.041, using cpu time: 00:08.200
2016-01-14 17:24:32,794 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2016-01-14 17:24:32,799 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2016-01-14 17:24:32,822 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:24:32,823 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:24:32,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.108
2016-01-14 17:24:32,936 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 17:24:32,936 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:24:32,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 17:24:32,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:24:32,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:24:32,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:24:32,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:24:32,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2016-01-14 17:24:32,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2016-01-14 17:24:32,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 2
2016-01-14 17:24:32,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 2
2016-01-14 17:24:32,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2016-01-14 17:24:33,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1452792018308_0014
2016-01-14 17:24:33,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0014/
2016-01-14 17:24:50,697 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0014_01_000006 is : 143
2016-01-14 17:24:50,960 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0014_01_000002 is : 143
2016-01-14 17:24:51,183 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0014_01_000005 is : 143
2016-01-14 17:24:51,424 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0014_01_000003 is : 143
2016-01-14 17:24:51,751 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0014_01_000004 is : 143
2016-01-14 17:24:52,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2016-01-14 17:24:53,072 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1452792018308_0015
2016-01-14 17:24:53,072 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0015/
2016-01-14 17:25:10,441 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0015_01_000003 is : 143
2016-01-14 17:25:10,634 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0015_01_000002 is : 143
2016-01-14 17:25:10,980 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0015_01_000004 is : 143
2016-01-14 17:25:11,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0015_01_000005 is : 143
2016-01-14 17:25:11,525 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0015_01_000006 is : 143
2016-01-14 17:25:16,691 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0015_01_000007 is : 143
2016-01-14 17:25:17,900 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2016-01-14 17:25:17,902 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 00:44.909, using cpu time: 00:12.470
2016-01-14 17:25:17,932 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2016-01-14 17:25:17,954 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:25:17,954 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:25:18,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.088
2016-01-14 17:25:18,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 17:25:18,048 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:25:18,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 17:25:18,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:25:18,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:25:18,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:25:18,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:25:18,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2016-01-14 17:25:18,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2016-01-14 17:25:18,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 2
2016-01-14 17:25:18,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 2
2016-01-14 17:25:18,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2016-01-14 17:25:18,227 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1452792018308_0016
2016-01-14 17:25:18,228 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0016/
2016-01-14 17:25:36,042 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0016_01_000003 is : 143
2016-01-14 17:25:36,268 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0016_01_000002 is : 143
2016-01-14 17:25:36,275 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0016_01_000006 is : 143
2016-01-14 17:25:36,376 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0016_01_000004 is : 143
2016-01-14 17:25:36,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0016_01_000005 is : 143
2016-01-14 17:25:38,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2016-01-14 17:25:38,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1452792018308_0017
2016-01-14 17:25:38,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0017/
2016-01-14 17:25:55,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0017_01_000002 is : 143
2016-01-14 17:25:55,943 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0017_01_000003 is : 143
2016-01-14 17:25:56,069 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0017_01_000006 is : 143
2016-01-14 17:25:56,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0017_01_000005 is : 143
2016-01-14 17:25:56,518 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0017_01_000004 is : 143
2016-01-14 17:26:01,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0017_01_000007 is : 143
2016-01-14 17:26:03,170 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2016-01-14 17:26:03,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 00:45.085, using cpu time: 00:12.700
2016-01-14 17:26:03,203 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2016-01-14 17:26:03,324 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:26:03,324 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:26:03,356 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:26:03,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:26:03,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:26:03,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:26:03,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:26:03,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:26:03,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2016-01-14 17:26:03,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:26:03,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:26:03,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:26:03,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2016-01-14 17:26:03,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0018
2016-01-14 17:26:03,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0018/
2016-01-14 17:26:21,721 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0018_01_000002 is : 143
2016-01-14 17:26:21,916 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0018_01_000003 is : 143
2016-01-14 17:26:22,207 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0018_01_000005 is : 143
2016-01-14 17:26:22,233 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0018_01_000006 is : 143
2016-01-14 17:26:22,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0018_01_000004 is : 143
2016-01-14 17:26:23,562 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2016-01-14 17:26:23,563 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:20.187, using cpu time: 00:08.240
2016-01-14 17:26:23,605 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2016-01-14 17:26:23,631 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:26:23,631 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:26:23,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-14 17:26:23,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 17:26:23,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:26:23,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting
2016-01-14 17:26:23,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:26:23,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:26:23,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 17:26:23,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2016-01-14 17:26:23,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  parallel execution of steps is enabled: true
2016-01-14 17:26:23,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  executing total steps: 2
2016-01-14 17:26:23,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  allocating management threads: 2
2016-01-14 17:26:23,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (1/2)
2016-01-14 17:26:23,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_1452792018308_0019
2016-01-14 17:26:23,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0019/
2016-01-14 17:26:41,069 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0019_01_000003 is : 143
2016-01-14 17:26:41,272 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0019_01_000002 is : 143
2016-01-14 17:26:41,722 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0019_01_000004 is : 143
2016-01-14 17:26:41,898 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0019_01_000005 is : 143
2016-01-14 17:26:42,025 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0019_01_000006 is : 143
2016-01-14 17:26:47,698 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0019_01_000007 is : 143
2016-01-14 17:26:48,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2016-01-14 17:26:49,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_1452792018308_0020
2016-01-14 17:26:49,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0020/
2016-01-14 17:26:59,471 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0020_01_000002 is : 143
2016-01-14 17:27:00,714 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2016-01-14 17:27:00,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined]  completed in: 00:36.984, using cpu time: 00:07.570
2016-01-14 17:27:00,748 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2016-01-14 17:27:00,766 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:00,766 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:27:00,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 17:27:00,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:00,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:27:00,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-14 17:27:00,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:27:00,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:27:00,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross"]
2016-01-14 17:27:00,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-01-14 17:27:00,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 1
2016-01-14 17:27:00,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 1
2016-01-14 17:27:00,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2016-01-14 17:27:00,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1452792018308_0021
2016-01-14 17:27:00,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0021/
2016-01-14 17:27:16,471 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0021_01_000002 is : 143
2016-01-14 17:27:16,680 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0021_01_000005 is : 143
2016-01-14 17:27:16,723 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0021_01_000003 is : 143
2016-01-14 17:27:16,751 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0021_01_000004 is : 143
2016-01-14 17:27:17,950 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2016-01-14 17:27:17,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 00:17.142, using cpu time: 00:04.690
2016-01-14 17:27:17,992 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2016-01-14 17:27:18,024 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:18,025 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:27:18,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:27:18,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:18,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:27:18,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:27:18,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:27:18,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:27:18,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join"]
2016-01-14 17:27:18,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:27:18,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:27:18,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:27:18,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2016-01-14 17:27:18,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0022
2016-01-14 17:27:18,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0022/
2016-01-14 17:27:35,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0022_01_000006 is : 143
2016-01-14 17:27:35,839 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0022_01_000003 is : 143
2016-01-14 17:27:36,008 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0022_01_000002 is : 143
2016-01-14 17:27:36,457 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0022_01_000004 is : 143
2016-01-14 17:27:36,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0022_01_000005 is : 143
2016-01-14 17:27:37,728 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2016-01-14 17:27:37,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:19.661, using cpu time: 00:05.310
2016-01-14 17:27:37,771 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2016-01-14 17:27:37,796 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:37,797 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:27:37,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-14 17:27:37,881 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 17:27:37,882 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:27:37,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 17:27:37,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:27:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:27:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:27:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2016-01-14 17:27:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2016-01-14 17:27:37,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2016-01-14 17:27:37,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 3
2016-01-14 17:27:37,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 3
2016-01-14 17:27:37,923 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2016-01-14 17:27:38,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0023
2016-01-14 17:27:38,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0023/
2016-01-14 17:27:55,658 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0023_01_000005 is : 143
2016-01-14 17:27:55,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0023_01_000002 is : 143
2016-01-14 17:27:55,959 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0023_01_000003 is : 143
2016-01-14 17:27:56,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0023_01_000006 is : 143
2016-01-14 17:27:56,281 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0023_01_000004 is : 143
2016-01-14 17:27:57,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/rhs
2016-01-14 17:27:57,477 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/lhs
2016-01-14 17:27:57,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0024
2016-01-14 17:27:57,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0024/
2016-01-14 17:27:57,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0025
2016-01-14 17:27:57,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0025/
2016-01-14 17:28:18,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0024_01_000005 is : 143
2016-01-14 17:28:18,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0024_01_000004 is : 143
2016-01-14 17:28:19,053 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0024_01_000003 is : 143
2016-01-14 17:28:19,120 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0024_01_000002 is : 143
2016-01-14 17:28:19,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0024_01_000006 is : 143
2016-01-14 17:28:31,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0025_01_000003 is : 143
2016-01-14 17:28:32,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0025_01_000002 is : 143
2016-01-14 17:28:32,351 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0025_01_000004 is : 143
2016-01-14 17:28:32,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0024_01_000007 is : 143
2016-01-14 17:28:32,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0025_01_000005 is : 143
2016-01-14 17:28:38,214 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0025_01_000006 is : 143
2016-01-14 17:28:39,453 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2016-01-14 17:28:39,454 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2016-01-14 17:28:39,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 01:01.513, using cpu time: 00:18.760
2016-01-14 17:28:39,487 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2016-01-14 17:28:39,491 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2016-01-14 17:28:39,511 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:28:39,512 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:28:39,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-01-14 17:28:39,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:28:39,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:28:39,602 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting
2016-01-14 17:28:39,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:28:39,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:28:39,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:28:39,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:28:39,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2016-01-14 17:28:39,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  parallel execution of steps is enabled: true
2016-01-14 17:28:39,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  executing total steps: 1
2016-01-14 17:28:39,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  allocating management threads: 1
2016-01-14 17:28:39,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2016-01-14 17:28:39,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] submitted hadoop job: job_1452792018308_0026
2016-01-14 17:28:39,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0026/
2016-01-14 17:28:58,874 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000003 is : 143
2016-01-14 17:28:59,657 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000002 is : 143
2016-01-14 17:29:00,364 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000005 is : 143
2016-01-14 17:29:00,421 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000004 is : 143
2016-01-14 17:29:00,537 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000006 is : 143
2016-01-14 17:29:00,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000007 is : 143
2016-01-14 17:29:04,812 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0026_01_000008 is : 143
2016-01-14 17:29:06,016 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2016-01-14 17:29:06,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merging]  completed in: 00:26.412, using cpu time: 00:08.270
2016-01-14 17:29:06,051 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2016-01-14 17:29:06,077 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:29:06,078 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:29:06,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 17:29:06,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:29:06,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:29:06,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:29:06,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:29:06,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:29:06,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2016-01-14 17:29:06,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:29:06,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:29:06,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:29:06,122 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2016-01-14 17:29:06,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0027
2016-01-14 17:29:06,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0027/
2016-01-14 17:29:23,779 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0027_01_000002 is : 143
2016-01-14 17:29:24,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0027_01_000006 is : 143
2016-01-14 17:29:24,445 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0027_01_000005 is : 143
2016-01-14 17:29:24,519 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0027_01_000004 is : 143
2016-01-14 17:29:25,745 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2016-01-14 17:29:25,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:19.622, using cpu time: 00:05.540
2016-01-14 17:29:25,799 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2016-01-14 17:29:25,825 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:29:25,825 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:29:25,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 17:29:25,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:29:25,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:29:25,888 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2016-01-14 17:29:25,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:29:25,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:29:25,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:29:25,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2016-01-14 17:29:25,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-01-14 17:29:25,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  executing total steps: 1
2016-01-14 17:29:25,890 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  allocating management threads: 1
2016-01-14 17:29:25,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2016-01-14 17:29:26,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1452792018308_0028
2016-01-14 17:29:26,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0028/
2016-01-14 17:29:43,464 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0028_01_000003 is : 143
2016-01-14 17:29:43,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0028_01_000002 is : 143
2016-01-14 17:29:43,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0028_01_000004 is : 143
2016-01-14 17:29:43,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0028_01_000006 is : 143
2016-01-14 17:29:44,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0028_01_000005 is : 143
2016-01-14 17:29:45,682 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2016-01-14 17:29:45,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  completed in: 00:19.791, using cpu time: 00:05.720
2016-01-14 17:29:45,724 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2016-01-14 17:29:45,760 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:29:45,761 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:29:45,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 17:29:45,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:29:45,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:29:45,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:29:45,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:29:45,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:29:45,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone"]
2016-01-14 17:29:45,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:29:45,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:29:45,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:29:45,809 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2016-01-14 17:29:45,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0029
2016-01-14 17:29:45,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0029/
2016-01-14 17:30:03,660 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0029_01_000002 is : 143
2016-01-14 17:30:04,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0029_01_000003 is : 143
2016-01-14 17:30:04,116 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0029_01_000006 is : 143
2016-01-14 17:30:04,511 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0029_01_000004 is : 143
2016-01-14 17:30:04,652 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0029_01_000005 is : 143
2016-01-14 17:30:05,894 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2016-01-14 17:30:05,895 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:20.084, using cpu time: 00:05.600
2016-01-14 17:30:05,949 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2016-01-14 17:30:05,973 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:30:05,974 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:30:06,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 17:30:06,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 17:30:06,013 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:30:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:30:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:30:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:30:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself"]
2016-01-14 17:30:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:30:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 2
2016-01-14 17:30:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 2
2016-01-14 17:30:06,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2016-01-14 17:30:06,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0030
2016-01-14 17:30:06,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0030/
2016-01-14 17:30:23,686 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0030_01_000002 is : 143
2016-01-14 17:30:24,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0030_01_000003 is : 143
2016-01-14 17:30:24,086 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0030_01_000005 is : 143
2016-01-14 17:30:24,379 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0030_01_000004 is : 143
2016-01-14 17:30:25,622 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0030_01_000006 is : 143
2016-01-14 17:30:26,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2016-01-14 17:30:26,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0031
2016-01-14 17:30:26,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0031/
2016-01-14 17:30:44,688 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0031_01_000006 is : 143
2016-01-14 17:30:44,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0031_01_000005 is : 143
2016-01-14 17:30:44,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0031_01_000002 is : 143
2016-01-14 17:30:45,175 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0031_01_000004 is : 143
2016-01-14 17:30:45,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0031_01_000003 is : 143
2016-01-14 17:30:46,603 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2016-01-14 17:30:46,605 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:40.567, using cpu time: 00:11.450
2016-01-14 17:30:46,656 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2016-01-14 17:30:46,687 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:30:46,688 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:30:46,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-01-14 17:30:46,754 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 17:30:46,754 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:30:46,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 17:30:46,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:30:46,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:30:46,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:30:46,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2016-01-14 17:30:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2016-01-14 17:30:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2016-01-14 17:30:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 3
2016-01-14 17:30:46,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 3
2016-01-14 17:30:46,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2016-01-14 17:30:46,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0032
2016-01-14 17:30:46,913 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0032/
2016-01-14 17:31:02,677 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0032_01_000002 is : 143
2016-01-14 17:31:02,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0032_01_000003 is : 143
2016-01-14 17:31:02,890 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0032_01_000005 is : 143
2016-01-14 17:31:03,714 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0032_01_000004 is : 143
2016-01-14 17:31:04,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/lhs
2016-01-14 17:31:04,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/rhs
2016-01-14 17:31:05,018 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(309)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-14 17:31:05,035 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(309)) - Failed to place enough replicas, still in need of 1 to reach 4. For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2016-01-14 17:31:05,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0033
2016-01-14 17:31:05,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0033/
2016-01-14 17:31:05,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0034
2016-01-14 17:31:05,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0034/
2016-01-14 17:31:23,901 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0033_01_000003 is : 143
2016-01-14 17:31:24,362 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0033_01_000005 is : 143
2016-01-14 17:31:24,469 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0033_01_000002 is : 143
2016-01-14 17:31:24,631 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0033_01_000004 is : 143
2016-01-14 17:31:33,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0034_01_000002 is : 143
2016-01-14 17:31:34,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0034_01_000003 is : 143
2016-01-14 17:31:34,285 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0034_01_000005 is : 143
2016-01-14 17:31:34,400 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0034_01_000004 is : 143
2016-01-14 17:31:35,653 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2016-01-14 17:31:35,655 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2016-01-14 17:31:35,659 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 00:48.865, using cpu time: 00:14.450
2016-01-14 17:31:35,702 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2016-01-14 17:31:35,712 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2016-01-14 17:31:35,735 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:31:35,735 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:31:35,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 17:31:35,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 17:31:35,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:31:35,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting
2016-01-14 17:31:35,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:31:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:31:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:31:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2016-01-14 17:31:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  parallel execution of steps is enabled: true
2016-01-14 17:31:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  executing total steps: 2
2016-01-14 17:31:35,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  allocating management threads: 2
2016-01-14 17:31:35,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (1/2)
2016-01-14 17:31:35,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_1452792018308_0035
2016-01-14 17:31:35,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0035/
2016-01-14 17:31:53,611 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0035_01_000004 is : 143
2016-01-14 17:31:53,734 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0035_01_000002 is : 143
2016-01-14 17:31:53,898 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0035_01_000003 is : 143
2016-01-14 17:31:54,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0035_01_000006 is : 143
2016-01-14 17:31:54,308 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0035_01_000005 is : 143
2016-01-14 17:31:55,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2016-01-14 17:31:55,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_1452792018308_0036
2016-01-14 17:31:55,637 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0036/
2016-01-14 17:32:13,518 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0036_01_000004 is : 143
2016-01-14 17:32:13,612 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0036_01_000002 is : 143
2016-01-14 17:32:14,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0036_01_000005 is : 143
2016-01-14 17:32:14,250 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0036_01_000006 is : 143
2016-01-14 17:32:14,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0036_01_000003 is : 143
2016-01-14 17:32:15,505 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2016-01-14 17:32:15,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1]  completed in: 00:39.698, using cpu time: 00:12.030
2016-01-14 17:32:15,548 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2016-01-14 17:32:15,575 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:32:15,576 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:32:15,620 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 17:32:15,623 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 17:32:15,624 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:32:15,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:32:15,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:32:15,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:32:15,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2016-01-14 17:32:15,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:32:15,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 2
2016-01-14 17:32:15,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 2
2016-01-14 17:32:15,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2016-01-14 17:32:15,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0037
2016-01-14 17:32:15,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0037/
2016-01-14 17:32:32,775 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0037_01_000002 is : 143
2016-01-14 17:32:33,645 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0037_01_000006 is : 143
2016-01-14 17:32:33,659 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0037_01_000003 is : 143
2016-01-14 17:32:33,750 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0037_01_000004 is : 143
2016-01-14 17:32:34,014 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0037_01_000005 is : 143
2016-01-14 17:32:39,450 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0037_01_000007 is : 143
2016-01-14 17:32:40,615 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2016-01-14 17:32:40,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0038
2016-01-14 17:32:40,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0038/
2016-01-14 17:32:58,210 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0038_01_000003 is : 143
2016-01-14 17:32:58,544 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0038_01_000006 is : 143
2016-01-14 17:32:58,946 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0038_01_000002 is : 143
2016-01-14 17:32:59,123 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0038_01_000004 is : 143
2016-01-14 17:32:59,204 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0038_01_000005 is : 143
2016-01-14 17:33:00,448 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2016-01-14 17:33:00,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:44.789, using cpu time: 00:11.880
2016-01-14 17:33:00,491 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2016-01-14 17:33:00,514 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:33:00,515 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:33:00,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-01-14 17:33:00,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2016-01-14 17:33:00,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:33:00,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2016-01-14 17:33:00,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:33:00,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:33:00,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:33:00,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2016-01-14 17:33:00,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2016-01-14 17:33:00,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  executing total steps: 3
2016-01-14 17:33:00,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  allocating management threads: 3
2016-01-14 17:33:00,617 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/3)
2016-01-14 17:33:00,775 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1452792018308_0039
2016-01-14 17:33:00,775 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0039/
2016-01-14 17:33:18,483 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0039_01_000002 is : 143
2016-01-14 17:33:18,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0039_01_000006 is : 143
2016-01-14 17:33:18,684 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0039_01_000003 is : 143
2016-01-14 17:33:18,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0039_01_000004 is : 143
2016-01-14 17:33:19,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0039_01_000005 is : 143
2016-01-14 17:33:20,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/3)
2016-01-14 17:33:20,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1452792018308_0040
2016-01-14 17:33:20,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0040/
2016-01-14 17:33:38,608 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0040_01_000003 is : 143
2016-01-14 17:33:38,641 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0040_01_000005 is : 143
2016-01-14 17:33:38,709 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0040_01_000004 is : 143
2016-01-14 17:33:38,979 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0040_01_000006 is : 143
2016-01-14 17:33:40,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2016-01-14 17:33:40,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1452792018308_0041
2016-01-14 17:33:40,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0041/
2016-01-14 17:33:57,424 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0041_01_000002 is : 143
2016-01-14 17:33:58,110 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0041_01_000003 is : 143
2016-01-14 17:33:58,343 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0041_01_000004 is : 143
2016-01-14 17:33:58,577 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0041_01_000005 is : 143
2016-01-14 17:33:58,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0041_01_000006 is : 143
2016-01-14 17:33:59,951 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2016-01-14 17:33:59,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  completed in: 00:59.331, using cpu time: 00:17.610
2016-01-14 17:34:00,000 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2016-01-14 17:34:00,035 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:34:00,035 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:34:00,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-01-14 17:34:00,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:34:00,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:34:00,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2016-01-14 17:34:00,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:34:00,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:34:00,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:34:00,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:34:00,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2016-01-14 17:34:00,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  parallel execution of steps is enabled: true
2016-01-14 17:34:00,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  executing total steps: 1
2016-01-14 17:34:00,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  allocating management threads: 1
2016-01-14 17:34:00,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2016-01-14 17:34:00,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1452792018308_0042
2016-01-14 17:34:00,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0042/
2016-01-14 17:34:19,769 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000003 is : 143
2016-01-14 17:34:20,067 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000002 is : 143
2016-01-14 17:34:21,033 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000005 is : 143
2016-01-14 17:34:21,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000004 is : 143
2016-01-14 17:34:21,273 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000006 is : 143
2016-01-14 17:34:21,312 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000007 is : 143
2016-01-14 17:34:26,601 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0042_01_000008 is : 143
2016-01-14 17:34:27,809 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2016-01-14 17:34:27,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping]  completed in: 00:27.659, using cpu time: 00:08.420
2016-01-14 17:34:27,841 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2016-01-14 17:34:27,890 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:34:27,890 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:34:27,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 17:34:27,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:34:27,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:34:27,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:34:27,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-14 17:34:27,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-14 17:34:27,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner"]
2016-01-14 17:34:27,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:34:27,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:34:27,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:34:27,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2016-01-14 17:34:28,071 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0043
2016-01-14 17:34:28,071 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0043/
2016-01-14 17:34:45,154 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0043_01_000004 is : 143
2016-01-14 17:34:45,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0043_01_000006 is : 143
2016-01-14 17:34:45,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0043_01_000005 is : 143
2016-01-14 17:34:45,964 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0043_01_000003 is : 143
2016-01-14 17:34:46,162 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0043_01_000002 is : 143
2016-01-14 17:34:47,399 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2016-01-14 17:34:47,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:19.463, using cpu time: 00:05.460
2016-01-14 17:34:47,441 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2016-01-14 17:34:47,465 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:34:47,466 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:34:47,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 17:34:47,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2016-01-14 17:34:47,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:34:47,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2016-01-14 17:34:47,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs.txt"]
2016-01-14 17:34:47,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 17:34:47,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2016-01-14 17:34:47,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2016-01-14 17:34:47,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  parallel execution of steps is enabled: true
2016-01-14 17:34:47,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  executing total steps: 2
2016-01-14 17:34:47,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  allocating management threads: 2
2016-01-14 17:34:47,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...latform/testJoinSplit/lhs
2016-01-14 17:34:47,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...latform/testJoinSplit/rhs
2016-01-14 17:34:47,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0044
2016-01-14 17:34:47,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0044/
2016-01-14 17:34:47,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1452792018308_0045
2016-01-14 17:34:47,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0045/
2016-01-14 17:35:05,340 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0044_01_000003 is : 143
2016-01-14 17:35:06,601 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0044_01_000004 is : 143
2016-01-14 17:35:06,928 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0044_01_000002 is : 143
2016-01-14 17:35:07,051 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0044_01_000005 is : 143
2016-01-14 17:35:16,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0045_01_000005 is : 143
2016-01-14 17:35:16,568 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0045_01_000004 is : 143
2016-01-14 17:35:16,831 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0045_01_000003 is : 143
2016-01-14 17:35:16,897 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0045_01_000002 is : 143
2016-01-14 17:35:18,133 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2016-01-14 17:35:18,134 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2016-01-14 17:35:18,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - []  completed in: 00:30.600, using cpu time: 00:09.240
2016-01-14 17:35:18,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2016-01-14 17:35:18,206 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2016-01-14 17:35:18,234 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:35:18,235 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:35:18,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 17:35:18,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2016-01-14 17:35:18,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:35:18,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-14 17:35:18,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:35:18,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2016-01-14 17:35:18,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-01-14 17:35:18,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 2
2016-01-14 17:35:18,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 2
2016-01-14 17:35:18,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/2)
2016-01-14 17:35:18,429 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1452792018308_0046
2016-01-14 17:35:18,429 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0046/
2016-01-14 17:35:35,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0046_01_000003 is : 143
2016-01-14 17:35:35,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0046_01_000002 is : 143
2016-01-14 17:35:36,307 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0046_01_000006 is : 143
2016-01-14 17:35:36,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0046_01_000004 is : 143
2016-01-14 17:35:36,535 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0046_01_000005 is : 143
2016-01-14 17:35:42,007 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0046_01_000007 is : 143
2016-01-14 17:35:43,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2016-01-14 17:35:43,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1452792018308_0047
2016-01-14 17:35:43,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0047/
2016-01-14 17:36:01,538 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0047_01_000003 is : 143
2016-01-14 17:36:01,580 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0047_01_000002 is : 143
2016-01-14 17:36:01,684 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0047_01_000006 is : 143
2016-01-14 17:36:01,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0047_01_000004 is : 143
2016-01-14 17:36:03,098 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2016-01-14 17:36:03,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 00:44.784, using cpu time: 00:11.970
2016-01-14 17:36:03,152 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2016-01-14 17:36:03,178 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:36:03,178 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:36:03,229 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 17:36:03,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2016-01-14 17:36:03,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:36:03,261 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2016-01-14 17:36:03,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:36:03,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:36:03,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2016-01-14 17:36:03,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  parallel execution of steps is enabled: true
2016-01-14 17:36:03,263 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  executing total steps: 3
2016-01-14 17:36:03,263 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  allocating management threads: 3
2016-01-14 17:36:03,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/3)
2016-01-14 17:36:03,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/3)
2016-01-14 17:36:03,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1452792018308_0048
2016-01-14 17:36:03,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0048/
2016-01-14 17:36:03,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1452792018308_0049
2016-01-14 17:36:03,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0049/
2016-01-14 17:36:23,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0048_01_000006 is : 143
2016-01-14 17:36:23,873 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0048_01_000005 is : 143
2016-01-14 17:36:24,431 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0048_01_000004 is : 143
2016-01-14 17:36:24,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0048_01_000002 is : 143
2016-01-14 17:36:24,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0048_01_000003 is : 143
2016-01-14 17:36:37,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0049_01_000003 is : 143
2016-01-14 17:36:38,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0049_01_000002 is : 143
2016-01-14 17:36:38,997 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0049_01_000006 is : 143
2016-01-14 17:36:39,064 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0049_01_000004 is : 143
2016-01-14 17:36:39,380 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0049_01_000005 is : 143
2016-01-14 17:36:39,832 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0048_01_000007 is : 143
2016-01-14 17:36:43,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0049_01_000007 is : 143
2016-01-14 17:36:45,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2016-01-14 17:36:45,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1452792018308_0050
2016-01-14 17:36:45,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0050/
2016-01-14 17:36:57,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0050_01_000002 is : 143
2016-01-14 17:36:58,687 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2016-01-14 17:36:58,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2]  completed in: 00:55.419, using cpu time: 00:13.720
2016-01-14 17:36:58,732 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2016-01-14 17:36:58,777 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:36:58,777 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:36:58,813 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.033
2016-01-14 17:36:58,814 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:36:58,814 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2016-01-14 17:36:58,827 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:36:58,827 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:36:58,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:36:58,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:36:58,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:36:58,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-14 17:36:58,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:36:58,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2016-01-14 17:36:58,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2016-01-14 17:36:58,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2016-01-14 17:36:58,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2016-01-14 17:36:58,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2016-01-14 17:36:58,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452792018308_0051
2016-01-14 17:36:58,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0051/
2016-01-14 17:37:16,794 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0051_01_000006 is : 143
2016-01-14 17:37:17,088 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0051_01_000004 is : 143
2016-01-14 17:37:17,280 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0051_01_000002 is : 143
2016-01-14 17:37:17,531 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0051_01_000003 is : 143
2016-01-14 17:37:17,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0051_01_000005 is : 143
2016-01-14 17:37:19,091 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2016-01-14 17:37:19,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 00:20.226, using cpu time: 00:05.230
2016-01-14 17:37:19,134 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2016-01-14 17:37:19,156 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:37:19,156 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:37:19,174 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:37:19,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:37:19,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:37:19,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2016-01-14 17:37:19,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:37:19,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2016-01-14 17:37:19,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  parallel execution of steps is enabled: true
2016-01-14 17:37:19,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  executing total steps: 1
2016-01-14 17:37:19,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  allocating management threads: 1
2016-01-14 17:37:19,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2016-01-14 17:37:19,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_1452792018308_0052
2016-01-14 17:37:19,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0052/
2016-01-14 17:37:36,497 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0052_01_000006 is : 143
2016-01-14 17:37:37,011 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0052_01_000002 is : 143
2016-01-14 17:37:37,118 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0052_01_000004 is : 143
2016-01-14 17:37:37,305 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0052_01_000005 is : 143
2016-01-14 17:37:37,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0052_01_000003 is : 143
2016-01-14 17:37:38,665 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2016-01-14 17:37:38,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  completed in: 00:19.477, using cpu time: 00:05.110
2016-01-14 17:37:38,706 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2016-01-14 17:37:38,730 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:37:38,731 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:37:38,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 17:37:38,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 17:37:38,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:37:38,776 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:37:38,777 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:37:38,777 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:37:38,777 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2016-01-14 17:37:38,777 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:37:38,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:37:38,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:37:38,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2016-01-14 17:37:38,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0053
2016-01-14 17:37:38,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0053/
2016-01-14 17:37:56,527 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0053_01_000003 is : 143
2016-01-14 17:37:56,595 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0053_01_000002 is : 143
2016-01-14 17:37:57,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0053_01_000006 is : 143
2016-01-14 17:37:57,205 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0053_01_000005 is : 143
2016-01-14 17:37:57,476 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0053_01_000004 is : 143
2016-01-14 17:38:02,835 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0053_01_000007 is : 143
2016-01-14 17:38:04,066 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2016-01-14 17:38:04,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:25.287, using cpu time: 00:06.580
2016-01-14 17:38:04,096 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2016-01-14 17:38:04,113 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:38:04,113 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:38:04,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 17:38:04,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:38:04,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:38:04,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2016-01-14 17:38:04,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:38:04,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2016-01-14 17:38:04,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2016-01-14 17:38:04,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2016-01-14 17:38:04,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2016-01-14 17:38:04,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2016-01-14 17:38:04,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1452792018308_0054
2016-01-14 17:38:04,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0054/
2016-01-14 17:38:21,852 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0054_01_000003 is : 143
2016-01-14 17:38:22,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0054_01_000004 is : 143
2016-01-14 17:38:22,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0054_01_000006 is : 143
2016-01-14 17:38:22,589 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0054_01_000005 is : 143
2016-01-14 17:38:22,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0054_01_000002 is : 143
2016-01-14 17:38:24,084 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2016-01-14 17:38:24,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 00:19.925, using cpu time: 00:05.240
2016-01-14 17:38:24,125 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2016-01-14 17:38:24,149 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:38:24,149 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:38:24,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-01-14 17:38:24,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 7
2016-01-14 17:38:24,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:38:24,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting
2016-01-14 17:38:24,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:38:24,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink"]
2016-01-14 17:38:24,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  parallel execution of steps is enabled: true
2016-01-14 17:38:24,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  executing total steps: 4
2016-01-14 17:38:24,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  allocating management threads: 4
2016-01-14 17:38:24,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (1/4)
2016-01-14 17:38:24,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1452792018308_0055
2016-01-14 17:38:24,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0055/
2016-01-14 17:38:41,395 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0055_01_000002 is : 143
2016-01-14 17:38:41,714 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0055_01_000003 is : 143
2016-01-14 17:38:41,815 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0055_01_000005 is : 143
2016-01-14 17:38:42,303 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0055_01_000004 is : 143
2016-01-14 17:38:42,368 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0055_01_000006 is : 143
2016-01-14 17:38:47,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0055_01_000007 is : 143
2016-01-14 17:38:49,130 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (2/4)
2016-01-14 17:38:49,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1452792018308_0056
2016-01-14 17:38:49,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0056/
2016-01-14 17:38:59,970 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0056_01_000002 is : 143
2016-01-14 17:39:06,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0056_01_000003 is : 143
2016-01-14 17:39:07,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (3/4)
2016-01-14 17:39:07,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1452792018308_0057
2016-01-14 17:39:07,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0057/
2016-01-14 17:39:18,059 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0057_01_000002 is : 143
2016-01-14 17:39:24,639 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0057_01_000003 is : 143
2016-01-14 17:39:25,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] starting step: (4/4) ...upBySplitGroupByJoin/sink
2016-01-14 17:39:25,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] submitted hadoop job: job_1452792018308_0058
2016-01-14 17:39:25,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0058/
2016-01-14 17:39:36,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0058_01_000002 is : 143
2016-01-14 17:39:37,727 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink/_temporary
2016-01-14 17:39:37,730 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first*second]  completed in: 01:13.438, using cpu time: 00:10.650
2016-01-14 17:39:37,758 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitGroupByJoin/sink
2016-01-14 17:39:37,775 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:39:37,775 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:39:37,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 17:39:37,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:39:37,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:39:37,810 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:39:37,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/rhs-sparse.txt"]
2016-01-14 17:39:37,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs-sparse.txt"]
2016-01-14 17:39:37,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2016-01-14 17:39:37,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:39:37,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:39:37,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:39:37,812 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2016-01-14 17:39:37,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0059
2016-01-14 17:39:37,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0059/
2016-01-14 17:39:55,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0059_01_000006 is : 143
2016-01-14 17:39:55,876 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0059_01_000003 is : 143
2016-01-14 17:39:55,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0059_01_000002 is : 143
2016-01-14 17:39:56,155 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0059_01_000005 is : 143
2016-01-14 17:39:56,420 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0059_01_000004 is : 143
2016-01-14 17:39:57,656 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2016-01-14 17:39:57,658 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:19.844, using cpu time: 00:05.730
2016-01-14 17:39:57,699 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2016-01-14 17:39:57,722 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:39:57,722 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 17:39:57,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 17:39:57,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:39:57,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:39:57,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 17:39:57,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 17:39:57,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 17:39:57,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2016-01-14 17:39:57,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2016-01-14 17:39:57,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 17:39:57,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 17:39:57,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2016-01-14 17:39:57,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1452792018308_0060
2016-01-14 17:39:57,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://ip-10-167-78-165.ec2.internal:57507/proxy/application_1452792018308_0060/
2016-01-14 17:40:15,082 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0060_01_000006 is : 143
2016-01-14 17:40:15,640 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0060_01_000002 is : 143
2016-01-14 17:40:15,785 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0060_01_000005 is : 143
2016-01-14 17:40:15,848 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0060_01_000003 is : 143
2016-01-14 17:40:16,190 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452792018308_0060_01_000004 is : 143
2016-01-14 17:40:17,422 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2016-01-14 17:40:17,423 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:19.663, using cpu time: 00:05.500
2016-01-14 17:40:17,465 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields

Standard error

Jan 14, 2016 5:20:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jan 14, 2016 5:20:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:20:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:20:18 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:20:18 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Jan 14, 2016 5:20:19 PM 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.
Jan 14, 2016 5:20:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:20:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jan 14, 2016 5:20:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:20:19 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:20:19 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:20 PM 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.
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:20:20 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:20 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:21 PM 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.
Jan 14, 2016 5:20:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 5:20:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:20:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:20:21 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:20:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:21 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:22 PM 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.
Jan 14, 2016 5:20:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 5:20:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:20:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:20:22 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:20:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:22 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:23 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:20:23 PM 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.