2015-02-10 13:04:38,922 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 13:04:38,970 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 13:04:38,971 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2015-02-10 13:04:39,004 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 13:04:39,404 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:04:39,406 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:04:39,418 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 4603A8B3AAA54FAFA6B1DE1AA1E3DF24
2015-02-10 13:04:39,674 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 13:04:39,678 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:04:39,679 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:04:39,679 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-02-10 13:04:39,680 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:04:39,680 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 2
2015-02-10 13:04:39,680 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:04:39,683 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/2)
2015-02-10 13:04:39,732 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-10 13:04:39,783 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 13:04:39,786 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:40,006 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0001
2015-02-10 13:04:40,010 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:04:40,076 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 13:04:40,084 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@35ad0839
2015-02-10 13:04:40,092 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:04:40,099 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:04:40,107 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:04:40,253 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:04:40,253 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:04:40,277 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:04:40,277 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:04:40,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:04:40,347 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:04:40,361 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:04:40,374 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:04:40,377 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:43,059 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:04:43,061 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2015-02-10 13:04:43,071 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@79429cb2
2015-02-10 13:04:43,072 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:43,078 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:04:43,083 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2015-02-10 13:04:43,083 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:43,085 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:04:43,085 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:04:43,105 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:04:43,106 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][6159678301/test/]
2015-02-10 13:04:43,131 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:43,132 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:43,133 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2015-02-10 13:04:43,137 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/tmp/hadoop-teamcity/6159678301_test_EE14379EB57D4375BA03E4A977A41CAF
2015-02-10 13:04:46,071 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:04:46,072 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_r_000000_0' done.
2015-02-10 13:04:46,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2015-02-10 13:04:46,104 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:46,193 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0002
2015-02-10 13:04:46,194 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:04:46,197 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@268be9ef
2015-02-10 13:04:46,199 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/6159678301_test_EE14379EB57D4375BA03E4A977A41CAF/part-00000
2015-02-10 13:04:46,207 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:04:46,207 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:04:46,355 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:04:46,356 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:04:46,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:04:46,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:04:46,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][6159678301/test/]
2015-02-10 13:04:46,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:04:46,374 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:04:46,378 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:04:46,381 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:49,198 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/tmp/hadoop-teamcity/6159678301_test_EE14379EB57D4375BA03E4A977A41CAF/part-00000:0+310
2015-02-10 13:04:49,199 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2015-02-10 13:04:49,204 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@44a9a32c
2015-02-10 13:04:49,205 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:49,206 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:04:49,207 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 202 bytes
2015-02-10 13:04:49,207 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:49,208 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:04:49,209 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:04:49,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:04:49,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-02-10 13:04:49,229 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:49,230 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:49,231 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2015-02-10 13:04:49,235 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain
2015-02-10 13:04:52,205 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:04:52,206 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_r_000000_0' done.
2015-02-10 13:04:52,221 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2015-02-10 13:04:52,246 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:52,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simplechain
2015-02-10 13:04:52,275 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:04:52,276 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:04:52,301 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 13:04:52,302 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:04:52,303 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-02-10 13:04:52,304 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 13:04:52,304 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 13:04:52,305 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 13:04:52,306 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) .../basicpipesplatform/count
2015-02-10 13:04:52,324 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:52,412 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0003
2015-02-10 13:04:52,412 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 13:04:52,417 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4b51ac10
2015-02-10 13:04:52,419 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt
2015-02-10 13:04:52,421 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:04:52,421 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:04:52,571 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:04:52,571 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:04:52,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:04:52,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:04:52,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:04:52,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:04:52,590 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:04:52,596 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:04:52,599 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:55,418 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 13:04:55,419 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2015-02-10 13:04:55,424 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5da5e65f
2015-02-10 13:04:55,425 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:55,426 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:04:55,427 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 13:04:55,427 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:55,428 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:04:55,428 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:04:55,438 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:04:55,438 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-02-10 13:04:55,451 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:55,452 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:55,453 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2015-02-10 13:04:55,457 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count
2015-02-10 13:04:58,424 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:04:58,425 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_r_000000_0' done.
2015-02-10 13:04:58,497 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count/_temporary
2015-02-10 13:04:58,518 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:58,539 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:58,541 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count
2015-02-10 13:04:58,562 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:04:58,563 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:04:58,584 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:04:58,584 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:04:58,584 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-02-10 13:04:58,585 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:04:58,585 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:04:58,585 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:04:58,586 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2015-02-10 13:04:58,606 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:04:58,652 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0004
2015-02-10 13:04:58,653 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:04:58,657 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@56d99277
2015-02-10 13:04:58,659 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:04:58,660 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 13:04:58,666 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:04:58,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:04:58,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:04:58,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-02-10 13:04:58,679 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:04:58,680 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:04:58,680 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2015-02-10 13:04:58,684 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap
2015-02-10 13:05:01,657 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:05:01,658 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2015-02-10 13:05:01,671 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2015-02-10 13:05:01,685 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:01,688 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/swap
2015-02-10 13:05:01,707 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:01,707 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:01,732 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:01,732 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower+upper.txt"]
2015-02-10 13:05:01,732 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-02-10 13:05:01,733 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:01,733 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:01,733 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:01,734 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2015-02-10 13:05:01,751 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:01,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0005
2015-02-10 13:05:01,788 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:01,794 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@18a4edc4
2015-02-10 13:05:01,796 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower+upper.txt
2015-02-10 13:05:01,797 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 13:05:01,804 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:01,804 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:01,814 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower+upper.txt"]
2015-02-10 13:05:01,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-02-10 13:05:01,817 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:01,818 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:01,820 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2015-02-10 13:05:01,824 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped
2015-02-10 13:05:04,794 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower+upper.txt:0+30
2015-02-10 13:05:04,795 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2015-02-10 13:05:04,806 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2015-02-10 13:05:04,818 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:04,820 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/ungrouped
2015-02-10 13:05:04,835 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:04,835 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:04,861 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:04,861 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:04,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-02-10 13:05:04,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:04,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:04,863 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:04,863 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...esplatform/simplerelative
2015-02-10 13:05:04,880 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:04,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0006
2015-02-10 13:05:04,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:04,932 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@11eea7f0
2015-02-10 13:05:04,934 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:05:04,935 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:04,935 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:05,085 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:05,085 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:05,088 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:05,088 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:05,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:05,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:05:05,101 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:05,105 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:05,107 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:07,933 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:05:07,934 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2015-02-10 13:05:07,938 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3b46ad8b
2015-02-10 13:05:07,939 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:07,940 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:05:07,941 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2015-02-10 13:05:07,941 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:07,942 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:07,942 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:07,951 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:05:07,952 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-02-10 13:05:07,960 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:07,961 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:07,961 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_r_000000_0 is allowed to commit now
2015-02-10 13:05:07,965 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative
2015-02-10 13:05:10,938 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:05:10,939 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_r_000000_0' done.
2015-02-10 13:05:10,949 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2015-02-10 13:05:10,961 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:10,963 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simplerelative
2015-02-10 13:05:11,201 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:11,202 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:11,238 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:11,238 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-02-10 13:05:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-02-10 13:05:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:11,239 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:11,240 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2015-02-10 13:05:11,257 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:11,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0007
2015-02-10 13:05:11,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:11,315 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@10fd0a62
2015-02-10 13:05:11,317 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt
2015-02-10 13:05:11,318 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:11,319 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:11,464 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:11,466 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:11,468 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:11,468 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:11,481 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-02-10 13:05:11,481 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:05:11,584 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:11,587 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:11,589 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:14,315 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt:0+19
2015-02-10 13:05:14,317 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2015-02-10 13:05:14,321 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3e29b849
2015-02-10 13:05:14,322 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:14,324 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:05:14,325 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 28 bytes
2015-02-10 13:05:14,325 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:14,326 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:14,327 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:14,338 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:05:14,339 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-02-10 13:05:14,345 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:14,346 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:14,347 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_r_000000_0 is allowed to commit now
2015-02-10 13:05:14,350 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult
2015-02-10 13:05:17,321 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:05:17,322 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_r_000000_0' done.
2015-02-10 13:05:17,336 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2015-02-10 13:05:17,347 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:17,349 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simpleresult
2015-02-10 13:05:17,361 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:17,362 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:17,380 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:17,381 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:17,381 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-02-10 13:05:17,382 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:17,383 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:17,383 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:17,384 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2015-02-10 13:05:17,399 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:17,428 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0008
2015-02-10 13:05:17,429 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:17,433 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@71d9d55b
2015-02-10 13:05:17,434 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:05:17,436 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 13:05:17,439 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:17,440 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:17,447 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:17,447 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-02-10 13:05:17,450 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:17,451 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:17,451 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2015-02-10 13:05:17,455 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall
2015-02-10 13:05:20,433 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:05:20,434 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2015-02-10 13:05:20,446 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2015-02-10 13:05:20,456 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:20,458 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/filterall
2015-02-10 13:05:20,472 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:20,472 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:20,506 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] starting
2015-02-10 13:05:20,506 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-02-10 13:05:20,507 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-02-10 13:05:20,507 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-02-10 13:05:20,508 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] parallel execution is enabled: false
2015-02-10 13:05:20,508 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] starting jobs: 1
2015-02-10 13:05:20,508 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] allocating threads: 1
2015-02-10 13:05:20,509 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2015-02-10 13:05:20,522 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:20,523 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:20,551 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] submitted hadoop job: job_local_0009
2015-02-10 13:05:20,551 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] tracking url: http://localhost:8080/
2015-02-10 13:05:20,555 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2214c7cd
2015-02-10 13:05:20,556 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/upper.txt
2015-02-10 13:05:20,557 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:20,558 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:20,922 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:20,922 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:20,925 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:20,925 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:20,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/upper.txt"]
2015-02-10 13:05:20,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 13:05:20,939 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:20,941 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:20,943 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:23,555 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/upper.txt:0+19
2015-02-10 13:05:23,556 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000000_0' done.
2015-02-10 13:05:23,558 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2bbe8bf1
2015-02-10 13:05:23,560 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt
2015-02-10 13:05:23,562 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:23,562 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:23,702 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:23,703 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:23,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:23,705 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:23,715 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt"]
2015-02-10 13:05:23,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 13:05:23,718 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:23,721 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:23,723 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000001_0 is done. And is in the process of commiting
2015-02-10 13:05:26,559 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lower.txt:0+19
2015-02-10 13:05:26,561 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000001_0' done.
2015-02-10 13:05:26,569 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@699238ad
2015-02-10 13:05:26,569 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:26,571 INFO mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2015-02-10 13:05:26,571 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2015-02-10 13:05:26,572 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:26,573 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:26,573 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:26,582 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 13:05:26,582 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-02-10 13:05:26,595 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 13:05:26,595 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 13:05:26,603 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:26,604 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:26,605 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0009_r_000000_0 is allowed to commit now
2015-02-10 13:05:26,608 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup
2015-02-10 13:05:29,568 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:05:29,570 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_r_000000_0' done.
2015-02-10 13:05:29,577 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2015-02-10 13:05:29,587 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:29,598 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:29,599 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/complexcogroup
2015-02-10 13:05:29,611 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:29,611 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:29,629 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:29,630 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:29,630 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-02-10 13:05:29,630 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:29,630 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:29,630 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:29,631 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2015-02-10 13:05:29,645 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:29,669 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0010
2015-02-10 13:05:29,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:29,674 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2d83e895
2015-02-10 13:05:29,675 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:05:29,676 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 13:05:29,681 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:29,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:29,689 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:29,689 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-02-10 13:05:29,692 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:29,692 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:29,693 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0010_m_000000_0 is allowed to commit now
2015-02-10 13:05:29,696 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0010_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace
2015-02-10 13:05:32,673 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:05:32,674 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0010_m_000000_0' done.
2015-02-10 13:05:32,688 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2015-02-10 13:05:32,699 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:32,701 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/replace
2015-02-10 13:05:32,713 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:32,714 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:32,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 13:05:32,735 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:05:32,735 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-02-10 13:05:32,736 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 13:05:32,736 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 13:05:32,736 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 13:05:32,737 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2015-02-10 13:05:32,749 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:32,785 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0011
2015-02-10 13:05:32,788 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 13:05:32,791 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3cdfd643
2015-02-10 13:05:32,792 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt
2015-02-10 13:05:32,794 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:32,794 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:32,954 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:32,954 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:32,955 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:32,955 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:32,963 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:05:32,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:05:32,967 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:32,972 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:32,974 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:35,791 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 13:05:35,792 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_m_000000_0' done.
2015-02-10 13:05:35,796 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@99c873d
2015-02-10 13:05:35,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:35,798 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:05:35,798 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 13:05:35,798 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:35,799 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:35,799 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:35,807 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:05:35,807 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-02-10 13:05:35,816 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:35,816 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:35,817 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2015-02-10 13:05:35,820 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0011_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2
2015-02-10 13:05:38,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:05:38,797 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_r_000000_0' done.
2015-02-10 13:05:38,808 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2015-02-10 13:05:38,818 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:38,829 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:38,831 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count2
2015-02-10 13:05:38,842 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:38,843 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:38,861 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 13:05:38,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:05:38,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-02-10 13:05:38,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 13:05:38,862 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 13:05:38,863 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 13:05:38,863 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2015-02-10 13:05:38,876 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:38,899 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0012
2015-02-10 13:05:38,899 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 13:05:38,902 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@65f102c1
2015-02-10 13:05:38,904 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt
2015-02-10 13:05:38,905 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:38,905 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:39,055 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:39,055 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:39,057 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:39,057 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:39,064 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:05:39,065 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:05:39,068 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:39,073 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:39,075 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:41,903 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 13:05:41,903 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_m_000000_0' done.
2015-02-10 13:05:41,907 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1d667df0
2015-02-10 13:05:41,908 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:41,909 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:05:41,909 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 13:05:41,910 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:41,910 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:41,911 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:41,918 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:05:41,918 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-02-10 13:05:41,926 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:41,927 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:41,927 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0012_r_000000_0 is allowed to commit now
2015-02-10 13:05:41,930 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0012_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3
2015-02-10 13:05:44,907 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:05:44,908 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_r_000000_0' done.
2015-02-10 13:05:44,921 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2015-02-10 13:05:44,931 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:44,941 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:44,943 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count3
2015-02-10 13:05:44,954 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:44,955 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:44,972 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 13:05:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:05:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-02-10 13:05:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 13:05:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 13:05:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 13:05:44,974 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2015-02-10 13:05:44,987 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:45,011 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0013
2015-02-10 13:05:45,012 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 13:05:45,014 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5329645a
2015-02-10 13:05:45,016 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt
2015-02-10 13:05:45,017 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:45,017 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:45,151 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:45,152 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:45,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:45,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:45,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 13:05:45,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:05:45,164 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:45,169 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:45,170 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:48,015 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 13:05:48,016 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_m_000000_0' done.
2015-02-10 13:05:48,020 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@35087359
2015-02-10 13:05:48,020 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:48,022 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:05:48,022 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2015-02-10 13:05:48,022 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:48,023 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:48,023 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:48,031 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 13:05:48,031 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-02-10 13:05:48,039 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:48,040 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:48,041 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0013_r_000000_0 is allowed to commit now
2015-02-10 13:05:48,044 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4
2015-02-10 13:05:51,020 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:05:51,021 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_r_000000_0' done.
2015-02-10 13:05:51,026 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2015-02-10 13:05:51,037 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:51,049 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:51,051 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/count4
2015-02-10 13:05:51,064 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:51,065 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:51,080 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:51,081 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:51,081 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-02-10 13:05:51,082 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:51,082 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:51,082 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:51,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2015-02-10 13:05:51,100 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:51,126 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0014
2015-02-10 13:05:51,127 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:51,130 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@78456a0c
2015-02-10 13:05:51,132 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:05:51,133 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 13:05:51,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:51,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:51,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:51,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-02-10 13:05:51,146 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:51,147 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:51,147 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2015-02-10 13:05:51,150 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter
2015-02-10 13:05:54,130 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:05:54,131 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_m_000000_0' done.
2015-02-10 13:05:54,144 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2015-02-10 13:05:54,157 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:54,158 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/filter
2015-02-10 13:05:54,175 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 13:05:54,176 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 13:05:54,197 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 13:05:54,198 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:54,198 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-02-10 13:05:54,198 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 13:05:54,198 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 13:05:54,198 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 13:05:54,199 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2015-02-10 13:05:54,211 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:05:54,245 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0015
2015-02-10 13:05:54,246 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 13:05:54,249 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6c408893
2015-02-10 13:05:54,251 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt
2015-02-10 13:05:54,252 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 13:05:54,252 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 13:05:54,607 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 13:05:54,607 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 13:05:54,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 13:05:54,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 13:05:54,618 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt"]
2015-02-10 13:05:54,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:05:54,622 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 13:05:54,625 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 13:05:54,626 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:57,249 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 13:05:57,250 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_m_000000_0' done.
2015-02-10 13:05:57,253 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b09062e
2015-02-10 13:05:57,253 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:57,255 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 13:05:57,255 INFO mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2015-02-10 13:05:57,255 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:57,256 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 13:05:57,256 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 13:05:57,265 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 13:05:57,266 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-02-10 13:05:57,271 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_r_000000_0 is done. And is in the process of commiting
2015-02-10 13:05:57,272 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2015-02-10 13:05:57,272 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0015_r_000000_0 is allowed to commit now
2015-02-10 13:05:57,275 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple
2015-02-10 13:06:00,253 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 13:06:00,254 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_r_000000_0' done.
2015-02-10 13:06:00,264 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2015-02-10 13:06:00,273 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 13:06:00,275 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/basicpipesplatform/simple