2016-05-17 21:14:36,496 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 21:14:36,512 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop
2016-05-17 21:14:36,538 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-17 21:14:36,771 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 21:14:36,873 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:14:36,875 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:14:36,987 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 59C691A20F6C4B71AA856BB083358C81
2016-05-17 21:14:37,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.192
2016-05-17 21:14:37,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:14:37,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:14:37,432 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 21:14:37,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:14:37,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:14:37,435 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-05-17 21:14:37,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:14:37,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-17 21:14:37,438 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:14:37,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-17 21:14:37,470 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 21:14:37,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0001
2016-05-17 21:14:37,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:14:37,741 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:14:37,886 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:14:37,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:14:37,900 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D72E603D01FE4162B34D0DA508FB2B3D, ordinal: 0
2016-05-17 21:14:37,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:14:37,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:14:37,939 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D72E603D01FE4162B34D0DA508FB2B3D, mem on start (mb), free: 85, total: 223, max: 672
2016-05-17 21:14:37,951 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D72E603D01FE4162B34D0DA508FB2B3D, mem on close (mb), free: 84, total: 223, max: 672
2016-05-17 21:14:40,733 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:14:40,734 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:14:40,748 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EE40BF753A384250B025E75198CDA895, ordinal: 1
2016-05-17 21:14:40,752 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:14:40,753 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][1386278894/test/]
2016-05-17 21:14:40,753 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE40BF753A384250B025E75198CDA895, mem on start (mb), free: 82, total: 223, max: 672
2016-05-17 21:14:40,774 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE40BF753A384250B025E75198CDA895, mem on close (mb), free: 81, total: 223, max: 672
2016-05-17 21:14:43,736 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2016-05-17 21:14:43,806 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0002
2016-05-17 21:14:43,807 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:14:43,812 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/1386278894_test_39E6BDB7DC7542F9A75EE96D30F147DB/part-00000
2016-05-17 21:14:43,915 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:14:43,915 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:14:43,926 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B54290BC978247A9B241CF792863D3D7, ordinal: 0
2016-05-17 21:14:43,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][1386278894/test/]
2016-05-17 21:14:43,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:14:43,928 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B54290BC978247A9B241CF792863D3D7, mem on start (mb), free: 71, total: 318, max: 672
2016-05-17 21:14:43,931 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B54290BC978247A9B241CF792863D3D7, mem on close (mb), free: 71, total: 318, max: 672
2016-05-17 21:14:46,818 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:14:46,818 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:14:46,834 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C2FAC0C2119345BCB426574E071C71F1, ordinal: 1
2016-05-17 21:14:46,835 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:14:46,836 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-05-17 21:14:46,837 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2FAC0C2119345BCB426574E071C71F1, mem on start (mb), free: 70, total: 318, max: 672
2016-05-17 21:14:46,846 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2FAC0C2119345BCB426574E071C71F1, mem on close (mb), free: 70, total: 318, max: 672
2016-05-17 21:14:49,824 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain/_temporary
2016-05-17 21:14:49,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:12.388
2016-05-17 21:14:49,843 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleChain/simplechain
2016-05-17 21:14:49,861 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:14:49,862 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:14:49,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 21:14:49,928 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:14:49,929 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:14:49,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-17 21:14:49,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:14:49,950 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-05-17 21:14:49,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-17 21:14:49,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-17 21:14:49,951 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-17 21:14:49,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...splatform/testCount/count
2016-05-17 21:14:50,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local_0003
2016-05-17 21:14:50,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-17 21:14:50,061 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 21:14:50,155 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:14:50,156 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:14:50,165 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E97AE95A42654138B747C03252DA8085, ordinal: 0
2016-05-17 21:14:50,166 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:14:50,166 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:14:50,166 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E97AE95A42654138B747C03252DA8085, mem on start (mb), free: 114, total: 414, max: 672
2016-05-17 21:14:50,171 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E97AE95A42654138B747C03252DA8085, mem on close (mb), free: 114, total: 414, max: 672
2016-05-17 21:14:53,067 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:14:53,067 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:14:53,075 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B7666BBF1FBE4C2CBE966E93B00EA573, ordinal: 1
2016-05-17 21:14:53,076 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:14:53,076 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-05-17 21:14:53,076 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B7666BBF1FBE4C2CBE966E93B00EA573, mem on start (mb), free: 113, total: 414, max: 672
2016-05-17 21:14:53,084 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B7666BBF1FBE4C2CBE966E93B00EA573, mem on close (mb), free: 113, total: 414, max: 672
2016-05-17 21:14:56,073 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount/count/_temporary
2016-05-17 21:14:56,074 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:06.124
2016-05-17 21:14:56,104 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount/count
2016-05-17 21:14:56,121 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:14:56,121 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:14:56,162 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 21:14:56,165 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:14:56,165 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:14:56,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:14:56,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:14:56,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-05-17 21:14:56,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:14:56,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:14:56,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:14:56,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-05-17 21:14:56,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0004
2016-05-17 21:14:56,234 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:14:56,240 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:14:56,246 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:14:56,246 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:14:56,255 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5E94F9EFFF24A3B9534920914995D92, ordinal: 0
2016-05-17 21:14:56,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:14:56,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-05-17 21:14:56,258 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5E94F9EFFF24A3B9534920914995D92, mem on start (mb), free: 102, total: 414, max: 672
2016-05-17 21:14:56,262 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5E94F9EFFF24A3B9534920914995D92, mem on close (mb), free: 102, total: 414, max: 672
2016-05-17 21:14:59,250 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSwap/swap/_temporary
2016-05-17 21:14:59,250 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:03.071
2016-05-17 21:14:59,261 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSwap/swap
2016-05-17 21:14:59,272 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:14:59,273 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:14:59,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 21:14:59,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:14:59,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:14:59,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:14:59,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:14:59,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-05-17 21:14:59,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:14:59,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:14:59,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:14:59,332 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-05-17 21:14:59,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0005
2016-05-17 21:14:59,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:14:59,378 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:14:59,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:14:59,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:14:59,392 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D12BB104D7E94089A07AE3F8AA4984A2, ordinal: 0
2016-05-17 21:14:59,393 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:14:59,394 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-05-17 21:14:59,394 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D12BB104D7E94089A07AE3F8AA4984A2, mem on start (mb), free: 93, total: 414, max: 672
2016-05-17 21:14:59,396 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D12BB104D7E94089A07AE3F8AA4984A2, mem on close (mb), free: 93, total: 414, max: 672
2016-05-17 21:15:02,389 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped/_temporary
2016-05-17 21:15:02,389 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:03.059
2016-05-17 21:15:02,401 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testUnGroup/ungrouped
2016-05-17 21:15:02,413 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:02,414 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:02,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2016-05-17 21:15:02,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:02,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:02,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-17 21:15:02,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:15:02,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:02,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-05-17 21:15:02,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: false
2016-05-17 21:15:02,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-17 21:15:02,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-17 21:15:02,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2016-05-17 21:15:02,556 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_local_0006
2016-05-17 21:15:02,560 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:8080/
2016-05-17 21:15:02,563 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:15:02,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:02,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:02,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DAD85BA1EEA14BDCB64758ED301E0297, ordinal: 0
2016-05-17 21:15:02,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:02,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-05-17 21:15:02,672 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAD85BA1EEA14BDCB64758ED301E0297, mem on start (mb), free: 77, total: 509, max: 672
2016-05-17 21:15:02,676 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAD85BA1EEA14BDCB64758ED301E0297, mem on close (mb), free: 77, total: 509, max: 672
2016-05-17 21:15:05,564 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt
2016-05-17 21:15:05,655 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:05,655 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:05,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DAD85BA1EEA14BDCB64758ED301E0297, ordinal: 0
2016-05-17 21:15:05,664 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:15:05,664 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-05-17 21:15:05,665 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAD85BA1EEA14BDCB64758ED301E0297, mem on start (mb), free: 39, total: 572, max: 672
2016-05-17 21:15:05,666 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAD85BA1EEA14BDCB64758ED301E0297, mem on close (mb), free: 39, total: 572, max: 672
2016-05-17 21:15:08,573 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:08,573 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:08,579 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C896A9BA390E4DD1AC19F420B962A8FB, ordinal: 1
2016-05-17 21:15:08,580 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-05-17 21:15:08,580 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-05-17 21:15:08,580 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C896A9BA390E4DD1AC19F420B962A8FB, mem on start (mb), free: 37, total: 572, max: 672
2016-05-17 21:15:08,597 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:15:08,597 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:15:08,605 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C896A9BA390E4DD1AC19F420B962A8FB, mem on close (mb), free: 36, total: 572, max: 672
2016-05-17 21:15:11,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2016-05-17 21:15:11,582 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:09.067
2016-05-17 21:15:11,603 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2016-05-17 21:15:11,617 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:11,618 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:11,682 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-17 21:15:11,683 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:11,683 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:11,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:15:11,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:15:11,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-05-17 21:15:11,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:15:11,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:15:11,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:15:11,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...leRelative/simplerelative
2016-05-17 21:15:11,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0007
2016-05-17 21:15:11,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:15:11,764 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:15:11,988 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:11,988 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:11,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6E03660A0C84B2B9E96473D1AFF9A59, ordinal: 0
2016-05-17 21:15:12,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:15:12,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:15:12,001 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6E03660A0C84B2B9E96473D1AFF9A59, mem on start (mb), free: 140, total: 247, max: 672
2016-05-17 21:15:12,004 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6E03660A0C84B2B9E96473D1AFF9A59, mem on close (mb), free: 140, total: 247, max: 672
2016-05-17 21:15:14,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:14,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:14,778 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B1630E7B858549CA838E246CF59E13AD, ordinal: 1
2016-05-17 21:15:14,779 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:15:14,780 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-05-17 21:15:14,780 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B1630E7B858549CA838E246CF59E13AD, mem on start (mb), free: 139, total: 247, max: 672
2016-05-17 21:15:14,787 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B1630E7B858549CA838E246CF59E13AD, mem on close (mb), free: 139, total: 247, max: 672
2016-05-17 21:15:17,780 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2016-05-17 21:15:17,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:06.071
2016-05-17 21:15:17,789 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleRelative/simplerelative
2016-05-17 21:15:17,978 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:17,979 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:18,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-17 21:15:18,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:18,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:18,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:15:18,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:18,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-05-17 21:15:18,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:15:18,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:15:18,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:15:18,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2016-05-17 21:15:18,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0008
2016-05-17 21:15:18,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:15:18,107 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:15:18,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:18,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:18,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB3DEC3ECFCF4C12BB3948062BF1A8CD, ordinal: 0
2016-05-17 21:15:18,210 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:18,211 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:15:18,211 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB3DEC3ECFCF4C12BB3948062BF1A8CD, mem on start (mb), free: 115, total: 342, max: 672
2016-05-17 21:15:18,293 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB3DEC3ECFCF4C12BB3948062BF1A8CD, mem on close (mb), free: 111, total: 342, max: 672
2016-05-17 21:15:21,113 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:21,113 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:21,120 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FA5C42DE9DB44278B2FCBA54AE37710B, ordinal: 1
2016-05-17 21:15:21,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:15:21,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-05-17 21:15:21,121 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FA5C42DE9DB44278B2FCBA54AE37710B, mem on start (mb), free: 110, total: 342, max: 672
2016-05-17 21:15:21,126 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FA5C42DE9DB44278B2FCBA54AE37710B, mem on close (mb), free: 110, total: 342, max: 672
2016-05-17 21:15:24,121 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2016-05-17 21:15:24,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:06.053
2016-05-17 21:15:24,130 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleResult/simpleresult
2016-05-17 21:15:24,138 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:24,139 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:24,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 21:15:24,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:15:24,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:24,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:15:24,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:15:24,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-05-17 21:15:24,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:15:24,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:15:24,186 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:15:24,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-05-17 21:15:24,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0009
2016-05-17 21:15:24,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:15:24,237 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:15:24,246 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:24,246 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:24,259 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E26B3D0234814DC79B3CDFCF8D5CADA1, ordinal: 0
2016-05-17 21:15:24,261 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:15:24,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-05-17 21:15:24,263 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E26B3D0234814DC79B3CDFCF8D5CADA1, mem on start (mb), free: 101, total: 342, max: 672
2016-05-17 21:15:24,266 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E26B3D0234814DC79B3CDFCF8D5CADA1, mem on close (mb), free: 101, total: 342, max: 672
2016-05-17 21:15:27,239 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall/_temporary
2016-05-17 21:15:27,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:03.054
2016-05-17 21:15:27,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testFilterAll/filterall
2016-05-17 21:15:27,258 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:27,258 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:27,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 21:15:27,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:27,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:27,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:15:27,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:27,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-05-17 21:15:27,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:15:27,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:15:27,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:15:27,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2016-05-17 21:15:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0010
2016-05-17 21:15:27,343 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:15:27,347 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:15:27,449 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:27,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:27,456 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C8488C03737541129BA5B24876BD711B, ordinal: 0
2016-05-17 21:15:27,457 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:27,457 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2016-05-17 21:15:27,457 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8488C03737541129BA5B24876BD711B, mem on start (mb), free: 191, total: 495, max: 672
2016-05-17 21:15:27,459 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8488C03737541129BA5B24876BD711B, mem on close (mb), free: 191, total: 495, max: 672
2016-05-17 21:15:30,352 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:30,353 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:30,359 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A8E5B69D53914E429BCA4263E21C6D29, ordinal: 1
2016-05-17 21:15:30,360 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2016-05-17 21:15:30,360 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-05-17 21:15:30,361 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8E5B69D53914E429BCA4263E21C6D29, mem on start (mb), free: 190, total: 495, max: 672
2016-05-17 21:15:30,366 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8E5B69D53914E429BCA4263E21C6D29, mem on close (mb), free: 190, total: 495, max: 672
2016-05-17 21:15:33,358 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2016-05-17 21:15:33,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:06.043
2016-05-17 21:15:33,367 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2016-05-17 21:15:33,379 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:33,380 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:33,426 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-17 21:15:33,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:33,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:33,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-17 21:15:33,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:15:33,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:33,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-05-17 21:15:33,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: false
2016-05-17 21:15:33,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-17 21:15:33,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-17 21:15:33,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2016-05-17 21:15:33,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_local_0011
2016-05-17 21:15:33,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:8080/
2016-05-17 21:15:33,498 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt
2016-05-17 21:15:33,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:33,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:33,691 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C360958F82D34193ABE05154F41EA989, ordinal: 0
2016-05-17 21:15:33,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:15:33,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-05-17 21:15:33,692 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C360958F82D34193ABE05154F41EA989, mem on start (mb), free: 194, total: 592, max: 672
2016-05-17 21:15:33,694 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C360958F82D34193ABE05154F41EA989, mem on close (mb), free: 194, total: 592, max: 672
2016-05-17 21:15:36,499 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:15:36,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:36,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:36,524 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C360958F82D34193ABE05154F41EA989, ordinal: 0
2016-05-17 21:15:36,525 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:15:36,525 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-05-17 21:15:36,525 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C360958F82D34193ABE05154F41EA989, mem on start (mb), free: 93, total: 592, max: 672
2016-05-17 21:15:36,527 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C360958F82D34193ABE05154F41EA989, mem on close (mb), free: 93, total: 592, max: 672
2016-05-17 21:15:39,506 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:39,507 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:39,512 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D3EC9C5A96B549D0AA2A2E6E0F5146DC, ordinal: 1
2016-05-17 21:15:39,513 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-05-17 21:15:39,513 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-05-17 21:15:39,514 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D3EC9C5A96B549D0AA2A2E6E0F5146DC, mem on start (mb), free: 92, total: 592, max: 672
2016-05-17 21:15:39,519 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:15:39,519 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:15:39,521 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D3EC9C5A96B549D0AA2A2E6E0F5146DC, mem on close (mb), free: 91, total: 592, max: 672
2016-05-17 21:15:42,514 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2016-05-17 21:15:42,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:09.069
2016-05-17 21:15:42,535 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCoGroup/complexcogroup
2016-05-17 21:15:42,543 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:42,543 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:42,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 21:15:42,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:15:42,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:42,582 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:15:42,582 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:15:42,586 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-05-17 21:15:42,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:15:42,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:15:42,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:15:42,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-05-17 21:15:42,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0012
2016-05-17 21:15:42,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:15:42,631 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:15:42,634 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:42,634 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:42,640 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CFB5DBE9E4D64F4896B22150CC111C29, ordinal: 0
2016-05-17 21:15:42,641 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:15:42,641 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-05-17 21:15:42,642 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CFB5DBE9E4D64F4896B22150CC111C29, mem on start (mb), free: 311, total: 705, max: 705
2016-05-17 21:15:42,644 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CFB5DBE9E4D64F4896B22150CC111C29, mem on close (mb), free: 311, total: 705, max: 705
2016-05-17 21:15:45,640 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testReplace/replace/_temporary
2016-05-17 21:15:45,641 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:03.058
2016-05-17 21:15:45,649 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testReplace/replace
2016-05-17 21:15:45,657 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:45,658 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:45,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 21:15:45,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:45,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:45,705 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-17 21:15:45,706 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:15:45,706 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-05-17 21:15:45,706 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-17 21:15:45,706 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-17 21:15:45,707 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-17 21:15:45,708 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...latform/testCount2/count2
2016-05-17 21:15:45,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local_0013
2016-05-17 21:15:45,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-17 21:15:45,750 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 21:15:45,765 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:45,765 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:45,770 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D2DCBD90FF5D4C22A6E98F144A83C591, ordinal: 0
2016-05-17 21:15:45,771 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:15:45,771 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:15:45,771 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2DCBD90FF5D4C22A6E98F144A83C591, mem on start (mb), free: 198, total: 705, max: 705
2016-05-17 21:15:45,774 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2DCBD90FF5D4C22A6E98F144A83C591, mem on close (mb), free: 198, total: 705, max: 705
2016-05-17 21:15:48,754 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:48,755 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:48,760 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F5BB5F88D7AB4FEBA65E873FD78F495B, ordinal: 1
2016-05-17 21:15:48,761 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:15:48,761 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-05-17 21:15:48,761 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F5BB5F88D7AB4FEBA65E873FD78F495B, mem on start (mb), free: 197, total: 705, max: 705
2016-05-17 21:15:48,767 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F5BB5F88D7AB4FEBA65E873FD78F495B, mem on close (mb), free: 197, total: 705, max: 705
2016-05-17 21:15:51,765 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount2/count2/_temporary
2016-05-17 21:15:51,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:06.059
2016-05-17 21:15:51,780 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount2/count2
2016-05-17 21:15:51,791 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:51,792 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:51,822 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 21:15:51,823 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:51,823 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:51,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-17 21:15:51,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:15:51,847 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-05-17 21:15:51,847 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-17 21:15:51,847 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-17 21:15:51,847 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-17 21:15:51,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...latform/testCount3/count3
2016-05-17 21:15:51,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local_0014
2016-05-17 21:15:51,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-17 21:15:51,879 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 21:15:51,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:51,970 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:51,974 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D34EC2D75FB846048DC0627205986A62, ordinal: 0
2016-05-17 21:15:51,975 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:15:51,975 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:15:51,975 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D34EC2D75FB846048DC0627205986A62, mem on start (mb), free: 84, total: 705, max: 705
2016-05-17 21:15:51,977 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D34EC2D75FB846048DC0627205986A62, mem on close (mb), free: 84, total: 705, max: 705
2016-05-17 21:15:54,891 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:15:54,891 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:15:54,897 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CEC87586CCF841EEA8F4AC84C7C6DBC3, ordinal: 1
2016-05-17 21:15:54,897 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:15:54,897 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-05-17 21:15:54,898 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CEC87586CCF841EEA8F4AC84C7C6DBC3, mem on start (mb), free: 313, total: 706, max: 706
2016-05-17 21:15:54,903 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CEC87586CCF841EEA8F4AC84C7C6DBC3, mem on close (mb), free: 312, total: 706, max: 706
2016-05-17 21:15:57,893 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount3/count3/_temporary
2016-05-17 21:15:57,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:06.049
2016-05-17 21:15:57,907 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount3/count3
2016-05-17 21:15:57,915 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:15:57,915 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:15:57,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 21:15:57,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:15:57,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:15:57,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-17 21:15:57,963 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:15:57,964 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-05-17 21:15:57,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-17 21:15:57,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-17 21:15:57,968 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-17 21:15:57,970 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...latform/testCount4/count4
2016-05-17 21:15:57,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local_0015
2016-05-17 21:15:57,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-17 21:15:57,999 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2016-05-17 21:15:58,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:15:58,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:15:58,019 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B32BCFE0CFF548DB9885248EFFFEB7B3, ordinal: 0
2016-05-17 21:15:58,020 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2016-05-17 21:15:58,020 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:15:58,021 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B32BCFE0CFF548DB9885248EFFFEB7B3, mem on start (mb), free: 197, total: 706, max: 706
2016-05-17 21:15:58,025 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B32BCFE0CFF548DB9885248EFFFEB7B3, mem on close (mb), free: 197, total: 706, max: 706
2016-05-17 21:16:01,003 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:16:01,003 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:16:01,008 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C2039427E0174EFA88FD7B65618E404C, ordinal: 1
2016-05-17 21:16:01,009 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-17 21:16:01,009 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-05-17 21:16:01,010 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2039427E0174EFA88FD7B65618E404C, mem on start (mb), free: 195, total: 706, max: 706
2016-05-17 21:16:01,016 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C2039427E0174EFA88FD7B65618E404C, mem on close (mb), free: 195, total: 706, max: 706
2016-05-17 21:16:04,004 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testCount4/count4/_temporary
2016-05-17 21:16:04,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:06.041
2016-05-17 21:16:04,023 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testCount4/count4
2016-05-17 21:16:04,030 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:16:04,030 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:16:04,056 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 21:16:04,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:16:04,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:16:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:16:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:16:04,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-05-17 21:16:04,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:16:04,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:16:04,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:16:04,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-05-17 21:16:04,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0016
2016-05-17 21:16:04,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:16:04,096 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:16:04,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:16:04,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:16:04,103 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4ABE63F151A45C494E3775792A90EDD, ordinal: 0
2016-05-17 21:16:04,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:16:04,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-05-17 21:16:04,104 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4ABE63F151A45C494E3775792A90EDD, mem on start (mb), free: 183, total: 706, max: 706
2016-05-17 21:16:04,105 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4ABE63F151A45C494E3775792A90EDD, mem on close (mb), free: 183, total: 706, max: 706
2016-05-17 21:16:07,106 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testFilter/filter/_temporary
2016-05-17 21:16:07,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:03.038
2016-05-17 21:16:07,114 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testFilter/filter
2016-05-17 21:16:07,124 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:16:07,125 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:16:07,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-17 21:16:07,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:16:07,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:16:07,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:16:07,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:16:07,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-05-17 21:16:07,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-17 21:16:07,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-17 21:16:07,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-17 21:16:07,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testSimple/simple
2016-05-17 21:16:07,203 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0017
2016-05-17 21:16:07,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:16:07,208 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:16:07,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:16:07,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:16:07,233 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB0DAE4C40324FDDA43D030FCEB5CD2E, ordinal: 0
2016-05-17 21:16:07,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:16:07,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:16:07,234 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB0DAE4C40324FDDA43D030FCEB5CD2E, mem on start (mb), free: 211, total: 705, max: 705
2016-05-17 21:16:07,237 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB0DAE4C40324FDDA43D030FCEB5CD2E, mem on close (mb), free: 211, total: 705, max: 705
2016-05-17 21:16:10,211 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:16:10,212 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:16:10,217 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A1355BA0984C414782E624810CFC1010, ordinal: 1
2016-05-17 21:16:10,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-17 21:16:10,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-05-17 21:16:10,218 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1355BA0984C414782E624810CFC1010, mem on start (mb), free: 209, total: 705, max: 705
2016-05-17 21:16:10,224 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A1355BA0984C414782E624810CFC1010, mem on close (mb), free: 209, total: 705, max: 705
2016-05-17 21:16:13,220 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/testSimple/simple/_temporary
2016-05-17 21:16:13,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:06.050
2016-05-17 21:16:13,228 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/testSimple/simple