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