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