Class cascading.BasicPipesPlatformTest

14

tests

0

failures

1m21.02s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 9.210s passed
testCount 6.197s passed
testCount2 6.109s passed
testCount3 6.134s passed
testCount4 6.114s passed
testFilter 3.097s passed
testFilterAll 3.093s passed
testReplace 3.106s passed
testSimple 6.087s passed
testSimpleChain 13.121s passed
testSimpleRelative 6.148s passed
testSimpleResult 6.330s passed
testSwap 3.145s passed
testUnGroup 3.132s passed

Standard output

2013-10-02 02:14:37,373 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-02 02:14:37,399 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-02 02:14:37,399 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2013-10-02 02:14:37,431 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-02 02:14:37,802 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:14:37,804 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:14:37,819 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: 8E2079C6E56D4E45A8B83207A796861D
2013-10-02 02:14:38,037 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0-wip-122
2013-10-02 02:14:38,040 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:14:38,041 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:14:38,041 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-10-02 02:14:38,041 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:14:38,042 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 2
2013-10-02 02:14:38,042 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:14:38,043 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/2)
2013-10-02 02:14:38,087 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-02 02:14:38,131 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-10-02 02:14:38,138 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:38,324 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0001
2013-10-02 02:14:38,382 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-10-02 02:14:38,391 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@22e496ab
2013-10-02 02:14:38,399 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:14:38,405 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:14:38,413 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:14:38,548 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:14:38,548 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:14:38,571 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:38,571 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:14:38,636 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:14:38,636 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:14:38,650 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:14:38,662 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:14:38,665 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:41,367 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:14:41,369 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-02 02:14:41,378 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2dd1082f
2013-10-02 02:14:41,379 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:41,385 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:14:41,390 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-10-02 02:14:41,390 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:41,392 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:41,392 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:14:41,410 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:14:41,410 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][2749024586/test/]
2013-10-02 02:14:41,434 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:41,435 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:41,436 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2013-10-02 02:14:41,440 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/tmp/hadoop-teamcity/2749024586_test_3ADBEBE62BE343769FEFE28E15BF6B6F
2013-10-02 02:14:44,378 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:14:44,380 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_r_000000_0' done.
2013-10-02 02:14:44,410 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2013-10-02 02:14:44,427 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:44,506 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0002
2013-10-02 02:14:44,511 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7e63f09e
2013-10-02 02:14:44,512 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/2749024586_test_3ADBEBE62BE343769FEFE28E15BF6B6F/part-00000
2013-10-02 02:14:44,519 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:14:44,520 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:14:44,654 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:14:44,654 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:14:44,656 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:44,656 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:14:44,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][2749024586/test/]
2013-10-02 02:14:44,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:14:44,670 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:14:44,674 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:14:44,709 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:47,511 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/tmp/hadoop-teamcity/2749024586_test_3ADBEBE62BE343769FEFE28E15BF6B6F/part-00000:0+310
2013-10-02 02:14:47,512 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2013-10-02 02:14:47,518 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7e9b59a2
2013-10-02 02:14:47,518 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:47,555 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:14:47,556 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 202 bytes
2013-10-02 02:14:47,556 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:47,557 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:47,558 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:14:47,568 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:14:47,568 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-10-02 02:14:47,577 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:47,578 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:47,578 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2013-10-02 02:14:47,582 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain
2013-10-02 02:14:50,518 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:14:50,519 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_r_000000_0' done.
2013-10-02 02:14:50,527 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2013-10-02 02:14:50,547 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:50,549 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simplechain
2013-10-02 02:14:50,569 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:14:50,570 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:14:50,592 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-02 02:14:50,592 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:14:50,592 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count"]
2013-10-02 02:14:50,593 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-10-02 02:14:50,593 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-10-02 02:14:50,593 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-10-02 02:14:50,594 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) .../basicpipesplatform/count
2013-10-02 02:14:50,610 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:50,676 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0003
2013-10-02 02:14:50,680 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2424c672
2013-10-02 02:14:50,682 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt
2013-10-02 02:14:50,683 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:14:50,684 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:14:50,803 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:14:50,804 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:14:50,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:50,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:14:50,814 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:14:50,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:14:50,819 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:14:50,825 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:14:50,827 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:53,681 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2013-10-02 02:14:53,682 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2013-10-02 02:14:53,687 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7eac4d3b
2013-10-02 02:14:53,687 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:53,689 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:14:53,689 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-02 02:14:53,690 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:53,691 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:53,691 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:14:53,699 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:14:53,699 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count"]
2013-10-02 02:14:53,710 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:53,711 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:53,712 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2013-10-02 02:14:53,716 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count
2013-10-02 02:14:56,688 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:14:56,689 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_r_000000_0' done.
2013-10-02 02:14:56,705 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count/_temporary
2013-10-02 02:14:56,724 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:56,746 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:56,749 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count
2013-10-02 02:14:56,768 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:14:56,769 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:14:56,790 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:14:56,790 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:14:56,790 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap"]
2013-10-02 02:14:56,791 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:14:56,791 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:14:56,791 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:14:56,792 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2013-10-02 02:14:56,811 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:56,858 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0004
2013-10-02 02:14:56,863 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@78c6cbc
2013-10-02 02:14:56,865 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:14:56,867 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 02:14:56,874 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:14:56,874 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:14:56,883 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:14:56,883 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap"]
2013-10-02 02:14:56,887 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:14:56,887 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:14:56,888 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2013-10-02 02:14:56,892 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap
2013-10-02 02:14:59,863 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:14:59,864 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2013-10-02 02:14:59,878 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2013-10-02 02:14:59,892 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:59,895 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/swap
2013-10-02 02:14:59,911 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:14:59,912 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:14:59,937 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:14:59,938 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower+upper.txt"]
2013-10-02 02:14:59,939 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-10-02 02:14:59,939 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:14:59,939 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:14:59,939 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:14:59,941 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2013-10-02 02:14:59,957 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:14:59,995 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0005
2013-10-02 02:15:00,000 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@51a422f6
2013-10-02 02:15:00,001 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower+upper.txt
2013-10-02 02:15:00,003 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 02:15:00,008 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:00,009 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:00,017 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower+upper.txt"]
2013-10-02 02:15:00,017 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-10-02 02:15:00,020 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:00,021 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:00,021 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2013-10-02 02:15:00,025 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped
2013-10-02 02:15:03,000 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower+upper.txt:0+30
2013-10-02 02:15:03,001 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2013-10-02 02:15:03,013 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2013-10-02 02:15:03,025 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:03,028 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/ungrouped
2013-10-02 02:15:03,040 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:03,041 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:03,065 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:15:03,066 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:03,066 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-10-02 02:15:03,066 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:15:03,067 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:15:03,067 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:15:03,069 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...esplatform/simplerelative
2013-10-02 02:15:03,086 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:03,137 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0006
2013-10-02 02:15:03,141 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2eb80f1c
2013-10-02 02:15:03,142 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:15:03,144 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:03,144 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:03,261 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:03,261 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:03,263 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:03,263 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:03,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:03,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:15:03,275 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:03,279 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:03,281 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:06,142 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:15:06,143 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2013-10-02 02:15:06,148 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@58dcdffc
2013-10-02 02:15:06,148 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:06,149 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:15:06,150 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-10-02 02:15:06,150 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:06,151 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:06,151 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:06,160 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:15:06,160 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-10-02 02:15:06,167 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:06,168 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:06,169 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_r_000000_0 is allowed to commit now
2013-10-02 02:15:06,172 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative
2013-10-02 02:15:09,148 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:09,149 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_r_000000_0' done.
2013-10-02 02:15:09,163 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2013-10-02 02:15:09,175 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:09,177 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simplerelative
2013-10-02 02:15:09,394 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:09,395 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:09,426 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:15:09,427 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt"]
2013-10-02 02:15:09,427 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-10-02 02:15:09,428 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:15:09,428 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:15:09,428 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:15:09,429 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2013-10-02 02:15:09,446 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:09,478 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0007
2013-10-02 02:15:09,483 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6e3404f
2013-10-02 02:15:09,485 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt
2013-10-02 02:15:09,486 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:09,486 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:09,605 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:09,606 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:09,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:09,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:09,618 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt"]
2013-10-02 02:15:09,619 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:15:09,731 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:09,733 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:09,735 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:12,484 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt:0+19
2013-10-02 02:15:12,485 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2013-10-02 02:15:12,488 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@233e9934
2013-10-02 02:15:12,488 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:12,490 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:15:12,490 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 28 bytes
2013-10-02 02:15:12,490 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:12,491 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:12,491 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:12,501 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:15:12,501 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-10-02 02:15:12,506 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:12,507 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:12,508 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_r_000000_0 is allowed to commit now
2013-10-02 02:15:12,511 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult
2013-10-02 02:15:15,488 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:15,489 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_r_000000_0' done.
2013-10-02 02:15:15,496 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2013-10-02 02:15:15,507 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:15,508 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simpleresult
2013-10-02 02:15:15,517 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:15,518 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:15,534 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:15:15,534 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:15,535 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-10-02 02:15:15,535 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:15:15,535 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:15:15,535 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:15:15,536 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2013-10-02 02:15:15,550 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:15,578 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0008
2013-10-02 02:15:15,582 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2bf87baf
2013-10-02 02:15:15,584 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:15:15,585 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 02:15:15,589 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:15,589 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:15,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:15,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-10-02 02:15:15,598 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:15,599 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:15,599 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-10-02 02:15:15,602 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall
2013-10-02 02:15:18,582 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:15:18,583 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2013-10-02 02:15:18,589 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2013-10-02 02:15:18,600 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:18,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/filterall
2013-10-02 02:15:18,612 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:18,613 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:18,643 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting
2013-10-02 02:15:18,643 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/upper.txt"]
2013-10-02 02:15:18,643 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt"]
2013-10-02 02:15:18,644 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-10-02 02:15:18,644 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  parallel execution is enabled: false
2013-10-02 02:15:18,644 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  starting jobs: 1
2013-10-02 02:15:18,644 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  allocating threads: 1
2013-10-02 02:15:18,645 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2013-10-02 02:15:18,695 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:18,697 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:18,723 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] submitted hadoop job: job_local_0009
2013-10-02 02:15:18,728 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@31672113
2013-10-02 02:15:18,730 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/upper.txt
2013-10-02 02:15:18,731 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:18,731 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:19,070 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:19,073 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:19,076 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:19,077 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:19,087 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/upper.txt"]
2013-10-02 02:15:19,087 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-10-02 02:15:19,091 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:19,188 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:19,191 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:21,728 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/upper.txt:0+19
2013-10-02 02:15:21,729 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000000_0' done.
2013-10-02 02:15:21,731 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@58cf17c3
2013-10-02 02:15:21,732 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt
2013-10-02 02:15:21,757 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:21,758 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:21,881 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:21,881 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:21,882 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:21,883 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:21,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt"]
2013-10-02 02:15:21,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-10-02 02:15:21,893 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:21,895 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:21,898 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000001_0 is done. And is in the process of commiting
2013-10-02 02:15:24,731 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/lower.txt:0+19
2013-10-02 02:15:24,732 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000001_0' done.
2013-10-02 02:15:24,739 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6f9bc716
2013-10-02 02:15:24,739 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:24,741 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2013-10-02 02:15:24,742 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2013-10-02 02:15:24,742 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:24,743 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:24,743 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:24,750 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-10-02 02:15:24,751 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-10-02 02:15:24,762 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-02 02:15:24,762 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-02 02:15:24,769 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:24,770 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:24,771 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0009_r_000000_0 is allowed to commit now
2013-10-02 02:15:24,773 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup
2013-10-02 02:15:27,739 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:27,740 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_r_000000_0' done.
2013-10-02 02:15:27,752 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2013-10-02 02:15:27,799 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:27,810 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:27,812 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/complexcogroup
2013-10-02 02:15:27,821 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:27,821 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:27,835 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:15:27,836 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:27,836 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace"]
2013-10-02 02:15:27,836 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:15:27,836 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:15:27,836 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:15:27,837 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2013-10-02 02:15:27,850 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:27,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0010
2013-10-02 02:15:27,877 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2820224a
2013-10-02 02:15:27,878 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:15:27,879 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 02:15:27,883 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:27,883 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:27,889 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:27,889 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace"]
2013-10-02 02:15:27,892 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:27,893 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:27,894 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0010_m_000000_0 is allowed to commit now
2013-10-02 02:15:27,897 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0010_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace
2013-10-02 02:15:30,877 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:15:30,878 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0010_m_000000_0' done.
2013-10-02 02:15:30,883 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2013-10-02 02:15:30,916 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:30,918 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/replace
2013-10-02 02:15:30,928 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:30,928 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:30,946 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-02 02:15:30,946 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:15:30,946 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2"]
2013-10-02 02:15:30,947 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-10-02 02:15:30,947 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-10-02 02:15:30,947 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-10-02 02:15:30,949 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2013-10-02 02:15:30,963 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:30,991 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0011
2013-10-02 02:15:30,996 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@12072edc
2013-10-02 02:15:30,998 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt
2013-10-02 02:15:30,999 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:31,000 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:31,131 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:31,132 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:31,133 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:31,133 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:31,140 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:15:31,140 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:15:31,143 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:31,148 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:31,150 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:33,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2013-10-02 02:15:33,998 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_m_000000_0' done.
2013-10-02 02:15:34,002 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@57af0af7
2013-10-02 02:15:34,002 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:34,003 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:15:34,004 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-02 02:15:34,004 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:34,005 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:34,005 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:34,012 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:15:34,012 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2"]
2013-10-02 02:15:34,020 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:34,021 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:34,022 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2013-10-02 02:15:34,025 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0011_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2
2013-10-02 02:15:37,002 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:37,002 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_r_000000_0' done.
2013-10-02 02:15:37,006 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2013-10-02 02:15:37,016 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:37,026 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:37,028 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count2
2013-10-02 02:15:37,037 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:37,038 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:37,053 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-02 02:15:37,053 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:15:37,053 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3"]
2013-10-02 02:15:37,054 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-10-02 02:15:37,054 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-10-02 02:15:37,054 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-10-02 02:15:37,054 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2013-10-02 02:15:37,066 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:37,128 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0012
2013-10-02 02:15:37,132 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@27443628
2013-10-02 02:15:37,133 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt
2013-10-02 02:15:37,134 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:37,134 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:37,251 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:37,252 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:37,253 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:37,253 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:37,259 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:15:37,260 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:15:37,263 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:37,266 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:37,268 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:40,132 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2013-10-02 02:15:40,133 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_m_000000_0' done.
2013-10-02 02:15:40,136 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@39c26db4
2013-10-02 02:15:40,137 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:40,138 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:15:40,138 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-02 02:15:40,138 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:40,139 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:40,139 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:40,145 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:15:40,146 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3"]
2013-10-02 02:15:40,153 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:40,153 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:40,154 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0012_r_000000_0 is allowed to commit now
2013-10-02 02:15:40,157 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0012_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3
2013-10-02 02:15:43,136 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:43,137 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_r_000000_0' done.
2013-10-02 02:15:43,141 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2013-10-02 02:15:43,150 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:43,161 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:43,163 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count3
2013-10-02 02:15:43,173 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:43,173 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:43,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-02 02:15:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:15:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4"]
2013-10-02 02:15:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-10-02 02:15:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-10-02 02:15:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-10-02 02:15:43,191 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2013-10-02 02:15:43,203 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:43,238 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0013
2013-10-02 02:15:43,241 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5561bfa3
2013-10-02 02:15:43,243 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt
2013-10-02 02:15:43,244 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:43,244 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:43,319 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:43,319 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:43,320 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:43,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:43,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2013-10-02 02:15:43,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:15:43,330 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:43,334 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:43,336 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:46,242 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2013-10-02 02:15:46,243 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_m_000000_0' done.
2013-10-02 02:15:46,247 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6f5e0eab
2013-10-02 02:15:46,247 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:46,248 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:15:46,248 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-02 02:15:46,249 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:46,249 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:46,250 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:46,256 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-02 02:15:46,256 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4"]
2013-10-02 02:15:46,264 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:46,265 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:46,266 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0013_r_000000_0 is allowed to commit now
2013-10-02 02:15:46,268 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4
2013-10-02 02:15:49,246 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:49,248 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_r_000000_0' done.
2013-10-02 02:15:49,255 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2013-10-02 02:15:49,265 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:49,276 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:49,277 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count4
2013-10-02 02:15:49,298 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:49,299 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:49,311 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:15:49,312 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:49,313 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter"]
2013-10-02 02:15:49,313 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:15:49,314 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:15:49,314 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:15:49,321 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2013-10-02 02:15:49,333 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:49,354 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0014
2013-10-02 02:15:49,357 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6ce5d622
2013-10-02 02:15:49,358 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:15:49,360 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 02:15:49,362 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:49,363 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:49,368 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:49,369 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter"]
2013-10-02 02:15:49,371 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:49,372 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:49,373 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2013-10-02 02:15:49,375 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter
2013-10-02 02:15:52,357 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:15:52,358 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_m_000000_0' done.
2013-10-02 02:15:52,365 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2013-10-02 02:15:52,373 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:52,375 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/filter
2013-10-02 02:15:52,385 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 02:15:52,385 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 02:15:52,402 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-02 02:15:52,402 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:52,403 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple"]
2013-10-02 02:15:52,404 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-10-02 02:15:52,404 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-10-02 02:15:52,405 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-10-02 02:15:52,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2013-10-02 02:15:52,416 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:52,435 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0015
2013-10-02 02:15:52,439 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1b186cf9
2013-10-02 02:15:52,441 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt
2013-10-02 02:15:52,442 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-10-02 02:15:52,443 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-10-02 02:15:52,566 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-10-02 02:15:52,567 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-10-02 02:15:52,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:52,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 02:15:52,577 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2013-10-02 02:15:52,577 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:15:52,580 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-10-02 02:15:52,582 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-10-02 02:15:52,584 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:55,441 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2013-10-02 02:15:55,441 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_m_000000_0' done.
2013-10-02 02:15:55,445 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@b583a80
2013-10-02 02:15:55,445 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:55,446 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-10-02 02:15:55,447 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-10-02 02:15:55,447 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:55,447 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0-wip-122
2013-10-02 02:15:55,448 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-02 02:15:55,455 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-02 02:15:55,455 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple"]
2013-10-02 02:15:55,462 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_r_000000_0 is done. And is in the process of commiting
2013-10-02 02:15:55,463 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-02 02:15:55,463 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0015_r_000000_0 is allowed to commit now
2013-10-02 02:15:55,466 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_r_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple
2013-10-02 02:15:58,445 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-02 02:15:58,446 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_r_000000_0' done.
2013-10-02 02:15:58,453 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2013-10-02 02:15:58,461 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 02:15:58,463 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simple