Class cascading.BasicPipesPlatformTest

14

tests

0

failures

5.560s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 0.702s passed
testCount 0.353s passed
testCount2 0.300s passed
testCount3 0.283s passed
testCount4 0.258s passed
testFilter 0.111s passed
testFilterAll 0.131s passed
testReplace 0.169s passed
testSimple 0.249s passed
testSimpleChain 1.792s passed
testSimpleRelative 0.292s passed
testSimpleResult 0.623s passed
testSwap 0.144s passed
testUnGroup 0.153s passed

Standard output

2013-11-20 13:50:13,331 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 13:50:13,359 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 13:50:13,359 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2013-11-20 13:50:13,391 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 13:50:13,766 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:13,768 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:13,780 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: 4A5790EF06C84D85B0D212D2DEDD1EA3
2013-11-20 13:50:13,996 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 13:50:13,999 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:14,000 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:14,000 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-11-20 13:50:14,000 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:14,001 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 2
2013-11-20 13:50:14,001 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:14,002 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/2)
2013-11-20 13:50:14,046 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 13:50:14,111 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-11-20 13:50:14,118 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:14,323 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local918606867_0001
2013-11-20 13:50:14,354 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:14,358 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local918606867_0001_m_000000_0
2013-11-20 13:50:14,413 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 13:50:14,421 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@552a66ea
2013-11-20 13:50:14,429 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:14,430 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6b96bac4
2013-11-20 13:50:14,436 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:14,444 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:14,633 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:14,633 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:14,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:14,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:14,715 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:14,716 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:14,728 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:14,740 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:14,743 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local918606867_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:14,748 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:14,748 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local918606867_0001_m_000000_0' done.
2013-11-20 13:50:14,749 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local918606867_0001_m_000000_0
2013-11-20 13:50:14,749 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:14,760 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7b603522
2013-11-20 13:50:14,761 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:14,767 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:14,773 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 13:50:14,774 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:14,775 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:14,775 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:14,793 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:14,793 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][2350144917/test/]
2013-11-20 13:50:14,816 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local918606867_0001_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:14,818 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:14,819 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local918606867_0001_r_000000_0 is allowed to commit now
2013-11-20 13:50:14,822 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local918606867_0001_r_000000_0' to file:/tmp/hadoop-teamcity/2350144917_test_957AFA70A52C493186788B5131189605
2013-11-20 13:50:14,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:14,824 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local918606867_0001_r_000000_0' done.
2013-11-20 13:50:14,834 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2013-11-20 13:50:14,850 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:14,941 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local137568485_0002
2013-11-20 13:50:14,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:14,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local137568485_0002_m_000000_0
2013-11-20 13:50:14,948 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2bf8f8c8
2013-11-20 13:50:14,950 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/2350144917_test_957AFA70A52C493186788B5131189605/part-00000
2013-11-20 13:50:14,950 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@23faa614
2013-11-20 13:50:14,957 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:14,958 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:15,079 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:15,080 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:15,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:15,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:15,096 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][2350144917/test/]
2013-11-20 13:50:15,096 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:15,099 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:15,102 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:15,104 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local137568485_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:15,107 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/tmp/hadoop-teamcity/2350144917_test_957AFA70A52C493186788B5131189605/part-00000:0+310
2013-11-20 13:50:15,108 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local137568485_0002_m_000000_0' done.
2013-11-20 13:50:15,108 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local137568485_0002_m_000000_0
2013-11-20 13:50:15,108 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:15,114 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@156a9424
2013-11-20 13:50:15,115 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,116 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:15,116 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 202 bytes
2013-11-20 13:50:15,117 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,118 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:15,118 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:15,131 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:15,131 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-11-20 13:50:15,140 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local137568485_0002_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:15,143 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,143 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local137568485_0002_r_000000_0 is allowed to commit now
2013-11-20 13:50:15,147 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local137568485_0002_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplechain
2013-11-20 13:50:15,148 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:15,148 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local137568485_0002_r_000000_0' done.
2013-11-20 13:50:15,157 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2013-11-20 13:50:15,178 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,181 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/simplechain
2013-11-20 13:50:15,201 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:15,202 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:15,223 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 13:50:15,223 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:15,224 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count"]
2013-11-20 13:50:15,224 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 13:50:15,224 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 13:50:15,224 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 13:50:15,225 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) .../basicpipesplatform/count
2013-11-20 13:50:15,239 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,303 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local2013975703_0003
2013-11-20 13:50:15,306 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:15,307 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2013975703_0003_m_000000_0
2013-11-20 13:50:15,309 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@206cc2a4
2013-11-20 13:50:15,311 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt
2013-11-20 13:50:15,312 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7f1fc4b8
2013-11-20 13:50:15,313 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:15,314 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:15,432 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:15,433 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:15,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:15,435 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:15,444 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:15,445 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:15,449 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:15,455 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:15,458 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2013975703_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:15,461 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt:0+275
2013-11-20 13:50:15,461 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2013975703_0003_m_000000_0' done.
2013-11-20 13:50:15,462 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2013975703_0003_m_000000_0
2013-11-20 13:50:15,462 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:15,467 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@71d382ab
2013-11-20 13:50:15,468 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,469 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:15,469 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 13:50:15,470 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,470 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:15,470 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:15,481 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:15,482 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count"]
2013-11-20 13:50:15,492 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2013975703_0003_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:15,494 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,494 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local2013975703_0003_r_000000_0 is allowed to commit now
2013-11-20 13:50:15,497 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2013975703_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count
2013-11-20 13:50:15,499 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:15,499 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2013975703_0003_r_000000_0' done.
2013-11-20 13:50:15,508 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count/_temporary
2013-11-20 13:50:15,520 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,533 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,535 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/count
2013-11-20 13:50:15,547 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:15,548 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:15,566 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:15,566 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:15,566 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/swap"]
2013-11-20 13:50:15,567 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:15,567 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:15,567 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:15,567 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2013-11-20 13:50:15,583 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,621 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1788943294_0004
2013-11-20 13:50:15,624 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:15,625 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1788943294_0004_m_000000_0
2013-11-20 13:50:15,627 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@51f88fbd
2013-11-20 13:50:15,629 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:15,629 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@31d1fc02
2013-11-20 13:50:15,630 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 13:50:15,635 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:15,636 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:15,643 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:15,643 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/swap"]
2013-11-20 13:50:15,646 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1788943294_0004_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:15,648 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,649 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1788943294_0004_m_000000_0 is allowed to commit now
2013-11-20 13:50:15,652 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1788943294_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/swap
2013-11-20 13:50:15,653 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:15,653 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1788943294_0004_m_000000_0' done.
2013-11-20 13:50:15,654 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1788943294_0004_m_000000_0
2013-11-20 13:50:15,654 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:15,664 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2013-11-20 13:50:15,677 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,680 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/swap
2013-11-20 13:50:15,693 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:15,693 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:15,714 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:15,714 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2013-11-20 13:50:15,714 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-11-20 13:50:15,715 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:15,715 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:15,715 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:15,715 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2013-11-20 13:50:15,731 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local2046858049_0005
2013-11-20 13:50:15,780 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:15,780 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2046858049_0005_m_000000_0
2013-11-20 13:50:15,782 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2206270b
2013-11-20 13:50:15,784 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower+upper.txt
2013-11-20 13:50:15,784 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@24442c76
2013-11-20 13:50:15,785 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 13:50:15,789 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:15,789 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:15,798 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2013-11-20 13:50:15,798 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-11-20 13:50:15,800 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2046858049_0005_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:15,802 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:15,802 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local2046858049_0005_m_000000_0 is allowed to commit now
2013-11-20 13:50:15,806 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2046858049_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/ungrouped
2013-11-20 13:50:15,807 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2013-11-20 13:50:15,807 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2046858049_0005_m_000000_0' done.
2013-11-20 13:50:15,807 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2046858049_0005_m_000000_0
2013-11-20 13:50:15,808 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:15,818 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2013-11-20 13:50:15,830 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,832 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/ungrouped
2013-11-20 13:50:15,844 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:15,845 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:15,867 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:15,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:15,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-11-20 13:50:15,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:15,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:15,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:15,869 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...esplatform/simplerelative
2013-11-20 13:50:15,882 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:15,916 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local2045449699_0006
2013-11-20 13:50:15,919 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:15,919 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2045449699_0006_m_000000_0
2013-11-20 13:50:15,922 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@163fc47c
2013-11-20 13:50:15,924 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:15,924 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4b33f6dd
2013-11-20 13:50:15,926 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:15,927 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:16,043 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:16,044 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:16,046 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:16,046 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:16,055 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:16,056 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:16,059 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:16,063 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:16,065 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2045449699_0006_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:16,068 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:16,069 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2045449699_0006_m_000000_0' done.
2013-11-20 13:50:16,069 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2045449699_0006_m_000000_0
2013-11-20 13:50:16,070 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:16,073 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4ab4faeb
2013-11-20 13:50:16,074 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,075 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:16,075 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 13:50:16,076 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,076 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:16,076 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:16,084 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:16,085 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-11-20 13:50:16,095 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2045449699_0006_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:16,096 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,097 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local2045449699_0006_r_000000_0 is allowed to commit now
2013-11-20 13:50:16,100 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2045449699_0006_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplerelative
2013-11-20 13:50:16,101 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:16,101 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2045449699_0006_r_000000_0' done.
2013-11-20 13:50:16,110 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2013-11-20 13:50:16,122 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,124 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/simplerelative
2013-11-20 13:50:16,337 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:16,338 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:16,370 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:16,370 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt"]
2013-11-20 13:50:16,370 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-11-20 13:50:16,370 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:16,371 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:16,371 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:16,371 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2013-11-20 13:50:16,387 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,429 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local152485484_0007
2013-11-20 13:50:16,433 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:16,433 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local152485484_0007_m_000000_0
2013-11-20 13:50:16,435 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4b7aa961
2013-11-20 13:50:16,437 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt
2013-11-20 13:50:16,437 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@aaf063
2013-11-20 13:50:16,439 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:16,439 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:16,558 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:16,559 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:16,561 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:16,561 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:16,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt"]
2013-11-20 13:50:16,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:16,683 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:16,686 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:16,689 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local152485484_0007_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:16,691 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt:0+19
2013-11-20 13:50:16,692 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local152485484_0007_m_000000_0' done.
2013-11-20 13:50:16,692 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local152485484_0007_m_000000_0
2013-11-20 13:50:16,693 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:16,697 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@8c1e4d5
2013-11-20 13:50:16,697 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,699 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:16,699 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 28 bytes
2013-11-20 13:50:16,700 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,700 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:16,700 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:16,710 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:16,711 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-11-20 13:50:16,716 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local152485484_0007_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:16,718 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,718 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local152485484_0007_r_000000_0 is allowed to commit now
2013-11-20 13:50:16,721 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local152485484_0007_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simpleresult
2013-11-20 13:50:16,723 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:16,723 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local152485484_0007_r_000000_0' done.
2013-11-20 13:50:16,735 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2013-11-20 13:50:16,746 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,748 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/simpleresult
2013-11-20 13:50:16,757 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:16,757 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:16,772 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:16,773 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:16,773 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-11-20 13:50:16,774 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:16,774 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:16,774 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:16,775 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2013-11-20 13:50:16,788 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,818 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local567784571_0008
2013-11-20 13:50:16,822 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:16,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local567784571_0008_m_000000_0
2013-11-20 13:50:16,825 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@c1bb35b
2013-11-20 13:50:16,826 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:16,827 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@37285252
2013-11-20 13:50:16,828 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 13:50:16,832 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:16,833 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:16,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:16,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-11-20 13:50:16,843 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local567784571_0008_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:16,845 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:16,845 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local567784571_0008_m_000000_0 is allowed to commit now
2013-11-20 13:50:16,848 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local567784571_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filterall
2013-11-20 13:50:16,850 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:16,850 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local567784571_0008_m_000000_0' done.
2013-11-20 13:50:16,850 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local567784571_0008_m_000000_0
2013-11-20 13:50:16,851 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:16,866 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2013-11-20 13:50:16,878 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,880 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/filterall
2013-11-20 13:50:16,890 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:16,890 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:16,920 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting
2013-11-20 13:50:16,921 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/upper.txt"]
2013-11-20 13:50:16,921 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt"]
2013-11-20 13:50:16,921 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-11-20 13:50:16,921 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  parallel execution is enabled: false
2013-11-20 13:50:16,921 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  starting jobs: 1
2013-11-20 13:50:16,922 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  allocating threads: 1
2013-11-20 13:50:16,923 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2013-11-20 13:50:16,936 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,938 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:16,983 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] submitted hadoop job: job_local996371868_0009
2013-11-20 13:50:16,986 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:16,986 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local996371868_0009_m_000000_0
2013-11-20 13:50:16,989 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@247ef45b
2013-11-20 13:50:16,991 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/upper.txt
2013-11-20 13:50:16,991 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6cbb3f71
2013-11-20 13:50:16,993 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:16,993 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:17,348 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:17,350 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:17,353 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:17,353 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:17,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/upper.txt"]
2013-11-20 13:50:17,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-11-20 13:50:17,368 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:17,371 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:17,373 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local996371868_0009_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:17,375 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/upper.txt:0+19
2013-11-20 13:50:17,376 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local996371868_0009_m_000000_0' done.
2013-11-20 13:50:17,376 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local996371868_0009_m_000000_0
2013-11-20 13:50:17,377 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local996371868_0009_m_000001_0
2013-11-20 13:50:17,379 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@53566060
2013-11-20 13:50:17,380 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt
2013-11-20 13:50:17,381 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@678a270a
2013-11-20 13:50:17,382 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:17,383 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:17,474 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:17,476 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:17,478 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:17,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:17,487 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt"]
2013-11-20 13:50:17,488 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-11-20 13:50:17,490 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:17,493 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:17,495 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local996371868_0009_m_000001_0 is done. And is in the process of commiting
2013-11-20 13:50:17,498 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/lower.txt:0+19
2013-11-20 13:50:17,498 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local996371868_0009_m_000001_0' done.
2013-11-20 13:50:17,499 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local996371868_0009_m_000001_0
2013-11-20 13:50:17,499 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:17,506 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@447cc9c9
2013-11-20 13:50:17,507 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:17,508 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 2 sorted segments
2013-11-20 13:50:17,509 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2013-11-20 13:50:17,509 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:17,510 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:17,510 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:17,517 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-11-20 13:50:17,517 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-11-20 13:50:17,528 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 13:50:17,529 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 13:50:17,535 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local996371868_0009_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:17,537 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:17,537 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local996371868_0009_r_000000_0 is allowed to commit now
2013-11-20 13:50:17,540 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local996371868_0009_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/complexcogroup
2013-11-20 13:50:17,542 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:17,542 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local996371868_0009_r_000000_0' done.
2013-11-20 13:50:17,559 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2013-11-20 13:50:17,569 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:17,580 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:17,581 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/complexcogroup
2013-11-20 13:50:17,591 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:17,592 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:17,605 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:17,606 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:17,606 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/replace"]
2013-11-20 13:50:17,606 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:17,607 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:17,607 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:17,607 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2013-11-20 13:50:17,618 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:17,644 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1099862831_0010
2013-11-20 13:50:17,646 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:17,647 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1099862831_0010_m_000000_0
2013-11-20 13:50:17,649 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@82db73e
2013-11-20 13:50:17,650 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:17,651 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7cd0570e
2013-11-20 13:50:17,652 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 13:50:17,656 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:17,656 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:17,662 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:17,662 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/replace"]
2013-11-20 13:50:17,665 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1099862831_0010_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:17,667 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:17,667 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1099862831_0010_m_000000_0 is allowed to commit now
2013-11-20 13:50:17,670 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1099862831_0010_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/replace
2013-11-20 13:50:17,672 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:17,673 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1099862831_0010_m_000000_0' done.
2013-11-20 13:50:17,673 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1099862831_0010_m_000000_0
2013-11-20 13:50:17,674 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:17,738 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2013-11-20 13:50:17,749 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:17,751 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/replace
2013-11-20 13:50:17,761 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:17,761 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:17,778 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 13:50:17,778 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:17,779 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count2"]
2013-11-20 13:50:17,780 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 13:50:17,780 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 13:50:17,781 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 13:50:17,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2013-11-20 13:50:17,794 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:17,819 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local1007851309_0011
2013-11-20 13:50:17,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:17,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1007851309_0011_m_000000_0
2013-11-20 13:50:17,825 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@714fdb76
2013-11-20 13:50:17,827 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt
2013-11-20 13:50:17,827 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2cd9799d
2013-11-20 13:50:17,829 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:17,829 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:17,958 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:17,958 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:17,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:17,960 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:17,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:17,967 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:17,970 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:17,975 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:17,977 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1007851309_0011_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:17,980 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt:0+275
2013-11-20 13:50:17,980 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1007851309_0011_m_000000_0' done.
2013-11-20 13:50:17,980 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1007851309_0011_m_000000_0
2013-11-20 13:50:17,981 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:17,986 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@58053b2c
2013-11-20 13:50:17,987 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:17,988 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:17,989 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 13:50:17,990 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:17,990 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:17,991 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:17,997 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:17,997 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count2"]
2013-11-20 13:50:18,006 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1007851309_0011_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,008 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,009 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1007851309_0011_r_000000_0 is allowed to commit now
2013-11-20 13:50:18,012 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1007851309_0011_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count2
2013-11-20 13:50:18,014 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:18,015 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1007851309_0011_r_000000_0' done.
2013-11-20 13:50:18,027 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2013-11-20 13:50:18,037 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,049 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,052 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/count2
2013-11-20 13:50:18,062 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:18,062 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:18,080 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 13:50:18,080 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:18,080 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count3"]
2013-11-20 13:50:18,081 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 13:50:18,081 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 13:50:18,081 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 13:50:18,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2013-11-20 13:50:18,093 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,118 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local468100991_0012
2013-11-20 13:50:18,121 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:18,121 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local468100991_0012_m_000000_0
2013-11-20 13:50:18,125 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1d6535bf
2013-11-20 13:50:18,127 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt
2013-11-20 13:50:18,128 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@89ffb18
2013-11-20 13:50:18,130 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:18,130 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:18,249 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:18,249 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:18,251 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:18,251 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:18,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:18,262 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:18,266 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:18,269 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local468100991_0012_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,271 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt:0+275
2013-11-20 13:50:18,272 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local468100991_0012_m_000000_0' done.
2013-11-20 13:50:18,272 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local468100991_0012_m_000000_0
2013-11-20 13:50:18,273 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:18,278 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@653e4653
2013-11-20 13:50:18,279 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,279 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:18,280 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 13:50:18,280 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:18,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,287 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:18,287 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count3"]
2013-11-20 13:50:18,295 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local468100991_0012_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,297 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,298 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local468100991_0012_r_000000_0 is allowed to commit now
2013-11-20 13:50:18,301 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local468100991_0012_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count3
2013-11-20 13:50:18,303 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:18,303 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local468100991_0012_r_000000_0' done.
2013-11-20 13:50:18,314 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2013-11-20 13:50:18,323 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,334 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,336 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/count3
2013-11-20 13:50:18,346 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:18,346 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:18,360 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 13:50:18,361 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:18,361 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count4"]
2013-11-20 13:50:18,362 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 13:50:18,362 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 13:50:18,363 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 13:50:18,364 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2013-11-20 13:50:18,374 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,400 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local937847162_0013
2013-11-20 13:50:18,403 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:18,403 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local937847162_0013_m_000000_0
2013-11-20 13:50:18,405 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3cdc5434
2013-11-20 13:50:18,406 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt
2013-11-20 13:50:18,406 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@62618565
2013-11-20 13:50:18,408 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:18,408 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:18,524 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:18,524 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:18,526 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:18,526 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,531 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt"]
2013-11-20 13:50:18,532 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:18,535 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:18,539 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:18,541 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local937847162_0013_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,543 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/ips.20.txt:0+275
2013-11-20 13:50:18,544 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local937847162_0013_m_000000_0' done.
2013-11-20 13:50:18,544 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local937847162_0013_m_000000_0
2013-11-20 13:50:18,544 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:18,547 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6fbae5f5
2013-11-20 13:50:18,548 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,549 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:18,549 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 13:50:18,549 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,550 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:18,550 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,556 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 13:50:18,556 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count4"]
2013-11-20 13:50:18,563 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local937847162_0013_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,564 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,565 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local937847162_0013_r_000000_0 is allowed to commit now
2013-11-20 13:50:18,567 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local937847162_0013_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count4
2013-11-20 13:50:18,568 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:18,569 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local937847162_0013_r_000000_0' done.
2013-11-20 13:50:18,575 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2013-11-20 13:50:18,583 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,593 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,595 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/count4
2013-11-20 13:50:18,604 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:18,604 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:18,616 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:18,617 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:18,617 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filter"]
2013-11-20 13:50:18,617 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:18,617 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:18,618 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:18,619 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2013-11-20 13:50:18,629 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,653 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local298399963_0014
2013-11-20 13:50:18,656 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:18,656 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local298399963_0014_m_000000_0
2013-11-20 13:50:18,659 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@57425f38
2013-11-20 13:50:18,660 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:18,661 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@21882d18
2013-11-20 13:50:18,662 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 13:50:18,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:18,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,672 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:18,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filter"]
2013-11-20 13:50:18,675 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local298399963_0014_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,677 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,677 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local298399963_0014_m_000000_0 is allowed to commit now
2013-11-20 13:50:18,680 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local298399963_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filter
2013-11-20 13:50:18,681 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:18,682 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local298399963_0014_m_000000_0' done.
2013-11-20 13:50:18,682 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local298399963_0014_m_000000_0
2013-11-20 13:50:18,683 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:18,696 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2013-11-20 13:50:18,705 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,706 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/filter
2013-11-20 13:50:18,717 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 13:50:18,717 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 13:50:18,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 13:50:18,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:18,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simple"]
2013-11-20 13:50:18,736 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 13:50:18,736 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 13:50:18,736 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 13:50:18,737 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2013-11-20 13:50:18,747 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,770 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1333696468_0015
2013-11-20 13:50:18,773 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 13:50:18,773 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1333696468_0015_m_000000_0
2013-11-20 13:50:18,775 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@62b92956
2013-11-20 13:50:18,777 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt
2013-11-20 13:50:18,777 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@38be9340
2013-11-20 13:50:18,778 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-11-20 13:50:18,778 INFO  mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-11-20 13:50:18,894 INFO  mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-11-20 13:50:18,895 INFO  mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-11-20 13:50:18,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 13:50:18,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,904 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2013-11-20 13:50:18,904 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:18,906 INFO  mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-11-20 13:50:18,909 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-11-20 13:50:18,910 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1333696468_0015_m_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,912 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 13:50:18,912 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1333696468_0015_m_000000_0' done.
2013-11-20 13:50:18,913 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1333696468_0015_m_000000_0
2013-11-20 13:50:18,913 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 13:50:18,917 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6d4b473
2013-11-20 13:50:18,917 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,918 INFO  mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-11-20 13:50:18,918 INFO  mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 13:50:18,919 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,919 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 13:50:18,919 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 13:50:18,926 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 13:50:18,926 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simple"]
2013-11-20 13:50:18,932 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1333696468_0015_r_000000_0 is done. And is in the process of commiting
2013-11-20 13:50:18,933 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 13:50:18,934 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1333696468_0015_r_000000_0 is allowed to commit now
2013-11-20 13:50:18,936 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1333696468_0015_r_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simple
2013-11-20 13:50:18,937 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-11-20 13:50:18,937 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1333696468_0015_r_000000_0' done.
2013-11-20 13:50:18,945 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2013-11-20 13:50:18,954 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 13:50:18,956 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/basicpipesplatform/simple