Class cascading.BasicPipesPlatformTest

16

tests

0

failures

0

ignored

8.703s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 0.381s passed
testCoGroupRelativeUnknown 0.580s passed
testCount 0.650s passed
testCount2 0.342s passed
testCount3 0.297s passed
testCount4 0.323s passed
testFilter 0.192s passed
testFilterAll 0.271s passed
testReplace 0.226s passed
testSimple 0.260s passed
testSimpleChain 3.261s passed
testSimpleRelative 0.525s passed
testSimpleRelativeUnknown 0.263s passed
testSimpleResult 0.542s passed
testSwap 0.280s passed
testUnGroup 0.310s passed

Standard output

2016-01-15 00:44:41,388 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 00:44:41,418 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop2-mr1
2016-01-15 00:44:41,453 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-15 00:44:42,241 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-15 00:44:42,405 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-15 00:44:42,556 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:42,559 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-15 00:44:42,662 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 1F8C572827BD4A0D9EE8236ED8EE8287
2016-01-15 00:44:42,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.163
2016-01-15 00:44:42,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-15 00:44:42,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:43,064 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 00:44:43,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:43,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:43,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-15 00:44:43,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:43,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2016-01-15 00:44:43,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:43,071 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-15 00:44:43,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1557318476_0001
2016-01-15 00:44:43,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:43,903 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:44,054 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:44,054 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:44,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C923113F22E54A2498DFC7E87230D0F9, ordinal: 0
2016-01-15 00:44:44,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:44,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:44,110 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C923113F22E54A2498DFC7E87230D0F9, mem on start (mb), free: 67, total: 223, max: 672
2016-01-15 00:44:44,119 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C923113F22E54A2498DFC7E87230D0F9, mem on close (mb), free: 66, total: 223, max: 672
2016-01-15 00:44:44,248 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:44,249 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:44,259 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B64578E8A6C6483A86348AC097FBE357, ordinal: 1
2016-01-15 00:44:44,263 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:44,263 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][4751202803/test/]
2016-01-15 00:44:44,263 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B64578E8A6C6483A86348AC097FBE357, mem on start (mb), free: 111, total: 223, max: 672
2016-01-15 00:44:44,291 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B64578E8A6C6483A86348AC097FBE357, mem on close (mb), free: 110, total: 223, max: 672
2016-01-15 00:44:44,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2016-01-15 00:44:44,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1856894398_0002
2016-01-15 00:44:44,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:44,484 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/4751202803_test_35816A5905C14B3B88E5A6789489D158/part-00000
2016-01-15 00:44:44,596 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:44,596 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:44,606 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C7942C62FC964DD7B71A51FF8C142F38, ordinal: 0
2016-01-15 00:44:44,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][4751202803/test/]
2016-01-15 00:44:44,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:44,607 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7942C62FC964DD7B71A51FF8C142F38, mem on start (mb), free: 77, total: 323, max: 672
2016-01-15 00:44:44,609 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7942C62FC964DD7B71A51FF8C142F38, mem on close (mb), free: 77, total: 323, max: 672
2016-01-15 00:44:44,625 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:44,625 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:44,635 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E7351F6956DE4C7A96F2D5946BD6D73B, ordinal: 1
2016-01-15 00:44:44,635 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:44,636 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-15 00:44:44,636 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7351F6956DE4C7A96F2D5946BD6D73B, mem on start (mb), free: 75, total: 323, max: 672
2016-01-15 00:44:44,644 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7351F6956DE4C7A96F2D5946BD6D73B, mem on close (mb), free: 74, total: 323, max: 672
2016-01-15 00:44:44,673 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleChain/simplechain/_temporary
2016-01-15 00:44:44,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:01.604
2016-01-15 00:44:44,710 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleChain/simplechain
2016-01-15 00:44:44,746 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:44,747 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-15 00:44:44,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-15 00:44:44,810 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:44,810 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:44,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-15 00:44:44,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:44,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount/count"]
2016-01-15 00:44:44,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-15 00:44:44,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-15 00:44:44,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-15 00:44:44,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...splatform/testCount/count
2016-01-15 00:44:45,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local1724841424_0003
2016-01-15 00:44:45,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-15 00:44:45,111 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt
2016-01-15 00:44:45,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:45,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:45,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA23F1E3056F46C1BD27E298FBDA0B80, ordinal: 0
2016-01-15 00:44:45,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:45,226 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:45,226 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA23F1E3056F46C1BD27E298FBDA0B80, mem on start (mb), free: 144, total: 482, max: 672
2016-01-15 00:44:45,229 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA23F1E3056F46C1BD27E298FBDA0B80, mem on close (mb), free: 144, total: 482, max: 672
2016-01-15 00:44:45,254 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:45,254 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:45,264 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B4A7A854C91D4CEF81EF134DE02B2540, ordinal: 1
2016-01-15 00:44:45,264 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:45,265 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount/count"]
2016-01-15 00:44:45,265 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B4A7A854C91D4CEF81EF134DE02B2540, mem on start (mb), free: 140, total: 482, max: 672
2016-01-15 00:44:45,274 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B4A7A854C91D4CEF81EF134DE02B2540, mem on close (mb), free: 139, total: 482, max: 672
2016-01-15 00:44:45,301 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount/count/_temporary
2016-01-15 00:44:45,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.470
2016-01-15 00:44:45,363 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount/count
2016-01-15 00:44:45,383 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:45,384 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-15 00:44:45,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-15 00:44:45,427 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:44:45,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:45,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:45,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:45,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSwap/swap"]
2016-01-15 00:44:45,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:45,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:45,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:45,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-15 00:44:45,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1674736454_0004
2016-01-15 00:44:45,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:45,571 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:45,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:45,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:45,586 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E93C7EDA7A9D4944BF31C8AA407FE013, ordinal: 0
2016-01-15 00:44:45,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:45,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSwap/swap"]
2016-01-15 00:44:45,588 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E93C7EDA7A9D4944BF31C8AA407FE013, mem on start (mb), free: 80, total: 482, max: 672
2016-01-15 00:44:45,590 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E93C7EDA7A9D4944BF31C8AA407FE013, mem on close (mb), free: 80, total: 482, max: 672
2016-01-15 00:44:45,611 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSwap/swap/_temporary
2016-01-15 00:44:45,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.171
2016-01-15 00:44:45,644 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSwap/swap
2016-01-15 00:44:45,666 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:45,667 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-15 00:44:45,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-15 00:44:45,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:44:45,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:45,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:45,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2016-01-15 00:44:45,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-15 00:44:45,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:45,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:45,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:45,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-15 00:44:45,880 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local647208228_0005
2016-01-15 00:44:45,882 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:45,889 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower+upper.txt
2016-01-15 00:44:45,895 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:45,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:45,904 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AC33520A400E48E6B4D5856F83DB58AE, ordinal: 0
2016-01-15 00:44:45,905 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2016-01-15 00:44:45,905 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-15 00:44:45,906 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC33520A400E48E6B4D5856F83DB58AE, mem on start (mb), free: 146, total: 482, max: 672
2016-01-15 00:44:45,908 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC33520A400E48E6B4D5856F83DB58AE, mem on close (mb), free: 146, total: 482, max: 672
2016-01-15 00:44:45,927 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testUnGroup/ungrouped/_temporary
2016-01-15 00:44:45,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.193
2016-01-15 00:44:45,953 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testUnGroup/ungrouped
2016-01-15 00:44:45,972 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:45,972 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-15 00:44:46,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-15 00:44:46,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:46,025 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-15 00:44:46,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 00:44:46,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-01-15 00:44:46,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:46,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-15 00:44:46,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: false
2016-01-15 00:44:46,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-15 00:44:46,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-15 00:44:46,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2016-01-15 00:44:46,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local1482062366_0006
2016-01-15 00:44:46,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-15 00:44:46,170 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt
2016-01-15 00:44:46,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:46,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:46,280 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC3DB24AA13C4478AA86E9B72211CA32, ordinal: 0
2016-01-15 00:44:46,281 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-01-15 00:44:46,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-15 00:44:46,282 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC3DB24AA13C4478AA86E9B72211CA32, mem on start (mb), free: 94, total: 583, max: 672
2016-01-15 00:44:46,284 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC3DB24AA13C4478AA86E9B72211CA32, mem on close (mb), free: 94, total: 583, max: 672
2016-01-15 00:44:46,292 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt
2016-01-15 00:44:46,392 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:46,393 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:46,401 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC3DB24AA13C4478AA86E9B72211CA32, ordinal: 0
2016-01-15 00:44:46,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:46,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-15 00:44:46,403 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC3DB24AA13C4478AA86E9B72211CA32, mem on start (mb), free: 41, total: 630, max: 672
2016-01-15 00:44:46,405 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC3DB24AA13C4478AA86E9B72211CA32, mem on close (mb), free: 41, total: 630, max: 672
2016-01-15 00:44:46,423 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:46,423 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:46,430 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E38060BD1E2745D7AC60A2923A021A28, ordinal: 1
2016-01-15 00:44:46,430 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-15 00:44:46,431 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-15 00:44:46,431 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E38060BD1E2745D7AC60A2923A021A28, mem on start (mb), free: 37, total: 630, max: 672
2016-01-15 00:44:46,441 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-15 00:44:46,441 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-15 00:44:46,448 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E38060BD1E2745D7AC60A2923A021A28, mem on close (mb), free: 35, total: 630, max: 672
2016-01-15 00:44:46,470 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2016-01-15 00:44:46,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:00.413
2016-01-15 00:44:46,534 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2016-01-15 00:44:46,554 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:46,555 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-15 00:44:46,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-15 00:44:46,602 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:46,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:46,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:46,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-15 00:44:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:46,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:46,637 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...leRelative/simplerelative
2016-01-15 00:44:46,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local242086434_0007
2016-01-15 00:44:46,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:46,956 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:46,973 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:46,973 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:46,980 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EAE34D15FC184259978BFA92B9E1E707, ordinal: 0
2016-01-15 00:44:46,981 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:46,981 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:46,981 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EAE34D15FC184259978BFA92B9E1E707, mem on start (mb), free: 106, total: 241, max: 672
2016-01-15 00:44:46,984 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EAE34D15FC184259978BFA92B9E1E707, mem on close (mb), free: 106, total: 241, max: 672
2016-01-15 00:44:46,997 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:46,997 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:47,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B45A34B641914C2EB9D9D693733BC3E3, ordinal: 1
2016-01-15 00:44:47,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:47,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-15 00:44:47,006 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B45A34B641914C2EB9D9D693733BC3E3, mem on start (mb), free: 102, total: 241, max: 672
2016-01-15 00:44:47,014 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B45A34B641914C2EB9D9D693733BC3E3, mem on close (mb), free: 100, total: 241, max: 672
2016-01-15 00:44:47,031 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2016-01-15 00:44:47,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.396
2016-01-15 00:44:47,060 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleRelative/simplerelative
2016-01-15 00:44:47,169 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:47,169 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-15 00:44:47,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-15 00:44:47,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:47,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:47,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:47,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:47,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-15 00:44:47,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:47,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:47,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:47,239 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2016-01-15 00:44:47,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1354517220_0008
2016-01-15 00:44:47,338 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:47,343 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt
2016-01-15 00:44:47,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:47,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:47,452 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B1560A22852A457D84548B981BACFBDF, ordinal: 0
2016-01-15 00:44:47,453 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:47,453 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:47,453 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1560A22852A457D84548B981BACFBDF, mem on start (mb), free: 44, total: 341, max: 672
2016-01-15 00:44:47,527 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1560A22852A457D84548B981BACFBDF, mem on close (mb), free: 40, total: 341, max: 672
2016-01-15 00:44:47,541 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:47,541 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:47,548 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E977976854C64F1BAB66A0CEC7741DBA, ordinal: 1
2016-01-15 00:44:47,549 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:47,549 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-15 00:44:47,549 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E977976854C64F1BAB66A0CEC7741DBA, mem on start (mb), free: 36, total: 341, max: 672
2016-01-15 00:44:47,556 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E977976854C64F1BAB66A0CEC7741DBA, mem on close (mb), free: 35, total: 341, max: 672
2016-01-15 00:44:47,577 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2016-01-15 00:44:47,578 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.340
2016-01-15 00:44:47,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult
2016-01-15 00:44:47,616 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:47,617 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-15 00:44:47,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 00:44:47,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:44:47,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:47,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:47,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:47,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilterAll/filterall"]
2016-01-15 00:44:47,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:47,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:47,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:47,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-01-15 00:44:47,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local667686503_0009
2016-01-15 00:44:47,809 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:47,814 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:47,819 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:47,819 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:47,825 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA2523DE09894EEF9A303A18608CB64A, ordinal: 0
2016-01-15 00:44:47,825 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:47,826 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilterAll/filterall"]
2016-01-15 00:44:47,826 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA2523DE09894EEF9A303A18608CB64A, mem on start (mb), free: 256, total: 299, max: 672
2016-01-15 00:44:47,828 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA2523DE09894EEF9A303A18608CB64A, mem on close (mb), free: 256, total: 299, max: 672
2016-01-15 00:44:47,843 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilterAll/filterall/_temporary
2016-01-15 00:44:47,844 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.188
2016-01-15 00:44:47,873 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testFilterAll/filterall
2016-01-15 00:44:47,889 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:47,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-15 00:44:47,923 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 00:44:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:47,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:47,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:47,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:47,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-15 00:44:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:47,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:47,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2016-01-15 00:44:48,034 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local72054609_0010
2016-01-15 00:44:48,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:48,039 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt
2016-01-15 00:44:48,053 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:48,053 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,061 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A08BB19CA55A4A6289979427EB6E3C8F, ordinal: 0
2016-01-15 00:44:48,061 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:48,062 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2016-01-15 00:44:48,062 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A08BB19CA55A4A6289979427EB6E3C8F, mem on start (mb), free: 106, total: 299, max: 672
2016-01-15 00:44:48,063 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A08BB19CA55A4A6289979427EB6E3C8F, mem on close (mb), free: 106, total: 299, max: 672
2016-01-15 00:44:48,077 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:48,077 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,083 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F073FEB46EF248BC9E3F39AE07F8CC43, ordinal: 1
2016-01-15 00:44:48,083 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2016-01-15 00:44:48,084 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-15 00:44:48,084 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F073FEB46EF248BC9E3F39AE07F8CC43, mem on start (mb), free: 102, total: 299, max: 672
2016-01-15 00:44:48,090 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F073FEB46EF248BC9E3F39AE07F8CC43, mem on close (mb), free: 101, total: 299, max: 672
2016-01-15 00:44:48,111 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2016-01-15 00:44:48,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.173
2016-01-15 00:44:48,136 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2016-01-15 00:44:48,152 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:48,152 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-15 00:44:48,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-15 00:44:48,199 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:48,200 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-15 00:44:48,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 00:44:48,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-01-15 00:44:48,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:48,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-15 00:44:48,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: false
2016-01-15 00:44:48,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-15 00:44:48,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-15 00:44:48,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2016-01-15 00:44:48,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local1846576302_0011
2016-01-15 00:44:48,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-15 00:44:48,324 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt
2016-01-15 00:44:48,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:48,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,346 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1417042158F4C4684640991806D3E30, ordinal: 0
2016-01-15 00:44:48,347 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 00:44:48,347 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-15 00:44:48,347 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1417042158F4C4684640991806D3E30, mem on start (mb), free: 94, total: 329, max: 672
2016-01-15 00:44:48,349 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1417042158F4C4684640991806D3E30, mem on close (mb), free: 94, total: 329, max: 672
2016-01-15 00:44:48,355 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt
2016-01-15 00:44:48,405 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:48,406 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,413 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1417042158F4C4684640991806D3E30, ordinal: 0
2016-01-15 00:44:48,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-01-15 00:44:48,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-15 00:44:48,414 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1417042158F4C4684640991806D3E30, mem on start (mb), free: 93, total: 430, max: 672
2016-01-15 00:44:48,416 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1417042158F4C4684640991806D3E30, mem on close (mb), free: 93, total: 430, max: 672
2016-01-15 00:44:48,430 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:48,430 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,436 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A9AFD1632C1E4765A7DB115BAEE9F599, ordinal: 1
2016-01-15 00:44:48,437 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-15 00:44:48,437 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-15 00:44:48,438 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A9AFD1632C1E4765A7DB115BAEE9F599, mem on start (mb), free: 86, total: 430, max: 672
2016-01-15 00:44:48,443 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-15 00:44:48,443 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-15 00:44:48,446 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A9AFD1632C1E4765A7DB115BAEE9F599, mem on close (mb), free: 86, total: 430, max: 672
2016-01-15 00:44:48,460 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2016-01-15 00:44:48,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:00.245
2016-01-15 00:44:48,517 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup
2016-01-15 00:44:48,537 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:48,538 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-15 00:44:48,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 00:44:48,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:44:48,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:48,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:48,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:48,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testReplace/replace"]
2016-01-15 00:44:48,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:48,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:48,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:48,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-15 00:44:48,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local645959228_0012
2016-01-15 00:44:48,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:48,678 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:48,683 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:48,683 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,691 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA271A292A3B49249D44A432FEC4DBBB, ordinal: 0
2016-01-15 00:44:48,692 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:48,692 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testReplace/replace"]
2016-01-15 00:44:48,692 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA271A292A3B49249D44A432FEC4DBBB, mem on start (mb), free: 225, total: 477, max: 672
2016-01-15 00:44:48,696 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA271A292A3B49249D44A432FEC4DBBB, mem on close (mb), free: 225, total: 477, max: 672
2016-01-15 00:44:48,718 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testReplace/replace/_temporary
2016-01-15 00:44:48,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.142
2016-01-15 00:44:48,743 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testReplace/replace
2016-01-15 00:44:48,757 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:48,757 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-15 00:44:48,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-15 00:44:48,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:48,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:48,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-15 00:44:48,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:48,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount2/count2"]
2016-01-15 00:44:48,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-15 00:44:48,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-15 00:44:48,819 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-15 00:44:48,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount2/count2
2016-01-15 00:44:48,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local898042306_0013
2016-01-15 00:44:48,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-15 00:44:48,917 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt
2016-01-15 00:44:48,971 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:48,972 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:48,976 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D2D3DA0D2E7F453D96CFC084559623F0, ordinal: 0
2016-01-15 00:44:48,977 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:48,979 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:48,979 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2D3DA0D2E7F453D96CFC084559623F0, mem on start (mb), free: 69, total: 477, max: 672
2016-01-15 00:44:48,981 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2D3DA0D2E7F453D96CFC084559623F0, mem on close (mb), free: 69, total: 477, max: 672
2016-01-15 00:44:48,996 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:48,996 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:49,002 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D578ADF4310E42429D7F43A6F2B05D41, ordinal: 1
2016-01-15 00:44:49,003 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:49,003 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount2/count2"]
2016-01-15 00:44:49,004 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D578ADF4310E42429D7F43A6F2B05D41, mem on start (mb), free: 62, total: 477, max: 672
2016-01-15 00:44:49,020 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D578ADF4310E42429D7F43A6F2B05D41, mem on close (mb), free: 286, total: 502, max: 672
2016-01-15 00:44:49,041 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount2/count2/_temporary
2016-01-15 00:44:49,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.223
2016-01-15 00:44:49,086 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount2/count2
2016-01-15 00:44:49,100 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:49,101 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-15 00:44:49,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-15 00:44:49,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:49,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:49,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-15 00:44:49,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:49,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount3/count3"]
2016-01-15 00:44:49,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-15 00:44:49,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-15 00:44:49,151 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-15 00:44:49,151 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount3/count3
2016-01-15 00:44:49,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local2138986573_0014
2016-01-15 00:44:49,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-15 00:44:49,263 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt
2016-01-15 00:44:49,278 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:49,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:49,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4E4A65C106A447EA64B058819B3D31E, ordinal: 0
2016-01-15 00:44:49,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:49,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:49,285 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4E4A65C106A447EA64B058819B3D31E, mem on start (mb), free: 125, total: 502, max: 672
2016-01-15 00:44:49,289 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4E4A65C106A447EA64B058819B3D31E, mem on close (mb), free: 125, total: 502, max: 672
2016-01-15 00:44:49,306 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:49,306 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:49,312 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FCDCFC983EC94D5ABD5906D09EAF97DC, ordinal: 1
2016-01-15 00:44:49,312 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:49,312 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount3/count3"]
2016-01-15 00:44:49,313 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FCDCFC983EC94D5ABD5906D09EAF97DC, mem on start (mb), free: 119, total: 502, max: 672
2016-01-15 00:44:49,321 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FCDCFC983EC94D5ABD5906D09EAF97DC, mem on close (mb), free: 118, total: 502, max: 672
2016-01-15 00:44:49,335 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount3/count3/_temporary
2016-01-15 00:44:49,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.186
2016-01-15 00:44:49,384 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount3/count3
2016-01-15 00:44:49,401 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:49,401 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-15 00:44:49,431 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-15 00:44:49,432 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:49,432 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:49,448 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-15 00:44:49,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:49,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount4/count4"]
2016-01-15 00:44:49,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-15 00:44:49,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-15 00:44:49,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-15 00:44:49,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount4/count4
2016-01-15 00:44:49,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local1125022461_0015
2016-01-15 00:44:49,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-15 00:44:49,574 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt
2016-01-15 00:44:49,589 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:49,589 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:49,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC20E48679934635BA9E976C142F57ED, ordinal: 0
2016-01-15 00:44:49,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2016-01-15 00:44:49,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:49,595 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC20E48679934635BA9E976C142F57ED, mem on start (mb), free: 175, total: 503, max: 672
2016-01-15 00:44:49,598 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC20E48679934635BA9E976C142F57ED, mem on close (mb), free: 175, total: 503, max: 672
2016-01-15 00:44:49,620 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:49,620 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:49,628 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B44626634D58425B9DCFD0BFB7A02193, ordinal: 1
2016-01-15 00:44:49,628 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-15 00:44:49,628 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount4/count4"]
2016-01-15 00:44:49,629 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B44626634D58425B9DCFD0BFB7A02193, mem on start (mb), free: 169, total: 503, max: 672
2016-01-15 00:44:49,637 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B44626634D58425B9DCFD0BFB7A02193, mem on close (mb), free: 168, total: 503, max: 672
2016-01-15 00:44:49,660 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount4/count4/_temporary
2016-01-15 00:44:49,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.212
2016-01-15 00:44:49,707 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount4/count4
2016-01-15 00:44:49,721 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:49,721 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-15 00:44:49,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 00:44:49,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:44:49,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:49,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:49,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:49,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilter/filter"]
2016-01-15 00:44:49,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:49,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:49,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:49,754 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-15 00:44:49,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1488055304_0016
2016-01-15 00:44:49,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:49,847 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:49,852 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:49,852 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:49,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BFEE5C75C33B45709DBC48CFD8C42A2A, ordinal: 0
2016-01-15 00:44:49,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:49,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilter/filter"]
2016-01-15 00:44:49,857 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFEE5C75C33B45709DBC48CFD8C42A2A, mem on start (mb), free: 107, total: 503, max: 672
2016-01-15 00:44:49,858 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFEE5C75C33B45709DBC48CFD8C42A2A, mem on close (mb), free: 107, total: 503, max: 672
2016-01-15 00:44:49,877 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilter/filter/_temporary
2016-01-15 00:44:49,877 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.126
2016-01-15 00:44:49,899 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testFilter/filter
2016-01-15 00:44:49,916 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:44:49,917 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-15 00:44:49,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-15 00:44:49,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 00:44:49,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:44:49,968 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 00:44:49,968 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:49,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimple/simple"]
2016-01-15 00:44:49,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-15 00:44:49,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-15 00:44:49,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-15 00:44:49,970 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testSimple/simple
2016-01-15 00:44:50,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local814161563_0017
2016-01-15 00:44:50,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 00:44:50,074 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt
2016-01-15 00:44:50,088 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:44:50,089 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:44:50,094 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7B4B4CF133B4E38A8C1ABEE28332640, ordinal: 0
2016-01-15 00:44:50,094 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/apache.10.txt"]
2016-01-15 00:44:50,094 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:50,095 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7B4B4CF133B4E38A8C1ABEE28332640, mem on start (mb), free: 178, total: 511, max: 672
2016-01-15 00:44:50,097 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7B4B4CF133B4E38A8C1ABEE28332640, mem on close (mb), free: 178, total: 511, max: 672
2016-01-15 00:44:50,109 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 00:44:50,109 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 00:44:50,114 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EA55CC371677433C9EF66C52D7C415D7, ordinal: 1
2016-01-15 00:44:50,115 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-15 00:44:50,115 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimple/simple"]
2016-01-15 00:44:50,115 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EA55CC371677433C9EF66C52D7C415D7, mem on start (mb), free: 172, total: 511, max: 672
2016-01-15 00:44:50,123 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EA55CC371677433C9EF66C52D7C415D7, mem on close (mb), free: 171, total: 511, max: 672
2016-01-15 00:44:50,136 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimple/simple/_temporary
2016-01-15 00:44:50,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.168
2016-01-15 00:44:50,160 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimple/simple