2016-01-14 15:43:28,888 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 15:43:28,918 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop
2016-01-14 15:43:28,947 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 15:43:29,171 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 15:43:29,267 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:43:29,269 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 15:43:29,371 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 842478D970544B73A09A649091BEEFA0
2016-01-14 15:43:29,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.190
2016-01-14 15:43:29,611 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-01-14 15:43:29,612 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 15:43:29,794 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 15:43:29,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:43:29,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:43:29,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-14 15:43:29,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:43:29,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2016-01-14 15:43:29,802 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:43:29,803 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2016-01-14 15:43:29,835 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 15:43:30,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0001
2016-01-14 15:43:30,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:43:30,116 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:43:30,242 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:30,243 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:30,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B1999CAF8B824EA0B48A74E017F4083D, ordinal: 0
2016-01-14 15:43:30,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:43:30,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:43:30,304 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1999CAF8B824EA0B48A74E017F4083D, mem on start (mb), free: 85, total: 223, max: 672
2016-01-14 15:43:30,317 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1999CAF8B824EA0B48A74E017F4083D, mem on close (mb), free: 85, total: 223, max: 672
2016-01-14 15:43:33,107 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:43:33,108 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:43:33,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A69663B34B674C4C88BFE52C6378D159, ordinal: 1
2016-01-14 15:43:33,126 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:43:33,127 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][3235450618/test/]
2016-01-14 15:43:33,127 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A69663B34B674C4C88BFE52C6378D159, mem on start (mb), free: 83, total: 223, max: 672
2016-01-14 15:43:33,146 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A69663B34B674C4C88BFE52C6378D159, mem on close (mb), free: 83, total: 223, max: 672
2016-01-14 15:43:36,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2016-01-14 15:43:36,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0002
2016-01-14 15:43:36,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:43:36,186 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/3235450618_test_B30A3531822747568255BEFAAE554B18/part-00000
2016-01-14 15:43:36,320 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:36,321 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:36,337 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABCC24824D0E46319151A0AE6634C031, ordinal: 0
2016-01-14 15:43:36,338 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][3235450618/test/]
2016-01-14 15:43:36,339 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:43:36,340 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABCC24824D0E46319151A0AE6634C031, mem on start (mb), free: 73, total: 318, max: 672
2016-01-14 15:43:36,343 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABCC24824D0E46319151A0AE6634C031, mem on close (mb), free: 73, total: 318, max: 672
2016-01-14 15:43:39,191 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:43:39,192 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:43:39,201 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DE9FE740E8024BEE9409F7ECDFA8268A, ordinal: 1
2016-01-14 15:43:39,203 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:43:39,203 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-01-14 15:43:39,203 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE9FE740E8024BEE9409F7ECDFA8268A, mem on start (mb), free: 72, total: 318, max: 672
2016-01-14 15:43:39,210 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE9FE740E8024BEE9409F7ECDFA8268A, mem on close (mb), free: 72, total: 318, max: 672
2016-01-14 15:43:42,201 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain/_temporary
2016-01-14 15:43:42,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:12.402
2016-01-14 15:43:42,222 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleChain/simplechain
2016-01-14 15:43:42,241 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:43:42,241 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 15:43:42,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-01-14 15:43:42,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:43:42,308 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 15:43:42,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 15:43:42,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:43:42,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-01-14 15:43:42,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 15:43:42,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 15:43:42,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 15:43:42,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...splatform/testCount/count
2016-01-14 15:43:42,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0003
2016-01-14 15:43:42,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 15:43:42,425 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-01-14 15:43:42,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:42,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:42,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7097B8A96B446A68BC36B01FCF930D8, ordinal: 0
2016-01-14 15:43:42,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:43:42,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:43:42,555 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7097B8A96B446A68BC36B01FCF930D8, mem on start (mb), free: 115, total: 414, max: 672
2016-01-14 15:43:42,560 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7097B8A96B446A68BC36B01FCF930D8, mem on close (mb), free: 115, total: 414, max: 672
2016-01-14 15:43:45,429 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:43:45,429 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:43:45,437 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E011E5E81D4A4A07B59F3590C1C657E0, ordinal: 1
2016-01-14 15:43:45,438 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:43:45,438 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-01-14 15:43:45,439 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E011E5E81D4A4A07B59F3590C1C657E0, mem on start (mb), free: 114, total: 414, max: 672
2016-01-14 15:43:45,448 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E011E5E81D4A4A07B59F3590C1C657E0, mem on close (mb), free: 114, total: 414, max: 672
2016-01-14 15:43:48,441 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount/count/_temporary
2016-01-14 15:43:48,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:06.113
2016-01-14 15:43:48,477 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount/count
2016-01-14 15:43:48,499 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:43:48,500 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 15:43:48,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-01-14 15:43:48,564 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 15:43:48,564 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 15:43:48,581 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:43:48,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:43:48,582 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-01-14 15:43:48,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:43:48,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:43:48,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:43:48,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-14 15:43:48,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0004
2016-01-14 15:43:48,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:43:48,656 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:43:48,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:48,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:48,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5E0202875FB4C0FA7210D6370389C54, ordinal: 0
2016-01-14 15:43:48,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:43:48,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-01-14 15:43:48,673 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5E0202875FB4C0FA7210D6370389C54, mem on start (mb), free: 103, total: 414, max: 672
2016-01-14 15:43:48,675 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5E0202875FB4C0FA7210D6370389C54, mem on close (mb), free: 103, total: 414, max: 672
2016-01-14 15:43:51,660 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSwap/swap/_temporary
2016-01-14 15:43:51,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.079
2016-01-14 15:43:51,673 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSwap/swap
2016-01-14 15:43:51,695 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:43:51,696 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 15:43:51,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 15:43:51,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 15:43:51,740 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 15:43:51,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:43:51,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-01-14 15:43:51,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-14 15:43:51,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:43:51,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:43:51,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:43:51,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-14 15:43:51,802 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0005
2016-01-14 15:43:51,803 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:43:51,812 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-01-14 15:43:51,817 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:51,817 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:51,826 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C8CB4555EA674116BFFAF9602150CBC4, ordinal: 0
2016-01-14 15:43:51,827 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-01-14 15:43:51,827 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-01-14 15:43:51,828 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8CB4555EA674116BFFAF9602150CBC4, mem on start (mb), free: 94, total: 414, max: 672
2016-01-14 15:43:51,831 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8CB4555EA674116BFFAF9602150CBC4, mem on close (mb), free: 94, total: 414, max: 672
2016-01-14 15:43:54,818 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped/_temporary
2016-01-14 15:43:54,819 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.057
2016-01-14 15:43:54,828 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testUnGroup/ungrouped
2016-01-14 15:43:54,841 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:43:54,841 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 15:43:54,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2016-01-14 15:43:54,920 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:43:54,920 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 15:43:54,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 15:43:54,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-01-14 15:43:54,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:43:54,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-14 15:43:54,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-14 15:43:54,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 15:43:54,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 15:43:54,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2016-01-14 15:43:54,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local_0006
2016-01-14 15:43:54,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 15:43:54,999 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-01-14 15:43:55,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:55,096 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:55,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA67A31860384CCB8CEC3BE741D9008A, ordinal: 0
2016-01-14 15:43:55,108 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:43:55,109 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 15:43:55,109 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA67A31860384CCB8CEC3BE741D9008A, mem on start (mb), free: 78, total: 509, max: 672
2016-01-14 15:43:55,113 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA67A31860384CCB8CEC3BE741D9008A, mem on close (mb), free: 78, total: 509, max: 672
2016-01-14 15:43:58,001 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/upper.txt
2016-01-14 15:43:58,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:43:58,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:43:58,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA67A31860384CCB8CEC3BE741D9008A, ordinal: 0
2016-01-14 15:43:58,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-01-14 15:43:58,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 15:43:58,105 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA67A31860384CCB8CEC3BE741D9008A, mem on start (mb), free: 40, total: 572, max: 672
2016-01-14 15:43:58,107 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA67A31860384CCB8CEC3BE741D9008A, mem on close (mb), free: 40, total: 572, max: 672
2016-01-14 15:44:01,008 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:01,008 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:01,014 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C74960CC7525493C9B4E99DFC797D138, ordinal: 1
2016-01-14 15:44:01,015 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-01-14 15:44:01,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-01-14 15:44:01,016 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C74960CC7525493C9B4E99DFC797D138, mem on start (mb), free: 39, total: 572, max: 672
2016-01-14 15:44:01,026 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 15:44:01,026 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 15:44:01,033 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C74960CC7525493C9B4E99DFC797D138, mem on close (mb), free: 38, total: 572, max: 672
2016-01-14 15:44:04,016 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2016-01-14 15:44:04,017 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:09.069
2016-01-14 15:44:04,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2016-01-14 15:44:04,055 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:04,056 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 15:44:04,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 15:44:04,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:04,104 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 15:44:04,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:04,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:04,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-14 15:44:04,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:04,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:04,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:04,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...leRelative/simplerelative
2016-01-14 15:44:04,213 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0007
2016-01-14 15:44:04,213 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:04,219 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:44:04,444 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:04,444 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:04,452 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0BDE48622FB4636B6C77DC888F6189D, ordinal: 0
2016-01-14 15:44:04,453 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:04,453 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:44:04,453 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0BDE48622FB4636B6C77DC888F6189D, mem on start (mb), free: 140, total: 246, max: 672
2016-01-14 15:44:04,458 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0BDE48622FB4636B6C77DC888F6189D, mem on close (mb), free: 140, total: 246, max: 672
2016-01-14 15:44:07,223 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:07,223 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:07,234 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CB643BCB240648A487DD6AD23E835AE1, ordinal: 1
2016-01-14 15:44:07,235 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:44:07,235 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-01-14 15:44:07,235 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CB643BCB240648A487DD6AD23E835AE1, mem on start (mb), free: 139, total: 246, max: 672
2016-01-14 15:44:07,240 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CB643BCB240648A487DD6AD23E835AE1, mem on close (mb), free: 139, total: 246, max: 672
2016-01-14 15:44:10,234 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2016-01-14 15:44:10,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.107
2016-01-14 15:44:10,244 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleRelative/simplerelative
2016-01-14 15:44:10,461 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:10,462 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 15:44:10,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 15:44:10,512 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:10,512 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 15:44:10,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:10,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:44:10,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-14 15:44:10,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:10,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:10,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:10,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2016-01-14 15:44:10,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0008
2016-01-14 15:44:10,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:10,574 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-01-14 15:44:10,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:10,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:10,678 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D39DEE4EA9DF4D7BAF60FB4FCACB5685, ordinal: 0
2016-01-14 15:44:10,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:44:10,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:44:10,681 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D39DEE4EA9DF4D7BAF60FB4FCACB5685, mem on start (mb), free: 117, total: 342, max: 672
2016-01-14 15:44:10,761 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D39DEE4EA9DF4D7BAF60FB4FCACB5685, mem on close (mb), free: 114, total: 342, max: 672
2016-01-14 15:44:13,578 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:13,578 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:13,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DF578882B13942D6B1263E2CFBC46034, ordinal: 1
2016-01-14 15:44:13,586 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:44:13,586 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-01-14 15:44:13,587 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DF578882B13942D6B1263E2CFBC46034, mem on start (mb), free: 113, total: 342, max: 672
2016-01-14 15:44:13,591 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DF578882B13942D6B1263E2CFBC46034, mem on close (mb), free: 113, total: 342, max: 672
2016-01-14 15:44:16,589 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2016-01-14 15:44:16,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.052
2016-01-14 15:44:16,598 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleResult/simpleresult
2016-01-14 15:44:16,606 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:16,606 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 15:44:16,637 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 15:44:16,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 15:44:16,639 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 15:44:16,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:16,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:16,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-01-14 15:44:16,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:16,652 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:16,653 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:16,654 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-01-14 15:44:16,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0009
2016-01-14 15:44:16,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:16,689 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:44:16,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:16,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:16,700 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E45600B93E384C45B775C7F72E5F9076, ordinal: 0
2016-01-14 15:44:16,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:16,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-01-14 15:44:16,701 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E45600B93E384C45B775C7F72E5F9076, mem on start (mb), free: 104, total: 342, max: 672
2016-01-14 15:44:16,704 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E45600B93E384C45B775C7F72E5F9076, mem on close (mb), free: 104, total: 342, max: 672
2016-01-14 15:44:19,700 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall/_temporary
2016-01-14 15:44:19,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.050
2016-01-14 15:44:19,709 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testFilterAll/filterall
2016-01-14 15:44:19,718 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:19,719 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 15:44:19,752 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 15:44:19,753 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:19,754 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 15:44:19,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:19,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:44:19,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-14 15:44:19,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:19,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:19,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:19,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2016-01-14 15:44:19,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0010
2016-01-14 15:44:19,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:19,799 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-01-14 15:44:19,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:19,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:19,908 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC0547E7A3234280BD6022F1BB2F5089, ordinal: 0
2016-01-14 15:44:19,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:44:19,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2016-01-14 15:44:19,911 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC0547E7A3234280BD6022F1BB2F5089, mem on start (mb), free: 90, total: 437, max: 672
2016-01-14 15:44:19,914 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC0547E7A3234280BD6022F1BB2F5089, mem on close (mb), free: 90, total: 437, max: 672
2016-01-14 15:44:22,803 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:22,803 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:22,809 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F229B7B5CBB9479E9FE31029B1C102D4, ordinal: 1
2016-01-14 15:44:22,810 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2016-01-14 15:44:22,810 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-01-14 15:44:22,810 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F229B7B5CBB9479E9FE31029B1C102D4, mem on start (mb), free: 89, total: 437, max: 672
2016-01-14 15:44:22,814 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F229B7B5CBB9479E9FE31029B1C102D4, mem on close (mb), free: 88, total: 437, max: 672
2016-01-14 15:44:25,824 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2016-01-14 15:44:25,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.056
2016-01-14 15:44:25,833 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2016-01-14 15:44:25,841 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:25,842 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 15:44:25,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 15:44:25,890 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:25,890 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 15:44:25,906 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 15:44:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-01-14 15:44:25,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:44:25,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-14 15:44:25,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-14 15:44:25,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 15:44:25,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 15:44:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2016-01-14 15:44:25,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local_0011
2016-01-14 15:44:25,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 15:44:25,947 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/upper.txt
2016-01-14 15:44:25,993 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:25,993 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:26,001 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BEF50EDFE1B8495590785F5083BD0451, ordinal: 0
2016-01-14 15:44:26,002 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-01-14 15:44:26,002 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 15:44:26,003 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEF50EDFE1B8495590785F5083BD0451, mem on start (mb), free: 85, total: 496, max: 672
2016-01-14 15:44:26,004 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEF50EDFE1B8495590785F5083BD0451, mem on close (mb), free: 85, total: 496, max: 672
2016-01-14 15:44:28,948 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-01-14 15:44:29,052 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:29,052 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:29,059 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BEF50EDFE1B8495590785F5083BD0451, ordinal: 0
2016-01-14 15:44:29,060 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-01-14 15:44:29,060 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 15:44:29,061 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEF50EDFE1B8495590785F5083BD0451, mem on start (mb), free: 194, total: 592, max: 672
2016-01-14 15:44:29,062 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEF50EDFE1B8495590785F5083BD0451, mem on close (mb), free: 194, total: 592, max: 672
2016-01-14 15:44:31,954 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:31,954 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:31,962 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E548447C38CB425F944F790FA2E8D95B, ordinal: 1
2016-01-14 15:44:31,963 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-01-14 15:44:31,963 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-01-14 15:44:31,964 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E548447C38CB425F944F790FA2E8D95B, mem on start (mb), free: 192, total: 592, max: 672
2016-01-14 15:44:31,969 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 15:44:31,969 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 15:44:31,972 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E548447C38CB425F944F790FA2E8D95B, mem on close (mb), free: 192, total: 592, max: 672
2016-01-14 15:44:34,958 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2016-01-14 15:44:34,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:09.052
2016-01-14 15:44:34,977 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCoGroup/complexcogroup
2016-01-14 15:44:34,984 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:34,984 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 15:44:35,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 15:44:35,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 15:44:35,013 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 15:44:35,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:35,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:35,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-01-14 15:44:35,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:35,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:35,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:35,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-14 15:44:35,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0012
2016-01-14 15:44:35,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:35,064 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:44:35,068 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:35,068 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:35,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF758AAA4FB64E40A8207BD38629E8CF, ordinal: 0
2016-01-14 15:44:35,077 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:35,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-01-14 15:44:35,078 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF758AAA4FB64E40A8207BD38629E8CF, mem on start (mb), free: 181, total: 592, max: 672
2016-01-14 15:44:35,080 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF758AAA4FB64E40A8207BD38629E8CF, mem on close (mb), free: 181, total: 592, max: 672
2016-01-14 15:44:38,067 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testReplace/replace/_temporary
2016-01-14 15:44:38,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.046
2016-01-14 15:44:38,075 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testReplace/replace
2016-01-14 15:44:38,082 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:38,082 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 15:44:38,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 15:44:38,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:38,120 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 15:44:38,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 15:44:38,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:44:38,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-01-14 15:44:38,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 15:44:38,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 15:44:38,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 15:44:38,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount2/count2
2016-01-14 15:44:38,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0013
2016-01-14 15:44:38,167 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 15:44:38,172 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-01-14 15:44:38,274 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:38,274 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:38,280 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C946099F80AB4E43B91C6B026DB8B791, ordinal: 0
2016-01-14 15:44:38,281 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:44:38,281 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:44:38,281 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C946099F80AB4E43B91C6B026DB8B791, mem on start (mb), free: 109, total: 631, max: 672
2016-01-14 15:44:38,285 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C946099F80AB4E43B91C6B026DB8B791, mem on close (mb), free: 109, total: 631, max: 672
2016-01-14 15:44:41,175 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:41,176 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:41,181 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CB47AB0D2EA54D5A8F5B45B328E084AA, ordinal: 1
2016-01-14 15:44:41,182 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:44:41,183 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-01-14 15:44:41,183 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CB47AB0D2EA54D5A8F5B45B328E084AA, mem on start (mb), free: 108, total: 631, max: 672
2016-01-14 15:44:41,188 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CB47AB0D2EA54D5A8F5B45B328E084AA, mem on close (mb), free: 108, total: 631, max: 672
2016-01-14 15:44:44,180 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount2/count2/_temporary
2016-01-14 15:44:44,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:06.040
2016-01-14 15:44:44,194 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount2/count2
2016-01-14 15:44:44,205 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:44,206 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 15:44:44,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 15:44:44,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:44,243 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 15:44:44,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 15:44:44,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:44:44,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-01-14 15:44:44,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 15:44:44,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 15:44:44,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 15:44:44,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount3/count3
2016-01-14 15:44:44,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0014
2016-01-14 15:44:44,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 15:44:44,284 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-01-14 15:44:44,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:44,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:44,313 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABCDCDCE0A8343139F9B01337C839FC1, ordinal: 0
2016-01-14 15:44:44,313 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:44:44,314 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:44:44,314 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABCDCDCE0A8343139F9B01337C839FC1, mem on start (mb), free: 156, total: 744, max: 744
2016-01-14 15:44:44,316 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABCDCDCE0A8343139F9B01337C839FC1, mem on close (mb), free: 156, total: 744, max: 744
2016-01-14 15:44:47,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:47,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:47,292 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E7DDC05F8501475793A5AAA459D05FB8, ordinal: 1
2016-01-14 15:44:47,293 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:44:47,293 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-01-14 15:44:47,294 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7DDC05F8501475793A5AAA459D05FB8, mem on start (mb), free: 154, total: 744, max: 744
2016-01-14 15:44:47,306 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E7DDC05F8501475793A5AAA459D05FB8, mem on close (mb), free: 153, total: 744, max: 744
2016-01-14 15:44:50,297 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount3/count3/_temporary
2016-01-14 15:44:50,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:06.042
2016-01-14 15:44:50,311 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount3/count3
2016-01-14 15:44:50,318 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:50,318 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 15:44:50,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 15:44:50,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:50,357 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 15:44:50,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2016-01-14 15:44:50,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:44:50,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-01-14 15:44:50,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2016-01-14 15:44:50,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2016-01-14 15:44:50,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2016-01-14 15:44:50,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount4/count4
2016-01-14 15:44:50,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local_0015
2016-01-14 15:44:50,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2016-01-14 15:44:50,419 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-01-14 15:44:50,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:50,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:50,511 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B6D030CFC5D34CD58D84901A7D2C46EC, ordinal: 0
2016-01-14 15:44:50,511 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-01-14 15:44:50,511 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:44:50,512 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6D030CFC5D34CD58D84901A7D2C46EC, mem on start (mb), free: 40, total: 744, max: 744
2016-01-14 15:44:50,514 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6D030CFC5D34CD58D84901A7D2C46EC, mem on close (mb), free: 40, total: 744, max: 744
2016-01-14 15:44:53,423 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:44:53,423 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:44:53,430 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D2CD25AAA74F4CAF98A5979BAB3EE668, ordinal: 1
2016-01-14 15:44:53,432 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-01-14 15:44:53,432 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-01-14 15:44:53,433 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D2CD25AAA74F4CAF98A5979BAB3EE668, mem on start (mb), free: 38, total: 744, max: 744
2016-01-14 15:44:53,441 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D2CD25AAA74F4CAF98A5979BAB3EE668, mem on close (mb), free: 38, total: 744, max: 744
2016-01-14 15:44:56,432 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount4/count4/_temporary
2016-01-14 15:44:56,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:06.054
2016-01-14 15:44:56,450 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount4/count4
2016-01-14 15:44:56,458 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:56,458 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 15:44:56,483 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 15:44:56,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 15:44:56,484 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 15:44:56,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:56,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:56,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-01-14 15:44:56,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:56,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:56,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:56,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-14 15:44:56,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0016
2016-01-14 15:44:56,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:56,670 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:44:56,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:56,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:56,684 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7BDB2D596A345CFB20FB6A8DD3CC3EC, ordinal: 0
2016-01-14 15:44:56,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:56,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-01-14 15:44:56,686 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7BDB2D596A345CFB20FB6A8DD3CC3EC, mem on start (mb), free: 317, total: 328, max: 672
2016-01-14 15:44:56,689 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7BDB2D596A345CFB20FB6A8DD3CC3EC, mem on close (mb), free: 317, total: 328, max: 672
2016-01-14 15:44:59,682 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilter/filter/_temporary
2016-01-14 15:44:59,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:03.189
2016-01-14 15:44:59,689 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testFilter/filter
2016-01-14 15:44:59,699 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 15:44:59,700 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 15:44:59,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 15:44:59,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 15:44:59,732 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 15:44:59,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 15:44:59,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:59,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-01-14 15:44:59,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 15:44:59,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 15:44:59,752 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 15:44:59,752 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testSimple/simple
2016-01-14 15:44:59,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local_0017
2016-01-14 15:44:59,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 15:44:59,786 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-01-14 15:44:59,801 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 15:44:59,802 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 15:44:59,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C57AF27656FA4FDB801F77B0ABAA95F5, ordinal: 0
2016-01-14 15:44:59,808 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-01-14 15:44:59,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:44:59,809 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C57AF27656FA4FDB801F77B0ABAA95F5, mem on start (mb), free: 204, total: 328, max: 672
2016-01-14 15:44:59,811 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C57AF27656FA4FDB801F77B0ABAA95F5, mem on close (mb), free: 204, total: 328, max: 672
2016-01-14 15:45:02,789 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 15:45:02,790 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 15:45:02,795 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EC7B941168334BA9823AD5D18D437EF7, ordinal: 1
2016-01-14 15:45:02,797 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-01-14 15:45:02,797 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-01-14 15:45:02,798 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC7B941168334BA9823AD5D18D437EF7, mem on start (mb), free: 202, total: 328, max: 672
2016-01-14 15:45:02,802 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC7B941168334BA9823AD5D18D437EF7, mem on close (mb), free: 202, total: 328, max: 672
2016-01-14 15:45:05,790 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimple/simple/_temporary
2016-01-14 15:45:05,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:06.040
2016-01-14 15:45:05,801 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimple/simple