2016-05-18 04:46:11,848 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 04:46:11,865 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop
2016-05-18 04:46:11,891 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 04:46:12,149 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 04:46:12,259 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:12,261 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-18 04:46:12,382 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 94C9A05A680E4D0A9364F4BA0292DEF4
2016-05-18 04:46:12,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.200
2016-05-18 04:46:12,631 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-18 04:46:12,631 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-18 04:46:12,847 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 04:46:12,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:12,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:12,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-05-18 04:46:12,850 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:12,851 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 2
2016-05-18 04:46:12,853 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:12,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/2)
2016-05-18 04:46:12,891 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 04:46:12,945 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 04:46:13,189 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local818490337_0001
2016-05-18 04:46:13,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:13,295 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:13,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:13,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:13,526 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE5F44A29EBF44CBB83B4F28305FBAFF, ordinal: 0
2016-05-18 04:46:13,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:13,580 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:13,581 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE5F44A29EBF44CBB83B4F28305FBAFF, mem on start (mb), free: 80, total: 223, max: 672
2016-05-18 04:46:13,598 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE5F44A29EBF44CBB83B4F28305FBAFF, mem on close (mb), free: 79, total: 223, max: 672
2016-05-18 04:46:13,637 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:13,638 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:13,656 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D4713E102CDA4EF9BC46F8E0C9C37236, ordinal: 1
2016-05-18 04:46:13,660 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:13,661 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][3256661497/test/]
2016-05-18 04:46:13,661 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D4713E102CDA4EF9BC46F8E0C9C37236, mem on start (mb), free: 77, total: 223, max: 672
2016-05-18 04:46:13,683 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D4713E102CDA4EF9BC46F8E0C9C37236, mem on close (mb), free: 76, total: 223, max: 672
2016-05-18 04:46:13,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2016-05-18 04:46:13,795 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1132614523_0002
2016-05-18 04:46:13,796 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:13,801 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/3256661497_test_F7D94881F30448EEA2322A4F65D86DA7/part-00000
2016-05-18 04:46:13,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:13,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:13,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D06FEABA752349A59F50818C906912DC, ordinal: 0
2016-05-18 04:46:13,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][3256661497/test/]
2016-05-18 04:46:13,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:13,922 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D06FEABA752349A59F50818C906912DC, mem on start (mb), free: 66, total: 318, max: 672
2016-05-18 04:46:13,924 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D06FEABA752349A59F50818C906912DC, mem on close (mb), free: 66, total: 318, max: 672
2016-05-18 04:46:13,938 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:13,939 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:13,953 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B112E3086E1444D6B67891D8903FFC47, ordinal: 1
2016-05-18 04:46:13,953 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:13,954 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain"]
2016-05-18 04:46:13,954 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B112E3086E1444D6B67891D8903FFC47, mem on start (mb), free: 65, total: 318, max: 672
2016-05-18 04:46:13,961 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B112E3086E1444D6B67891D8903FFC47, mem on close (mb), free: 64, total: 318, max: 672
2016-05-18 04:46:13,980 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleChain/simplechain/_temporary
2016-05-18 04:46:13,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:01.130
2016-05-18 04:46:14,005 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleChain/simplechain
2016-05-18 04:46:14,027 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:14,028 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-18 04:46:14,134 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-05-18 04:46:14,135 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:14,136 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-18 04:46:14,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-18 04:46:14,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:14,163 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-05-18 04:46:14,164 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-18 04:46:14,164 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-18 04:46:14,164 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-18 04:46:14,166 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...splatform/testCount/count
2016-05-18 04:46:14,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local127040132_0003
2016-05-18 04:46:14,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-18 04:46:14,252 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-05-18 04:46:14,322 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:14,322 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:14,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C11E777CAA7641AB8656F9C939E57DB8, ordinal: 0
2016-05-18 04:46:14,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:14,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:14,334 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C11E777CAA7641AB8656F9C939E57DB8, mem on start (mb), free: 68, total: 377, max: 672
2016-05-18 04:46:14,339 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C11E777CAA7641AB8656F9C939E57DB8, mem on close (mb), free: 68, total: 377, max: 672
2016-05-18 04:46:14,359 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:14,359 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:14,372 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D7370E4B8FBB4367B095A94844DAE634, ordinal: 1
2016-05-18 04:46:14,373 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:14,373 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount/count"]
2016-05-18 04:46:14,374 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7370E4B8FBB4367B095A94844DAE634, mem on start (mb), free: 66, total: 377, max: 672
2016-05-18 04:46:14,386 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7370E4B8FBB4367B095A94844DAE634, mem on close (mb), free: 66, total: 377, max: 672
2016-05-18 04:46:14,400 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount/count/_temporary
2016-05-18 04:46:14,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:00.241
2016-05-18 04:46:14,442 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount/count
2016-05-18 04:46:14,459 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:14,459 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-18 04:46:14,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-05-18 04:46:14,536 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:46:14,536 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-18 04:46:14,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:14,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:14,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-05-18 04:46:14,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:14,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:14,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:14,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-05-18 04:46:14,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1331352966_0004
2016-05-18 04:46:14,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:14,607 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:14,612 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:14,612 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:14,621 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A6319886512E4239B6F2E1B4EFDEEA02, ordinal: 0
2016-05-18 04:46:14,623 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:14,623 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap"]
2016-05-18 04:46:14,623 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A6319886512E4239B6F2E1B4EFDEEA02, mem on start (mb), free: 172, total: 377, max: 672
2016-05-18 04:46:14,626 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A6319886512E4239B6F2E1B4EFDEEA02, mem on close (mb), free: 172, total: 377, max: 672
2016-05-18 04:46:14,644 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSwap/swap/_temporary
2016-05-18 04:46:14,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.096
2016-05-18 04:46:14,654 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSwap/swap
2016-05-18 04:46:14,667 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:14,668 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-18 04:46:14,724 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 04:46:14,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:46:14,725 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-18 04:46:14,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:14,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 04:46:14,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-05-18 04:46:14,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:14,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:14,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:14,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-05-18 04:46:14,785 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1566444739_0005
2016-05-18 04:46:14,785 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:14,790 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower+upper.txt
2016-05-18 04:46:14,796 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:14,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:14,810 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB8A28C0EDA94115A8960419F2862879, ordinal: 0
2016-05-18 04:46:14,811 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2016-05-18 04:46:14,812 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped"]
2016-05-18 04:46:14,812 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB8A28C0EDA94115A8960419F2862879, mem on start (mb), free: 159, total: 377, max: 672
2016-05-18 04:46:14,815 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB8A28C0EDA94115A8960419F2862879, mem on close (mb), free: 159, total: 377, max: 672
2016-05-18 04:46:14,827 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testUnGroup/ungrouped/_temporary
2016-05-18 04:46:14,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.084
2016-05-18 04:46:14,836 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testUnGroup/ungrouped
2016-05-18 04:46:14,849 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:14,849 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-18 04:46:14,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 04:46:14,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:14,899 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-18 04:46:14,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:46:14,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-05-18 04:46:14,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:14,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-05-18 04:46:14,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: false
2016-05-18 04:46:14,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:46:14,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:46:14,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2016-05-18 04:46:14,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_local1181105564_0006
2016-05-18 04:46:14,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:8080/
2016-05-18 04:46:14,982 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt
2016-05-18 04:46:15,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:15,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:15,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACE7BF75A22144328CD16902A5874B00, ordinal: 0
2016-05-18 04:46:15,094 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:15,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-05-18 04:46:15,095 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACE7BF75A22144328CD16902A5874B00, mem on start (mb), free: 140, total: 472, max: 672
2016-05-18 04:46:15,098 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACE7BF75A22144328CD16902A5874B00, mem on close (mb), free: 140, total: 472, max: 672
2016-05-18 04:46:15,106 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/upper.txt
2016-05-18 04:46:15,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:15,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:15,212 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACE7BF75A22144328CD16902A5874B00, ordinal: 0
2016-05-18 04:46:15,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-05-18 04:46:15,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-05-18 04:46:15,214 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACE7BF75A22144328CD16902A5874B00, mem on start (mb), free: 135, total: 568, max: 672
2016-05-18 04:46:15,216 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACE7BF75A22144328CD16902A5874B00, mem on close (mb), free: 135, total: 568, max: 672
2016-05-18 04:46:15,231 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:15,231 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:15,237 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A5CD8BD937244492BF7A35B3B39F5481, ordinal: 1
2016-05-18 04:46:15,238 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2016-05-18 04:46:15,238 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2016-05-18 04:46:15,238 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A5CD8BD937244492BF7A35B3B39F5481, mem on start (mb), free: 133, total: 568, max: 672
2016-05-18 04:46:15,254 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 04:46:15,254 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 04:46:15,262 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A5CD8BD937244492BF7A35B3B39F5481, mem on close (mb), free: 132, total: 568, max: 672
2016-05-18 04:46:15,285 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2016-05-18 04:46:15,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:00.360
2016-05-18 04:46:15,304 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2016-05-18 04:46:15,319 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:15,320 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-18 04:46:15,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-18 04:46:15,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:15,368 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-18 04:46:15,391 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:15,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:15,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-05-18 04:46:15,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:15,395 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:15,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:15,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...leRelative/simplerelative
2016-05-18 04:46:15,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local314106026_0007
2016-05-18 04:46:15,430 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:15,435 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:15,529 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:15,529 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:15,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C8840555F90649F584F9012C06681E83, ordinal: 0
2016-05-18 04:46:15,537 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:15,537 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:15,537 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8840555F90649F584F9012C06681E83, mem on start (mb), free: 81, total: 630, max: 672
2016-05-18 04:46:15,539 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8840555F90649F584F9012C06681E83, mem on close (mb), free: 81, total: 630, max: 672
2016-05-18 04:46:15,550 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:15,550 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:15,557 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F2042C373B9A4159A82B3CCA3A3AF0BE, ordinal: 1
2016-05-18 04:46:15,558 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:15,558 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative"]
2016-05-18 04:46:15,558 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2042C373B9A4159A82B3CCA3A3AF0BE, mem on start (mb), free: 79, total: 630, max: 672
2016-05-18 04:46:15,563 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2042C373B9A4159A82B3CCA3A3AF0BE, mem on close (mb), free: 79, total: 630, max: 672
2016-05-18 04:46:15,576 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2016-05-18 04:46:15,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.185
2016-05-18 04:46:15,586 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleRelative/simplerelative
2016-05-18 04:46:15,777 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:15,778 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-18 04:46:15,830 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-05-18 04:46:15,833 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:15,833 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-18 04:46:15,862 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:15,862 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:15,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-05-18 04:46:15,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:15,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:15,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:15,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2016-05-18 04:46:15,905 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local2085385325_0008
2016-05-18 04:46:15,906 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:15,912 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt
2016-05-18 04:46:15,957 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:15,957 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:15,965 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B139536116904924950DB8C93B4767A4, ordinal: 0
2016-05-18 04:46:15,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:15,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:15,968 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B139536116904924950DB8C93B4767A4, mem on start (mb), free: 161, total: 746, max: 746
2016-05-18 04:46:16,052 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B139536116904924950DB8C93B4767A4, mem on close (mb), free: 157, total: 746, max: 746
2016-05-18 04:46:16,062 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:16,062 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,069 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FDD2CA415BC84F1E9621371830F8B080, ordinal: 1
2016-05-18 04:46:16,070 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:16,070 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult"]
2016-05-18 04:46:16,070 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FDD2CA415BC84F1E9621371830F8B080, mem on start (mb), free: 154, total: 746, max: 746
2016-05-18 04:46:16,075 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FDD2CA415BC84F1E9621371830F8B080, mem on close (mb), free: 154, total: 746, max: 746
2016-05-18 04:46:16,087 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2016-05-18 04:46:16,088 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.225
2016-05-18 04:46:16,098 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleResult/simpleresult
2016-05-18 04:46:16,107 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:16,108 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-18 04:46:16,138 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 04:46:16,142 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:46:16,142 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-18 04:46:16,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:16,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:16,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-05-18 04:46:16,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:16,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:16,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:16,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-05-18 04:46:16,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1069462076_0009
2016-05-18 04:46:16,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:16,189 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:16,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:16,193 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,199 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EBE5E62A9A834BDF8F4E85B6C0CAB549, ordinal: 0
2016-05-18 04:46:16,200 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:16,200 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall"]
2016-05-18 04:46:16,201 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBE5E62A9A834BDF8F4E85B6C0CAB549, mem on start (mb), free: 138, total: 746, max: 746
2016-05-18 04:46:16,202 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBE5E62A9A834BDF8F4E85B6C0CAB549, mem on close (mb), free: 138, total: 746, max: 746
2016-05-18 04:46:16,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilterAll/filterall/_temporary
2016-05-18 04:46:16,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.065
2016-05-18 04:46:16,227 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testFilterAll/filterall
2016-05-18 04:46:16,236 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:16,237 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-18 04:46:16,275 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 04:46:16,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:16,277 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-18 04:46:16,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:16,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:16,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-05-18 04:46:16,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:16,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:16,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:16,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2016-05-18 04:46:16,328 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1302495978_0010
2016-05-18 04:46:16,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:16,334 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt
2016-05-18 04:46:16,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:16,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BAC8BF76885E46C0B55B75C85F0362AF, ordinal: 0
2016-05-18 04:46:16,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:16,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2016-05-18 04:46:16,375 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAC8BF76885E46C0B55B75C85F0362AF, mem on start (mb), free: 163, total: 746, max: 746
2016-05-18 04:46:16,377 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAC8BF76885E46C0B55B75C85F0362AF, mem on close (mb), free: 163, total: 746, max: 746
2016-05-18 04:46:16,386 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:16,387 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,394 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DE4071D0C24142B29F91EB14218C196D, ordinal: 1
2016-05-18 04:46:16,394 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2016-05-18 04:46:16,395 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2016-05-18 04:46:16,395 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE4071D0C24142B29F91EB14218C196D, mem on start (mb), free: 160, total: 746, max: 746
2016-05-18 04:46:16,404 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DE4071D0C24142B29F91EB14218C196D, mem on close (mb), free: 160, total: 746, max: 746
2016-05-18 04:46:16,416 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2016-05-18 04:46:16,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.121
2016-05-18 04:46:16,424 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2016-05-18 04:46:16,433 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:16,433 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-18 04:46:16,479 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-18 04:46:16,481 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:16,481 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-18 04:46:16,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 04:46:16,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-05-18 04:46:16,505 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:16,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-05-18 04:46:16,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: false
2016-05-18 04:46:16,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 04:46:16,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 04:46:16,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2016-05-18 04:46:16,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_local1683393708_0011
2016-05-18 04:46:16,555 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:8080/
2016-05-18 04:46:16,562 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/upper.txt
2016-05-18 04:46:16,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:16,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,685 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCF15BF3E2B04B8984894B0EA2D8DFA2, ordinal: 0
2016-05-18 04:46:16,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/upper.txt"]
2016-05-18 04:46:16,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-05-18 04:46:16,687 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCF15BF3E2B04B8984894B0EA2D8DFA2, mem on start (mb), free: 43, total: 746, max: 746
2016-05-18 04:46:16,689 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCF15BF3E2B04B8984894B0EA2D8DFA2, mem on close (mb), free: 43, total: 746, max: 746
2016-05-18 04:46:16,700 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt
2016-05-18 04:46:16,731 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:16,731 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,739 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCF15BF3E2B04B8984894B0EA2D8DFA2, ordinal: 0
2016-05-18 04:46:16,740 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/lower.txt"]
2016-05-18 04:46:16,740 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-05-18 04:46:16,740 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCF15BF3E2B04B8984894B0EA2D8DFA2, mem on start (mb), free: 163, total: 746, max: 746
2016-05-18 04:46:16,742 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCF15BF3E2B04B8984894B0EA2D8DFA2, mem on close (mb), free: 163, total: 746, max: 746
2016-05-18 04:46:16,759 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:16,759 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,769 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D60BEC13A0154341B2B221B31B1602DE, ordinal: 1
2016-05-18 04:46:16,770 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2016-05-18 04:46:16,770 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup"]
2016-05-18 04:46:16,771 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D60BEC13A0154341B2B221B31B1602DE, mem on start (mb), free: 161, total: 746, max: 746
2016-05-18 04:46:16,777 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 04:46:16,778 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-18 04:46:16,780 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D60BEC13A0154341B2B221B31B1602DE, mem on close (mb), free: 160, total: 746, max: 746
2016-05-18 04:46:16,801 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2016-05-18 04:46:16,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:00.296
2016-05-18 04:46:16,826 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCoGroup/complexcogroup
2016-05-18 04:46:16,839 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:16,839 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-18 04:46:16,865 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 04:46:16,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:46:16,866 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-18 04:46:16,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:16,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:16,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-05-18 04:46:16,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:16,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:16,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:16,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-05-18 04:46:16,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local661537641_0012
2016-05-18 04:46:16,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:16,910 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:16,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:16,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:16,919 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F30675BCDED5476AB4F2B4FFFECB0F33, ordinal: 0
2016-05-18 04:46:16,919 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:16,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace"]
2016-05-18 04:46:16,920 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F30675BCDED5476AB4F2B4FFFECB0F33, mem on start (mb), free: 145, total: 746, max: 746
2016-05-18 04:46:16,921 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F30675BCDED5476AB4F2B4FFFECB0F33, mem on close (mb), free: 145, total: 746, max: 746
2016-05-18 04:46:16,936 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testReplace/replace/_temporary
2016-05-18 04:46:16,937 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.062
2016-05-18 04:46:16,946 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testReplace/replace
2016-05-18 04:46:16,956 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:16,956 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-18 04:46:16,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 04:46:16,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:16,995 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-18 04:46:17,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-18 04:46:17,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:17,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-05-18 04:46:17,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-18 04:46:17,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-18 04:46:17,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-18 04:46:17,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...latform/testCount2/count2
2016-05-18 04:46:17,038 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local1246900337_0013
2016-05-18 04:46:17,039 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-18 04:46:17,043 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-05-18 04:46:17,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:17,263 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,268 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E88F2CB425724D64BAB0B2A4823CD120, ordinal: 0
2016-05-18 04:46:17,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:17,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:17,269 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E88F2CB425724D64BAB0B2A4823CD120, mem on start (mb), free: 336, total: 443, max: 672
2016-05-18 04:46:17,271 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E88F2CB425724D64BAB0B2A4823CD120, mem on close (mb), free: 336, total: 443, max: 672
2016-05-18 04:46:17,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:17,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,286 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C467A0BC8F8B43DE870E6B5C6AC01BB4, ordinal: 1
2016-05-18 04:46:17,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:17,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2"]
2016-05-18 04:46:17,288 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C467A0BC8F8B43DE870E6B5C6AC01BB4, mem on start (mb), free: 333, total: 443, max: 672
2016-05-18 04:46:17,296 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C467A0BC8F8B43DE870E6B5C6AC01BB4, mem on close (mb), free: 333, total: 443, max: 672
2016-05-18 04:46:17,312 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount2/count2/_temporary
2016-05-18 04:46:17,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:00.305
2016-05-18 04:46:17,334 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount2/count2
2016-05-18 04:46:17,345 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:17,346 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-18 04:46:17,381 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 04:46:17,382 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:17,382 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-18 04:46:17,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-18 04:46:17,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:17,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-05-18 04:46:17,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-18 04:46:17,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-18 04:46:17,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-18 04:46:17,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...latform/testCount3/count3
2016-05-18 04:46:17,426 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local1190376999_0014
2016-05-18 04:46:17,426 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-18 04:46:17,434 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-05-18 04:46:17,449 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:17,449 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,454 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3BF6046FE91439494F89A83C66CB5E7, ordinal: 0
2016-05-18 04:46:17,454 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:17,454 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:17,454 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3BF6046FE91439494F89A83C66CB5E7, mem on start (mb), free: 218, total: 443, max: 672
2016-05-18 04:46:17,457 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3BF6046FE91439494F89A83C66CB5E7, mem on close (mb), free: 218, total: 443, max: 672
2016-05-18 04:46:17,468 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:17,468 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,473 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FB39045534C941E5AA6073EFCC4EFE23, ordinal: 1
2016-05-18 04:46:17,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:17,474 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3"]
2016-05-18 04:46:17,474 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB39045534C941E5AA6073EFCC4EFE23, mem on start (mb), free: 216, total: 443, max: 672
2016-05-18 04:46:17,480 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FB39045534C941E5AA6073EFCC4EFE23, mem on close (mb), free: 215, total: 443, max: 672
2016-05-18 04:46:17,495 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount3/count3/_temporary
2016-05-18 04:46:17,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:00.093
2016-05-18 04:46:17,509 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount3/count3
2016-05-18 04:46:17,516 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:17,516 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-18 04:46:17,542 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 04:46:17,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:17,543 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-18 04:46:17,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting
2016-05-18 04:46:17,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:17,557 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-05-18 04:46:17,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] parallel execution of steps is enabled: false
2016-05-18 04:46:17,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] executing total steps: 1
2016-05-18 04:46:17,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] allocating management threads: 1
2016-05-18 04:46:17,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] starting step: (1/1) ...latform/testCount4/count4
2016-05-18 04:46:17,583 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] submitted hadoop job: job_local806902361_0015
2016-05-18 04:46:17,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] tracking url: http://localhost:8080/
2016-05-18 04:46:17,588 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt
2016-05-18 04:46:17,605 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:17,605 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F8D39FD8D1704693A52244E66FCD0FFB, ordinal: 0
2016-05-18 04:46:17,611 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2016-05-18 04:46:17,611 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:17,612 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8D39FD8D1704693A52244E66FCD0FFB, mem on start (mb), free: 235, total: 443, max: 672
2016-05-18 04:46:17,615 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8D39FD8D1704693A52244E66FCD0FFB, mem on close (mb), free: 235, total: 443, max: 672
2016-05-18 04:46:17,625 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:17,625 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,630 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DCFABF185731411892FBE543C0C33DD7, ordinal: 1
2016-05-18 04:46:17,631 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2016-05-18 04:46:17,631 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4"]
2016-05-18 04:46:17,631 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DCFABF185731411892FBE543C0C33DD7, mem on start (mb), free: 232, total: 443, max: 672
2016-05-18 04:46:17,637 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DCFABF185731411892FBE543C0C33DD7, mem on close (mb), free: 232, total: 443, max: 672
2016-05-18 04:46:17,647 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testCount4/count4/_temporary
2016-05-18 04:46:17,647 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [count] completed in: 00:00.089
2016-05-18 04:46:17,662 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testCount4/count4
2016-05-18 04:46:17,669 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:17,669 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-18 04:46:17,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 04:46:17,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 04:46:17,690 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-18 04:46:17,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:17,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:17,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-05-18 04:46:17,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:17,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:17,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:17,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-05-18 04:46:17,721 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1054791739_0016
2016-05-18 04:46:17,722 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:17,725 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:17,728 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:17,728 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4C6CA118E48493894DAD0B101E20D19, ordinal: 0
2016-05-18 04:46:17,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:17,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter"]
2016-05-18 04:46:17,735 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4C6CA118E48493894DAD0B101E20D19, mem on start (mb), free: 218, total: 443, max: 672
2016-05-18 04:46:17,736 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4C6CA118E48493894DAD0B101E20D19, mem on close (mb), free: 217, total: 443, max: 672
2016-05-18 04:46:17,754 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testFilter/filter/_temporary
2016-05-18 04:46:17,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.056
2016-05-18 04:46:17,761 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testFilter/filter
2016-05-18 04:46:17,771 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 04:46:17,771 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-18 04:46:17,805 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 04:46:17,806 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 04:46:17,806 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-18 04:46:17,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-18 04:46:17,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:17,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-05-18 04:46:17,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] parallel execution of steps is enabled: false
2016-05-18 04:46:17,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executing total steps: 1
2016-05-18 04:46:17,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] allocating management threads: 1
2016-05-18 04:46:17,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...latform/testSimple/simple
2016-05-18 04:46:17,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1060501677_0017
2016-05-18 04:46:17,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-18 04:46:17,862 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt
2016-05-18 04:46:17,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 04:46:17,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D0AABE79BBF74C2694FE7E8B3FBBC5EB, ordinal: 0
2016-05-18 04:46:17,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2016-05-18 04:46:17,885 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:17,885 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D0AABE79BBF74C2694FE7E8B3FBBC5EB, mem on start (mb), free: 104, total: 443, max: 672
2016-05-18 04:46:17,887 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D0AABE79BBF74C2694FE7E8B3FBBC5EB, mem on close (mb), free: 104, total: 443, max: 672
2016-05-18 04:46:17,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-18 04:46:17,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-18 04:46:17,905 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C1C2F60BF6BA47948C6DA86C6E9B2EB4, ordinal: 1
2016-05-18 04:46:17,906 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2016-05-18 04:46:17,907 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple"]
2016-05-18 04:46:17,907 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C1C2F60BF6BA47948C6DA86C6E9B2EB4, mem on start (mb), free: 103, total: 443, max: 672
2016-05-18 04:46:17,917 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C1C2F60BF6BA47948C6DA86C6E9B2EB4, mem on close (mb), free: 335, total: 443, max: 672
2016-05-18 04:46:17,931 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/testSimple/simple/_temporary
2016-05-18 04:46:17,932 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] completed in: 00:00.112
2016-05-18 04:46:17,939 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/testSimple/simple