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