Class cascading.BasicPipesPlatformTest

16

tests

0

failures

0

ignored

6.010s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 0.390s passed
testCoGroupRelativeUnknown 0.480s passed
testCount 0.426s passed
testCount2 0.173s passed
testCount3 0.185s passed
testCount4 0.341s passed
testFilter 0.100s passed
testFilterAll 0.115s passed
testReplace 0.134s passed
testSimple 0.140s passed
testSimpleChain 1.964s passed
testSimpleRelative 0.415s passed
testSimpleRelativeUnknown 0.207s passed
testSimpleResult 0.558s passed
testSwap 0.208s passed
testUnGroup 0.174s passed

Standard output

2016-01-14 21:21:55,517 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 21:21:55,533 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop
2016-01-14 21:21:55,558 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 21:21:55,793 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 21:21:55,898 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:55,900 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:56,016 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 6026A0C606614AFC8459D9018DAA457D
2016-01-14 21:21:56,250 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.192
2016-01-14 21:21:56,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 21:21:56,256 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-14 21:21:56,463 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 21:21:56,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:56,466 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:56,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-14 21:21:56,468 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:56,468 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2016-01-14 21:21:56,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:56,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 21:21:56,510 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 21:21:56,559 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 21:21:56,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0001
2016-01-14 21:21:56,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:56,917 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:21:57,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:57,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:57,066 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9AE4FA36327409FB164A9F2F82563CB, ordinal: 0
2016-01-14 21:21:57,112 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:57,112 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:57,113 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9AE4FA36327409FB164A9F2F82563CB, mem on start (mb), free: 81, total: 223, max: 672
2016-01-14 21:21:57,125 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9AE4FA36327409FB164A9F2F82563CB, mem on close (mb), free: 80, total: 223, max: 672
2016-01-14 21:21:57,157 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:21:57,157 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:21:57,171 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D65BAAC0195C492E987EFA2E7B81B757, ordinal: 1
2016-01-14 21:21:57,177 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:57,177 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][742331803/test/]
2016-01-14 21:21:57,178 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D65BAAC0195C492E987EFA2E7B81B757, mem on start (mb), free: 78, total: 223, max: 672
2016-01-14 21:21:57,197 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D65BAAC0195C492E987EFA2E7B81B757, mem on close (mb), free: 77, total: 223, max: 672
2016-01-14 21:21:57,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2016-01-14 21:21:57,321 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0002
2016-01-14 21:21:57,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:57,328 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/742331803_test_A97A138CB8D44E0FAE93EF83437783B5/part-00000
2016-01-14 21:21:57,438 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:57,438 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:57,449 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B57D6A07EEDB49A7B88A2A042B8EDB88, ordinal: 0
2016-01-14 21:21:57,450 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][742331803/test/]
2016-01-14 21:21:57,450 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:57,451 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B57D6A07EEDB49A7B88A2A042B8EDB88, mem on start (mb), free: 66, total: 318, max: 672
2016-01-14 21:21:57,453 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B57D6A07EEDB49A7B88A2A042B8EDB88, mem on close (mb), free: 66, total: 318, max: 672
2016-01-14 21:21:57,463 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:21:57,464 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:21:57,475 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C16A864E0A244B949E47427C8CB70B04, ordinal: 1
2016-01-14 21:21:57,476 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:57,476 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-14 21:21:57,476 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C16A864E0A244B949E47427C8CB70B04, mem on start (mb), free: 65, total: 318, max: 672
2016-01-14 21:21:57,485 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C16A864E0A244B949E47427C8CB70B04, mem on close (mb), free: 65, total: 318, max: 672
2016-01-14 21:21:57,497 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain/_temporary
2016-01-14 21:21:57,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:01.030
2016-01-14 21:21:57,519 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testSimpleChain/simplechain
2016-01-14 21:21:57,543 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:57,544 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:57,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-01-14 21:21:57,650 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:21:57,651 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-14 21:21:57,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 21:21:57,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:21:57,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-01-14 21:21:57,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-14 21:21:57,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-14 21:21:57,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-14 21:21:57,670 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...splatform/testCount/count
2016-01-14 21:21:57,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0003
2016-01-14 21:21:57,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 21:21:57,744 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt
2016-01-14 21:21:57,842 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:57,843 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:57,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6736CC5C0664478985DB100B7CE770E, ordinal: 0
2016-01-14 21:21:57,854 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:21:57,854 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:21:57,854 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6736CC5C0664478985DB100B7CE770E, mem on start (mb), free: 106, total: 414, max: 672
2016-01-14 21:21:57,858 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6736CC5C0664478985DB100B7CE770E, mem on close (mb), free: 106, total: 414, max: 672
2016-01-14 21:21:57,869 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:21:57,869 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:21:57,877 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C056D316E328442CADA401333FF26042, ordinal: 1
2016-01-14 21:21:57,878 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:21:57,879 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-01-14 21:21:57,879 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C056D316E328442CADA401333FF26042, mem on start (mb), free: 105, total: 414, max: 672
2016-01-14 21:21:57,887 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C056D316E328442CADA401333FF26042, mem on close (mb), free: 105, total: 414, max: 672
2016-01-14 21:21:57,903 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount/count/_temporary
2016-01-14 21:21:57,903 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.235
2016-01-14 21:21:57,946 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testCount/count
2016-01-14 21:21:57,966 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:57,967 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:58,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 21:21:58,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:21:58,028 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-14 21:21:58,044 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:58,044 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:58,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-01-14 21:21:58,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:58,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:21:58,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:58,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-14 21:21:58,111 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0004
2016-01-14 21:21:58,111 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:58,115 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:21:58,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:58,122 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:58,129 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AEC822F3A7B8403AB9C0D9AA2A8FC327, ordinal: 0
2016-01-14 21:21:58,130 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:58,130 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-01-14 21:21:58,130 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEC822F3A7B8403AB9C0D9AA2A8FC327, mem on start (mb), free: 92, total: 414, max: 672
2016-01-14 21:21:58,133 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEC822F3A7B8403AB9C0D9AA2A8FC327, mem on close (mb), free: 92, total: 414, max: 672
2016-01-14 21:21:58,143 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap/_temporary
2016-01-14 21:21:58,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.099
2016-01-14 21:21:58,155 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testSwap/swap
2016-01-14 21:21:58,167 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:58,168 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:58,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 21:21:58,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:21:58,216 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-14 21:21:58,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:58,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 21:21:58,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-14 21:21:58,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:58,239 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:21:58,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:58,241 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-14 21:21:58,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0005
2016-01-14 21:21:58,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:58,286 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower+upper.txt
2016-01-14 21:21:58,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:58,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:58,298 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A7786CCEDB7E4E50A0FBA8943C195A90, ordinal: 0
2016-01-14 21:21:58,299 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 21:21:58,299 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-14 21:21:58,299 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A7786CCEDB7E4E50A0FBA8943C195A90, mem on start (mb), free: 81, total: 414, max: 672
2016-01-14 21:21:58,301 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A7786CCEDB7E4E50A0FBA8943C195A90, mem on close (mb), free: 81, total: 414, max: 672
2016-01-14 21:21:58,315 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped/_temporary
2016-01-14 21:21:58,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.079
2016-01-14 21:21:58,329 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testUnGroup/ungrouped
2016-01-14 21:21:58,343 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:58,344 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:58,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-01-14 21:21:58,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:21:58,419 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 21:21:58,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:21:58,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:21:58,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:21:58,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-14 21:21:58,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: false
2016-01-14 21:21:58,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 21:21:58,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 21:21:58,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2016-01-14 21:21:58,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local_0006
2016-01-14 21:21:58,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 21:21:58,486 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt
2016-01-14 21:21:58,583 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:58,584 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:58,592 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FDBDFCE6D0194974854F1033BE4D379E, ordinal: 0
2016-01-14 21:21:58,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:21:58,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 21:21:58,595 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDBDFCE6D0194974854F1033BE4D379E, mem on start (mb), free: 63, total: 509, max: 672
2016-01-14 21:21:58,597 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDBDFCE6D0194974854F1033BE4D379E, mem on close (mb), free: 63, total: 509, max: 672
2016-01-14 21:21:58,617 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt
2016-01-14 21:21:58,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:58,713 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:58,721 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FDBDFCE6D0194974854F1033BE4D379E, ordinal: 0
2016-01-14 21:21:58,722 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:21:58,723 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 21:21:58,723 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDBDFCE6D0194974854F1033BE4D379E, mem on start (mb), free: 79, total: 572, max: 672
2016-01-14 21:21:58,726 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDBDFCE6D0194974854F1033BE4D379E, mem on close (mb), free: 79, total: 572, max: 672
2016-01-14 21:21:58,737 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:21:58,738 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:21:58,744 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A0B9190044EF420DB1A0811AAD6530DC, ordinal: 1
2016-01-14 21:21:58,744 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 21:21:58,745 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-14 21:21:58,745 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A0B9190044EF420DB1A0811AAD6530DC, mem on start (mb), free: 78, total: 572, max: 672
2016-01-14 21:21:58,755 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 21:21:58,755 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 21:21:58,761 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A0B9190044EF420DB1A0811AAD6530DC, mem on close (mb), free: 77, total: 572, max: 672
2016-01-14 21:21:58,783 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2016-01-14 21:21:58,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:00.339
2016-01-14 21:21:58,810 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2016-01-14 21:21:58,822 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:58,823 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:58,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 21:21:58,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:21:58,870 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-14 21:21:58,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:58,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:58,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-14 21:21:58,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:58,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:21:58,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:58,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...leRelative/simplerelative
2016-01-14 21:21:58,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0007
2016-01-14 21:21:58,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:58,932 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:21:59,169 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:59,170 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:59,177 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FE932BB531324E03B53CF5F4F51FA858, ordinal: 0
2016-01-14 21:21:59,178 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:59,178 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:59,178 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FE932BB531324E03B53CF5F4F51FA858, mem on start (mb), free: 144, total: 251, max: 672
2016-01-14 21:21:59,181 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FE932BB531324E03B53CF5F4F51FA858, mem on close (mb), free: 144, total: 251, max: 672
2016-01-14 21:21:59,189 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:21:59,189 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:21:59,196 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E3C7A6676A104A9389A0ED8D84E18A5A, ordinal: 1
2016-01-14 21:21:59,197 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:59,197 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-14 21:21:59,197 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3C7A6676A104A9389A0ED8D84E18A5A, mem on start (mb), free: 142, total: 251, max: 672
2016-01-14 21:21:59,202 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3C7A6676A104A9389A0ED8D84E18A5A, mem on close (mb), free: 142, total: 251, max: 672
2016-01-14 21:21:59,216 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2016-01-14 21:21:59,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.324
2016-01-14 21:21:59,224 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testSimpleRelative/simplerelative
2016-01-14 21:21:59,412 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:59,412 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:59,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-01-14 21:21:59,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:21:59,481 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-14 21:21:59,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:59,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:21:59,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-14 21:21:59,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:59,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:21:59,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:59,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2016-01-14 21:21:59,546 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0008
2016-01-14 21:21:59,546 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:59,551 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt
2016-01-14 21:21:59,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:59,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:59,664 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABF410845946449D8253453BBF8943E1, ordinal: 0
2016-01-14 21:21:59,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:21:59,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:59,666 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABF410845946449D8253453BBF8943E1, mem on start (mb), free: 118, total: 346, max: 672
2016-01-14 21:21:59,744 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABF410845946449D8253453BBF8943E1, mem on close (mb), free: 115, total: 346, max: 672
2016-01-14 21:21:59,752 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:21:59,753 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:21:59,759 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B920A71EFE7748508907C5C987040D67, ordinal: 1
2016-01-14 21:21:59,760 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:21:59,760 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-14 21:21:59,760 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B920A71EFE7748508907C5C987040D67, mem on start (mb), free: 114, total: 346, max: 672
2016-01-14 21:21:59,764 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B920A71EFE7748508907C5C987040D67, mem on close (mb), free: 114, total: 346, max: 672
2016-01-14 21:21:59,771 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2016-01-14 21:21:59,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.267
2016-01-14 21:21:59,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testSimpleResult/simpleresult
2016-01-14 21:21:59,791 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:59,792 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:59,826 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 21:21:59,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:21:59,827 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-14 21:21:59,838 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:59,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:59,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-01-14 21:21:59,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:59,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:21:59,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:59,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-01-14 21:21:59,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0009
2016-01-14 21:21:59,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:21:59,872 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:21:59,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:21:59,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:21:59,881 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E5CDD1219E2740F8938312BC97046C00, ordinal: 0
2016-01-14 21:21:59,882 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:21:59,882 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-01-14 21:21:59,882 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5CDD1219E2740F8938312BC97046C00, mem on start (mb), free: 103, total: 346, max: 672
2016-01-14 21:21:59,883 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5CDD1219E2740F8938312BC97046C00, mem on close (mb), free: 103, total: 346, max: 672
2016-01-14 21:21:59,890 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall/_temporary
2016-01-14 21:21:59,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.052
2016-01-14 21:21:59,898 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testFilterAll/filterall
2016-01-14 21:21:59,909 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:21:59,909 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:21:59,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 21:21:59,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:21:59,949 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-14 21:21:59,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:21:59,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:21:59,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-14 21:21:59,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:21:59,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:21:59,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:21:59,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2016-01-14 21:22:00,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0010
2016-01-14 21:22:00,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:22:00,015 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt
2016-01-14 21:22:00,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:00,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CAAE5CC8733F42DEB6376AFE005C87BE, ordinal: 0
2016-01-14 21:22:00,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:22:00,059 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2016-01-14 21:22:00,059 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CAAE5CC8733F42DEB6376AFE005C87BE, mem on start (mb), free: 93, total: 399, max: 672
2016-01-14 21:22:00,062 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CAAE5CC8733F42DEB6376AFE005C87BE, mem on close (mb), free: 93, total: 399, max: 672
2016-01-14 21:22:00,072 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:22:00,072 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,078 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BAE56B08AE674B039ED88C64849620F5, ordinal: 1
2016-01-14 21:22:00,079 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2016-01-14 21:22:00,079 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-14 21:22:00,080 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BAE56B08AE674B039ED88C64849620F5, mem on start (mb), free: 91, total: 399, max: 672
2016-01-14 21:22:00,085 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BAE56B08AE674B039ED88C64849620F5, mem on close (mb), free: 91, total: 399, max: 672
2016-01-14 21:22:00,094 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2016-01-14 21:22:00,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.131
2016-01-14 21:22:00,105 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2016-01-14 21:22:00,115 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:00,116 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:00,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-14 21:22:00,174 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:22:00,174 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 21:22:00,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 21:22:00,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:22:00,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:22:00,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-14 21:22:00,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: false
2016-01-14 21:22:00,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2016-01-14 21:22:00,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2016-01-14 21:22:00,197 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2016-01-14 21:22:00,242 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local_0011
2016-01-14 21:22:00,243 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 21:22:00,251 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt
2016-01-14 21:22:00,268 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:00,269 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F04E33FC8FF74921ADA8C755A45B09CA, ordinal: 0
2016-01-14 21:22:00,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/upper.txt"]
2016-01-14 21:22:00,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 21:22:00,284 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F04E33FC8FF74921ADA8C755A45B09CA, mem on start (mb), free: 96, total: 404, max: 672
2016-01-14 21:22:00,286 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F04E33FC8FF74921ADA8C755A45B09CA, mem on close (mb), free: 96, total: 404, max: 672
2016-01-14 21:22:00,294 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt
2016-01-14 21:22:00,405 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:00,405 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F04E33FC8FF74921ADA8C755A45B09CA, ordinal: 0
2016-01-14 21:22:00,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/lower.txt"]
2016-01-14 21:22:00,415 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 21:22:00,415 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F04E33FC8FF74921ADA8C755A45B09CA, mem on start (mb), free: 90, total: 499, max: 672
2016-01-14 21:22:00,417 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F04E33FC8FF74921ADA8C755A45B09CA, mem on close (mb), free: 90, total: 499, max: 672
2016-01-14 21:22:00,429 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:22:00,430 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,436 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A1F02A8CD71A4EB1B591C83A3E6F9631, ordinal: 1
2016-01-14 21:22:00,437 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 21:22:00,438 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-14 21:22:00,438 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1F02A8CD71A4EB1B591C83A3E6F9631, mem on start (mb), free: 89, total: 499, max: 672
2016-01-14 21:22:00,442 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 21:22:00,443 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 21:22:00,445 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1F02A8CD71A4EB1B591C83A3E6F9631, mem on close (mb), free: 88, total: 499, max: 672
2016-01-14 21:22:00,472 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2016-01-14 21:22:00,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:00.277
2016-01-14 21:22:00,496 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testCoGroup/complexcogroup
2016-01-14 21:22:00,507 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:00,508 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:00,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 21:22:00,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:22:00,546 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-14 21:22:00,553 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:22:00,553 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:22:00,553 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-01-14 21:22:00,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:22:00,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:22:00,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:22:00,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-14 21:22:00,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0012
2016-01-14 21:22:00,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:22:00,590 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:22:00,593 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:00,593 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4477BD7586242C88CAE3C545B9E6FCE, ordinal: 0
2016-01-14 21:22:00,601 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:22:00,602 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-01-14 21:22:00,602 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4477BD7586242C88CAE3C545B9E6FCE, mem on start (mb), free: 286, total: 600, max: 672
2016-01-14 21:22:00,604 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4477BD7586242C88CAE3C545B9E6FCE, mem on close (mb), free: 286, total: 600, max: 672
2016-01-14 21:22:00,618 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace/_temporary
2016-01-14 21:22:00,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.065
2016-01-14 21:22:00,630 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testReplace/replace
2016-01-14 21:22:00,638 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:00,639 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:00,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 21:22:00,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:22:00,672 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-14 21:22:00,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 21:22:00,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:22:00,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-01-14 21:22:00,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-14 21:22:00,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-14 21:22:00,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-14 21:22:00,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount2/count2
2016-01-14 21:22:00,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0013
2016-01-14 21:22:00,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 21:22:00,727 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt
2016-01-14 21:22:00,750 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:00,750 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,755 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B6E78DA2E19E4629AEC4A2980DF15123, ordinal: 0
2016-01-14 21:22:00,756 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:22:00,756 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:22:00,756 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6E78DA2E19E4629AEC4A2980DF15123, mem on start (mb), free: 174, total: 600, max: 672
2016-01-14 21:22:00,760 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6E78DA2E19E4629AEC4A2980DF15123, mem on close (mb), free: 174, total: 600, max: 672
2016-01-14 21:22:00,768 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:22:00,768 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,773 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D229E99763CA40B8A23279C2810896FC, ordinal: 1
2016-01-14 21:22:00,773 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:22:00,773 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-01-14 21:22:00,774 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D229E99763CA40B8A23279C2810896FC, mem on start (mb), free: 172, total: 600, max: 672
2016-01-14 21:22:00,778 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D229E99763CA40B8A23279C2810896FC, mem on close (mb), free: 171, total: 600, max: 672
2016-01-14 21:22:00,786 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2/_temporary
2016-01-14 21:22:00,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.096
2016-01-14 21:22:00,804 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testCount2/count2
2016-01-14 21:22:00,812 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:00,813 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:00,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 21:22:00,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:22:00,849 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-14 21:22:00,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 21:22:00,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:22:00,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-01-14 21:22:00,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-14 21:22:00,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-14 21:22:00,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-14 21:22:00,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount3/count3
2016-01-14 21:22:00,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0014
2016-01-14 21:22:00,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 21:22:00,899 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt
2016-01-14 21:22:00,929 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:00,929 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA4F155D001240CC8A41D894C3F27094, ordinal: 0
2016-01-14 21:22:00,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:22:00,935 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:22:00,935 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA4F155D001240CC8A41D894C3F27094, mem on start (mb), free: 201, total: 599, max: 672
2016-01-14 21:22:00,937 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA4F155D001240CC8A41D894C3F27094, mem on close (mb), free: 201, total: 599, max: 672
2016-01-14 21:22:00,947 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:22:00,947 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:22:00,954 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A3AE2E3B6CCA4C7E8EED953B4F59953B, ordinal: 1
2016-01-14 21:22:00,955 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:22:00,955 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-01-14 21:22:00,955 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A3AE2E3B6CCA4C7E8EED953B4F59953B, mem on start (mb), free: 198, total: 599, max: 672
2016-01-14 21:22:00,961 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A3AE2E3B6CCA4C7E8EED953B4F59953B, mem on close (mb), free: 198, total: 599, max: 672
2016-01-14 21:22:00,976 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3/_temporary
2016-01-14 21:22:00,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.112
2016-01-14 21:22:00,990 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testCount3/count3
2016-01-14 21:22:00,997 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:00,997 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:01,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 21:22:01,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:22:01,028 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-14 21:22:01,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 21:22:01,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:22:01,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-01-14 21:22:01,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  parallel execution of steps is enabled: false
2016-01-14 21:22:01,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  executing total steps: 1
2016-01-14 21:22:01,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  allocating management threads: 1
2016-01-14 21:22:01,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount4/count4
2016-01-14 21:22:01,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0015
2016-01-14 21:22:01,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 21:22:01,069 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt
2016-01-14 21:22:01,277 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:01,278 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:01,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FC057C1E95EF40E58C9E6F1CC5B165E8, ordinal: 0
2016-01-14 21:22:01,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2016-01-14 21:22:01,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:22:01,283 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC057C1E95EF40E58C9E6F1CC5B165E8, mem on start (mb), free: 311, total: 709, max: 709
2016-01-14 21:22:01,285 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC057C1E95EF40E58C9E6F1CC5B165E8, mem on close (mb), free: 311, total: 709, max: 709
2016-01-14 21:22:01,293 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:22:01,293 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:22:01,299 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A17C4317CE18490EAF56E9508BF2433B, ordinal: 1
2016-01-14 21:22:01,300 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 21:22:01,300 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-01-14 21:22:01,300 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A17C4317CE18490EAF56E9508BF2433B, mem on start (mb), free: 308, total: 709, max: 709
2016-01-14 21:22:01,308 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A17C4317CE18490EAF56E9508BF2433B, mem on close (mb), free: 308, total: 709, max: 709
2016-01-14 21:22:01,317 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4/_temporary
2016-01-14 21:22:01,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [count]  completed in: 00:00.277
2016-01-14 21:22:01,332 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testCount4/count4
2016-01-14 21:22:01,342 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:01,343 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:01,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 21:22:01,363 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:22:01,363 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-14 21:22:01,369 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:22:01,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:22:01,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-01-14 21:22:01,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:22:01,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:22:01,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:22:01,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-14 21:22:01,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0016
2016-01-14 21:22:01,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:22:01,396 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:22:01,400 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:01,400 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:01,408 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4D12F5110CD43EF812E1ED7BEFEC3E0, ordinal: 0
2016-01-14 21:22:01,409 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:22:01,409 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-01-14 21:22:01,410 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4D12F5110CD43EF812E1ED7BEFEC3E0, mem on start (mb), free: 292, total: 709, max: 709
2016-01-14 21:22:01,412 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4D12F5110CD43EF812E1ED7BEFEC3E0, mem on close (mb), free: 291, total: 709, max: 709
2016-01-14 21:22:01,424 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter/_temporary
2016-01-14 21:22:01,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.055
2016-01-14 21:22:01,432 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testFilter/filter
2016-01-14 21:22:01,440 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:22:01,440 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 21:22:01,468 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 21:22:01,468 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 21:22:01,469 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-14 21:22:01,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 21:22:01,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:22:01,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-01-14 21:22:01,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2016-01-14 21:22:01,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 21:22:01,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 21:22:01,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testSimple/simple
2016-01-14 21:22:01,512 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0017
2016-01-14 21:22:01,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 21:22:01,515 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt
2016-01-14 21:22:01,529 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:22:01,530 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:22:01,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FEEA2E4A7F6542F0AE5C46406E2F4D26, ordinal: 0
2016-01-14 21:22:01,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2016-01-14 21:22:01,536 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:22:01,536 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEEA2E4A7F6542F0AE5C46406E2F4D26, mem on start (mb), free: 179, total: 709, max: 709
2016-01-14 21:22:01,538 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEEA2E4A7F6542F0AE5C46406E2F4D26, mem on close (mb), free: 179, total: 709, max: 709
2016-01-14 21:22:01,544 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 21:22:01,544 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 21:22:01,550 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FAAD647FD66C417D8B49AB0E5D9BD79C, ordinal: 1
2016-01-14 21:22:01,551 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 21:22:01,551 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-01-14 21:22:01,551 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FAAD647FD66C417D8B49AB0E5D9BD79C, mem on start (mb), free: 177, total: 709, max: 709
2016-01-14 21:22:01,555 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FAAD647FD66C417D8B49AB0E5D9BD79C, mem on close (mb), free: 176, total: 709, max: 709
2016-01-14 21:22:01,564 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple/_temporary
2016-01-14 21:22:01,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.084
2016-01-14 21:22:01,572 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/testSimple/simple