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