Class cascading.BasicPipesPlatformTest

14

tests

0

failures

6.281s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 0.757s passed
testCount 0.395s passed
testCount2 0.345s passed
testCount3 0.318s passed
testCount4 0.294s passed
testFilter 0.110s passed
testFilterAll 0.147s passed
testReplace 0.125s passed
testSimple 0.470s passed
testSimpleChain 1.936s passed
testSimpleRelative 0.357s passed
testSimpleResult 0.688s passed
testSwap 0.181s passed
testUnGroup 0.158s passed

Standard output

2015-02-10 15:27:18,948 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 15:27:18,997 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 15:27:18,997 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2015-02-10 15:27:19,032 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 15:27:19,441 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:19,443 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:19,457 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 01C4C80560CF4260A154F42A17A5E7F1
2015-02-10 15:27:19,712 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 15:27:19,715 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:19,716 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:19,716 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-02-10 15:27:19,717 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:19,717 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 2
2015-02-10 15:27:19,717 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:19,719 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/2)
2015-02-10 15:27:19,767 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-10 15:27:19,832 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 15:27:19,836 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:20,088 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0001
2015-02-10 15:27:20,091 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:20,162 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 15:27:20,172 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@24a09e41
2015-02-10 15:27:20,180 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:20,188 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:20,197 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:20,339 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:20,339 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:20,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:20,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,435 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:20,436 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,451 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:20,465 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:20,468 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,472 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:20,474 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0001_m_000000_0' done.
2015-02-10 15:27:20,485 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@540523be
2015-02-10 15:27:20,485 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:20,492 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:20,499 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2015-02-10 15:27:20,499 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:20,502 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:20,502 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,523 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,523 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][2772040731/test/]
2015-02-10 15:27:20,550 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,551 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:20,552 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2015-02-10 15:27:20,556 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/tmp/hadoop-teamcity/2772040731_test_4A75CC09A8C84718A290FE53DBC671B2
2015-02-10 15:27:20,557 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:20,558 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0001_r_000000_0' done.
2015-02-10 15:27:20,565 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2015-02-10 15:27:20,584 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:20,687 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0002
2015-02-10 15:27:20,688 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:20,694 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@19123eb0
2015-02-10 15:27:20,696 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/2772040731_test_4A75CC09A8C84718A290FE53DBC671B2/part-00000
2015-02-10 15:27:20,705 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:20,706 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:20,848 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:20,849 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:20,851 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:20,851 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,866 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][2772040731/test/]
2015-02-10 15:27:20,866 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,869 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:20,873 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:20,876 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,877 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/tmp/hadoop-teamcity/2772040731_test_4A75CC09A8C84718A290FE53DBC671B2/part-00000:0+310
2015-02-10 15:27:20,878 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0002_m_000000_0' done.
2015-02-10 15:27:20,884 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@42bb0406
2015-02-10 15:27:20,884 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:20,886 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:20,886 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 202 bytes
2015-02-10 15:27:20,887 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:20,888 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:20,888 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,899 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,900 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-02-10 15:27:20,909 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,910 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:20,911 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2015-02-10 15:27:20,915 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain
2015-02-10 15:27:20,916 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:20,916 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0002_r_000000_0' done.
2015-02-10 15:27:20,934 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2015-02-10 15:27:20,957 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:20,965 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplechain
2015-02-10 15:27:20,990 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:20,991 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:21,017 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:21,018 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:21,018 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-02-10 15:27:21,019 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  parallel execution is enabled: false
2015-02-10 15:27:21,019 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  starting jobs: 1
2015-02-10 15:27:21,019 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  allocating threads: 1
2015-02-10 15:27:21,021 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) .../basicpipesplatform/count
2015-02-10 15:27:21,037 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,101 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0003
2015-02-10 15:27:21,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:21,105 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@279977bd
2015-02-10 15:27:21,107 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:21,109 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:21,109 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:21,243 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:21,243 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:21,245 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,245 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,256 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:21,256 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:21,261 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:21,267 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:21,269 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,271 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:21,272 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0003_m_000000_0' done.
2015-02-10 15:27:21,277 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1a3526cf
2015-02-10 15:27:21,277 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:21,279 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:21,279 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 15:27:21,280 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:21,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:21,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,290 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:21,290 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-02-10 15:27:21,301 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,302 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:21,303 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2015-02-10 15:27:21,307 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count
2015-02-10 15:27:21,307 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:21,308 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0003_r_000000_0' done.
2015-02-10 15:27:21,315 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count/_temporary
2015-02-10 15:27:21,337 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,359 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,362 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count
2015-02-10 15:27:21,383 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:21,384 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:21,406 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:21,407 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,407 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-02-10 15:27:21,407 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:21,408 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:21,408 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:21,408 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2015-02-10 15:27:21,425 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,478 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0004
2015-02-10 15:27:21,478 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:21,482 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@665c1eae
2015-02-10 15:27:21,484 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:21,485 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:21,492 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,492 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,501 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,501 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-02-10 15:27:21,505 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,506 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:21,507 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2015-02-10 15:27:21,511 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap
2015-02-10 15:27:21,511 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:21,512 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0004_m_000000_0' done.
2015-02-10 15:27:21,519 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2015-02-10 15:27:21,541 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,545 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/swap
2015-02-10 15:27:21,562 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:21,563 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:21,587 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:21,588 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2015-02-10 15:27:21,588 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-02-10 15:27:21,588 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:21,590 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2015-02-10 15:27:21,605 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,645 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0005
2015-02-10 15:27:21,646 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:21,650 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5dd6c336
2015-02-10 15:27:21,651 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt
2015-02-10 15:27:21,653 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:21,658 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,658 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,667 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2015-02-10 15:27:21,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-02-10 15:27:21,670 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,671 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:21,672 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2015-02-10 15:27:21,676 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped
2015-02-10 15:27:21,676 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt:0+30
2015-02-10 15:27:21,677 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0005_m_000000_0' done.
2015-02-10 15:27:21,687 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2015-02-10 15:27:21,701 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,704 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/ungrouped
2015-02-10 15:27:21,720 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:21,721 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:21,750 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:21,751 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,752 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-02-10 15:27:21,753 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:21,753 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:21,754 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:21,755 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...esplatform/simplerelative
2015-02-10 15:27:21,769 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,809 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0006
2015-02-10 15:27:21,810 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:21,813 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@30db95a1
2015-02-10 15:27:21,815 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:21,816 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:21,817 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:21,974 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:21,974 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:21,976 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,976 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,986 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,987 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:21,990 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:21,994 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:21,996 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:21,998 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0006_m_000000_0' done.
2015-02-10 15:27:22,003 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2755d4be
2015-02-10 15:27:22,003 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,005 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:22,005 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2015-02-10 15:27:22,006 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,007 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:22,007 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,016 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:22,017 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-02-10 15:27:22,025 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,026 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,027 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0006_r_000000_0 is allowed to commit now
2015-02-10 15:27:22,030 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative
2015-02-10 15:27:22,031 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:22,032 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0006_r_000000_0' done.
2015-02-10 15:27:22,044 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2015-02-10 15:27:22,059 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,062 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplerelative
2015-02-10 15:27:22,312 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:22,313 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:22,349 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:22,349 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:22,350 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-02-10 15:27:22,350 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:22,351 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:22,351 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:22,353 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2015-02-10 15:27:22,368 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,404 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0007
2015-02-10 15:27:22,406 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:22,410 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b5ede11
2015-02-10 15:27:22,412 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt
2015-02-10 15:27:22,413 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:22,413 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:22,548 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:22,548 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:22,550 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:22,550 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:22,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:22,665 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:22,667 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:22,669 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,671 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt:0+19
2015-02-10 15:27:22,672 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0007_m_000000_0' done.
2015-02-10 15:27:22,676 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2a5b8e8c
2015-02-10 15:27:22,676 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,677 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:22,678 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 28 bytes
2015-02-10 15:27:22,678 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,679 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:22,679 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,690 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:22,691 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-02-10 15:27:22,696 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,697 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,698 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0007_r_000000_0 is allowed to commit now
2015-02-10 15:27:22,701 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult
2015-02-10 15:27:22,701 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:22,702 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0007_r_000000_0' done.
2015-02-10 15:27:22,710 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2015-02-10 15:27:22,750 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,752 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simpleresult
2015-02-10 15:27:22,764 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:22,765 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:22,798 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:22,799 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:22,799 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-02-10 15:27:22,800 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:22,800 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:22,800 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:22,801 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2015-02-10 15:27:22,813 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,844 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0008
2015-02-10 15:27:22,845 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:22,849 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7d1050be
2015-02-10 15:27:22,851 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:22,852 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:22,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:22,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:22,865 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-02-10 15:27:22,868 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,869 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:22,869 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2015-02-10 15:27:22,873 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall
2015-02-10 15:27:22,873 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:22,874 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0008_m_000000_0' done.
2015-02-10 15:27:22,887 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2015-02-10 15:27:22,898 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,900 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/filterall
2015-02-10 15:27:22,913 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:22,914 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:22,946 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] starting
2015-02-10 15:27:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-02-10 15:27:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-02-10 15:27:22,948 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper]  parallel execution is enabled: false
2015-02-10 15:27:22,948 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper]  starting jobs: 1
2015-02-10 15:27:22,948 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper]  allocating threads: 1
2015-02-10 15:27:22,949 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2015-02-10 15:27:22,961 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,962 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,989 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] submitted hadoop job: job_local_0009
2015-02-10 15:27:22,990 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] tracking url: http://localhost:8080/
2015-02-10 15:27:22,993 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@16365c90
2015-02-10 15:27:22,995 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt
2015-02-10 15:27:22,997 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:22,997 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:23,370 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:23,373 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:23,377 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:23,377 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,389 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-02-10 15:27:23,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 15:27:23,393 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:23,396 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:23,398 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:23,399 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt:0+19
2015-02-10 15:27:23,401 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0009_m_000000_0' done.
2015-02-10 15:27:23,403 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@78d2883b
2015-02-10 15:27:23,405 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt
2015-02-10 15:27:23,406 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:23,407 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:23,548 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:23,549 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:23,550 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:23,551 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,561 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:23,562 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 15:27:23,564 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:23,567 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:23,569 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0009_m_000001_0 is done. And is in the process of commiting
2015-02-10 15:27:23,571 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt:0+19
2015-02-10 15:27:23,572 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0009_m_000001_0' done.
2015-02-10 15:27:23,580 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5cee644c
2015-02-10 15:27:23,580 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:23,582 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2015-02-10 15:27:23,583 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2015-02-10 15:27:23,584 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:23,585 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:23,586 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,594 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 15:27:23,595 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-02-10 15:27:23,607 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 15:27:23,607 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 15:27:23,615 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:23,616 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:23,618 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0009_r_000000_0 is allowed to commit now
2015-02-10 15:27:23,621 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup
2015-02-10 15:27:23,622 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:23,623 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0009_r_000000_0' done.
2015-02-10 15:27:23,633 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2015-02-10 15:27:23,644 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,656 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,658 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/complexcogroup
2015-02-10 15:27:23,669 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:23,670 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:23,685 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:23,686 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:23,686 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-02-10 15:27:23,686 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:23,687 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:23,687 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:23,687 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2015-02-10 15:27:23,699 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,728 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0010
2015-02-10 15:27:23,728 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:23,733 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@87e05c4
2015-02-10 15:27:23,734 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:23,736 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:23,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:23,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:23,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-02-10 15:27:23,751 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:23,753 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:23,754 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0010_m_000000_0 is allowed to commit now
2015-02-10 15:27:23,757 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0010_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace
2015-02-10 15:27:23,758 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:23,759 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0010_m_000000_0' done.
2015-02-10 15:27:23,770 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2015-02-10 15:27:23,781 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/replace
2015-02-10 15:27:23,796 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:23,797 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:23,817 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:23,817 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:23,817 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-02-10 15:27:23,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  parallel execution is enabled: false
2015-02-10 15:27:23,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  starting jobs: 1
2015-02-10 15:27:23,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  allocating threads: 1
2015-02-10 15:27:23,819 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2015-02-10 15:27:23,830 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,858 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0011
2015-02-10 15:27:23,859 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:23,864 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6efde050
2015-02-10 15:27:23,866 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:23,868 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:23,869 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:24,036 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:24,036 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:24,038 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,039 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,048 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,048 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,052 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:24,057 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:24,060 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,061 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:24,062 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0011_m_000000_0' done.
2015-02-10 15:27:24,067 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6647108e
2015-02-10 15:27:24,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,069 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:24,069 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 15:27:24,070 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,071 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:24,071 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,079 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,079 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-02-10 15:27:24,090 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,092 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,093 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2015-02-10 15:27:24,096 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0011_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2
2015-02-10 15:27:24,097 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:24,098 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0011_r_000000_0' done.
2015-02-10 15:27:24,103 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2015-02-10 15:27:24,115 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,128 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,130 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count2
2015-02-10 15:27:24,147 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,148 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:24,170 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:24,170 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,170 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-02-10 15:27:24,171 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  parallel execution is enabled: false
2015-02-10 15:27:24,171 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  starting jobs: 1
2015-02-10 15:27:24,171 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  allocating threads: 1
2015-02-10 15:27:24,172 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2015-02-10 15:27:24,184 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,223 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0012
2015-02-10 15:27:24,229 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:24,233 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5ac524dd
2015-02-10 15:27:24,234 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:24,236 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:24,236 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:24,370 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:24,370 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:24,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,372 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,383 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:24,387 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:24,388 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,390 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:24,390 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0012_m_000000_0' done.
2015-02-10 15:27:24,394 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@59bd523d
2015-02-10 15:27:24,394 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,395 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:24,396 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 15:27:24,396 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,397 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:24,397 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,404 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,404 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-02-10 15:27:24,412 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0012_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,413 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,413 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0012_r_000000_0 is allowed to commit now
2015-02-10 15:27:24,416 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0012_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3
2015-02-10 15:27:24,417 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:24,417 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0012_r_000000_0' done.
2015-02-10 15:27:24,423 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2015-02-10 15:27:24,434 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,447 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,449 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count3
2015-02-10 15:27:24,462 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,463 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:24,480 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:24,480 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,481 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-02-10 15:27:24,481 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  parallel execution is enabled: false
2015-02-10 15:27:24,481 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  starting jobs: 1
2015-02-10 15:27:24,481 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [count]  allocating threads: 1
2015-02-10 15:27:24,483 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2015-02-10 15:27:24,494 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,518 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0013
2015-02-10 15:27:24,518 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:24,522 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@30a4effe
2015-02-10 15:27:24,523 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:24,524 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:24,525 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:24,663 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:24,664 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:24,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,677 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:24,681 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:24,683 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,684 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:24,685 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0013_m_000000_0' done.
2015-02-10 15:27:24,689 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3a47c130
2015-02-10 15:27:24,689 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,691 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:24,691 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 15:27:24,691 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,692 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:24,692 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,699 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,699 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-02-10 15:27:24,708 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0013_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,708 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,709 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0013_r_000000_0 is allowed to commit now
2015-02-10 15:27:24,713 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4
2015-02-10 15:27:24,715 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:24,716 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0013_r_000000_0' done.
2015-02-10 15:27:24,722 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2015-02-10 15:27:24,731 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,741 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,743 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count4
2015-02-10 15:27:24,755 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,755 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:24,769 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:24,771 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:24,771 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-02-10 15:27:24,772 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:24,772 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:24,772 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:24,773 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2015-02-10 15:27:24,784 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,808 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0014
2015-02-10 15:27:24,809 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:24,812 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@63376afa
2015-02-10 15:27:24,813 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:24,815 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:24,818 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,818 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,824 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:24,825 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-02-10 15:27:24,827 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,827 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:24,828 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2015-02-10 15:27:24,831 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter
2015-02-10 15:27:24,831 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:24,832 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0014_m_000000_0' done.
2015-02-10 15:27:24,841 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2015-02-10 15:27:24,852 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,853 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/filter
2015-02-10 15:27:24,865 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,865 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 15:27:24,884 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:24,885 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:24,885 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-02-10 15:27:24,885 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  parallel execution is enabled: false
2015-02-10 15:27:24,885 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  starting jobs: 1
2015-02-10 15:27:24,885 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [test]  allocating threads: 1
2015-02-10 15:27:24,886 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2015-02-10 15:27:24,898 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,922 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0015
2015-02-10 15:27:24,923 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:24,925 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@538787fd
2015-02-10 15:27:24,928 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:24,929 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:24,929 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:25,262 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:25,262 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:25,264 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:25,264 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:25,273 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:25,273 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:25,276 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:25,279 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:25,280 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:25,282 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:25,282 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0015_m_000000_0' done.
2015-02-10 15:27:25,285 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@161e14f0
2015-02-10 15:27:25,286 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:25,287 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:25,287 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2015-02-10 15:27:25,287 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:25,288 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:25,288 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:25,296 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:25,297 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-02-10 15:27:25,302 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local_0015_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:25,303 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - 
2015-02-10 15:27:25,304 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local_0015_r_000000_0 is allowed to commit now
2015-02-10 15:27:25,306 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple
2015-02-10 15:27:25,306 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:25,307 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0015_r_000000_0' done.
2015-02-10 15:27:25,313 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2015-02-10 15:27:25,322 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:25,324 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simple