2015-02-10 15:27:18,948 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 15:27:18,997 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 15:27:18,997 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2015-02-10 15:27:19,032 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 15:27:19,441 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:19,443 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 15:27:19,457 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 01C4C80560CF4260A154F42A17A5E7F1
2015-02-10 15:27:19,712 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 15:27:19,715 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:19,716 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:19,716 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-02-10 15:27:19,717 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:19,717 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 2
2015-02-10 15:27:19,717 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:19,719 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/2)
2015-02-10 15:27:19,767 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 15:27:19,832 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 15:27:19,836 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:20,088 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0001
2015-02-10 15:27:20,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:20,162 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 15:27:20,172 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@24a09e41
2015-02-10 15:27:20,180 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:20,188 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:20,197 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:20,339 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:20,339 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:20,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:20,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,435 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:20,436 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,451 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:20,465 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:20,468 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,472 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:20,474 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0001_m_000000_0' done.
2015-02-10 15:27:20,485 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@540523be
2015-02-10 15:27:20,485 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:20,492 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:20,499 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 15:27:20,499 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:20,502 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:20,502 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,523 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,523 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][2772040731/test/]
2015-02-10 15:27:20,550 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,551 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:20,552 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2015-02-10 15:27:20,556 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/tmp/hadoop-teamcity/2772040731_test_4A75CC09A8C84718A290FE53DBC671B2
2015-02-10 15:27:20,557 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:20,558 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0001_r_000000_0' done.
2015-02-10 15:27:20,565 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2015-02-10 15:27:20,584 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:20,687 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0002
2015-02-10 15:27:20,688 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:20,694 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@19123eb0
2015-02-10 15:27:20,696 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/2772040731_test_4A75CC09A8C84718A290FE53DBC671B2/part-00000
2015-02-10 15:27:20,705 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:20,706 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:20,848 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:20,849 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:20,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:20,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,866 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][2772040731/test/]
2015-02-10 15:27:20,866 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,869 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:20,873 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:20,876 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,877 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/tmp/hadoop-teamcity/2772040731_test_4A75CC09A8C84718A290FE53DBC671B2/part-00000:0+310
2015-02-10 15:27:20,878 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0002_m_000000_0' done.
2015-02-10 15:27:20,884 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@42bb0406
2015-02-10 15:27:20,884 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:20,886 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:20,886 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 15:27:20,887 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:20,888 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:20,888 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:20,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:20,900 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain"]
2015-02-10 15:27:20,909 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:20,910 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:20,911 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2015-02-10 15:27:20,915 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.1.x/build/test/output/hadoop/basicpipesplatform/simplechain
2015-02-10 15:27:20,916 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:20,916 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0002_r_000000_0' done.
2015-02-10 15:27:20,934 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2015-02-10 15:27:20,957 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:20,965 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplechain
2015-02-10 15:27:20,990 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:20,991 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 15:27:21,017 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:21,018 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:21,018 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-02-10 15:27:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 15:27:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 15:27:21,019 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 15:27:21,021 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) .../basicpipesplatform/count
2015-02-10 15:27:21,037 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,101 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0003
2015-02-10 15:27:21,102 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:21,105 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@279977bd
2015-02-10 15:27:21,107 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:21,109 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:21,109 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:21,243 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:21,243 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:21,245 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,245 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:21,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:21,261 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:21,267 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:21,269 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,271 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:21,272 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0003_m_000000_0' done.
2015-02-10 15:27:21,277 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1a3526cf
2015-02-10 15:27:21,277 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:21,279 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:21,279 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 15:27:21,280 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:21,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:21,281 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:21,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count"]
2015-02-10 15:27:21,301 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,302 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:21,303 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2015-02-10 15:27:21,307 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.1.x/build/test/output/hadoop/basicpipesplatform/count
2015-02-10 15:27:21,307 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:21,308 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0003_r_000000_0' done.
2015-02-10 15:27:21,315 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count/_temporary
2015-02-10 15:27:21,337 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,359 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,362 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count
2015-02-10 15:27:21,383 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:21,384 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 15:27:21,406 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:21,407 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,407 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-02-10 15:27:21,407 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:21,408 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:21,408 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:21,408 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2015-02-10 15:27:21,425 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,478 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0004
2015-02-10 15:27:21,478 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:21,482 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@665c1eae
2015-02-10 15:27:21,484 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:21,485 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:21,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,501 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,501 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap"]
2015-02-10 15:27:21,505 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,506 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:21,507 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2015-02-10 15:27:21,511 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.1.x/build/test/output/hadoop/basicpipesplatform/swap
2015-02-10 15:27:21,511 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:21,512 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0004_m_000000_0' done.
2015-02-10 15:27:21,519 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2015-02-10 15:27:21,541 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,545 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/swap
2015-02-10 15:27:21,562 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:21,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 15:27:21,587 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:21,588 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2015-02-10 15:27:21,588 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-02-10 15:27:21,588 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:21,589 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:21,589 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:21,590 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2015-02-10 15:27:21,605 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,645 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0005
2015-02-10 15:27:21,646 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:21,650 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5dd6c336
2015-02-10 15:27:21,651 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt
2015-02-10 15:27:21,653 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:21,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt"]
2015-02-10 15:27:21,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2015-02-10 15:27:21,670 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,671 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:21,672 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2015-02-10 15:27:21,676 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.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped
2015-02-10 15:27:21,676 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower+upper.txt:0+30
2015-02-10 15:27:21,677 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0005_m_000000_0' done.
2015-02-10 15:27:21,687 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2015-02-10 15:27:21,701 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,704 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/ungrouped
2015-02-10 15:27:21,720 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:21,721 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 15:27:21,750 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:21,751 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,752 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-02-10 15:27:21,753 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:21,753 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:21,754 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:21,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...esplatform/simplerelative
2015-02-10 15:27:21,769 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:21,809 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0006
2015-02-10 15:27:21,810 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:21,813 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@30db95a1
2015-02-10 15:27:21,815 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:21,816 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:21,817 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:21,974 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:21,974 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:21,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:21,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:21,986 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:21,987 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:21,990 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:21,994 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:21,996 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:21,997 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:21,998 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0006_m_000000_0' done.
2015-02-10 15:27:22,003 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2755d4be
2015-02-10 15:27:22,003 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,005 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:22,005 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 15:27:22,006 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,007 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:22,007 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,016 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:22,017 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2015-02-10 15:27:22,025 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,026 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,027 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0006_r_000000_0 is allowed to commit now
2015-02-10 15:27:22,030 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.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative
2015-02-10 15:27:22,031 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:22,032 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0006_r_000000_0' done.
2015-02-10 15:27:22,044 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2015-02-10 15:27:22,059 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,062 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simplerelative
2015-02-10 15:27:22,312 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:22,313 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 15:27:22,349 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:22,349 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:22,350 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-02-10 15:27:22,350 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:22,351 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:22,351 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:22,353 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2015-02-10 15:27:22,368 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,404 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0007
2015-02-10 15:27:22,406 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:22,410 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b5ede11
2015-02-10 15:27:22,412 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt
2015-02-10 15:27:22,413 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:22,413 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:22,548 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:22,548 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:22,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:22,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:22,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:22,665 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:22,667 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:22,669 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,671 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt:0+19
2015-02-10 15:27:22,672 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0007_m_000000_0' done.
2015-02-10 15:27:22,676 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2a5b8e8c
2015-02-10 15:27:22,676 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,677 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:22,678 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 15:27:22,678 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,679 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:22,679 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,690 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:22,691 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2015-02-10 15:27:22,696 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,697 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,698 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0007_r_000000_0 is allowed to commit now
2015-02-10 15:27:22,701 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.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult
2015-02-10 15:27:22,701 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:22,702 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0007_r_000000_0' done.
2015-02-10 15:27:22,710 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2015-02-10 15:27:22,750 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,752 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simpleresult
2015-02-10 15:27:22,764 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:22,765 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 15:27:22,798 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:22,799 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:22,799 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-02-10 15:27:22,800 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:22,800 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:22,800 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:22,801 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2015-02-10 15:27:22,813 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,844 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0008
2015-02-10 15:27:22,845 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:22,849 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7d1050be
2015-02-10 15:27:22,851 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:22,852 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:22,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:22,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:22,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:22,865 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall"]
2015-02-10 15:27:22,868 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:22,869 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:22,869 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2015-02-10 15:27:22,873 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.1.x/build/test/output/hadoop/basicpipesplatform/filterall
2015-02-10 15:27:22,873 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:22,874 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0008_m_000000_0' done.
2015-02-10 15:27:22,887 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2015-02-10 15:27:22,898 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,900 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/filterall
2015-02-10 15:27:22,913 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:22,914 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 15:27:22,946 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] starting
2015-02-10 15:27:22,947 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-02-10 15:27:22,947 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:22,947 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-02-10 15:27:22,948 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] parallel execution is enabled: false
2015-02-10 15:27:22,948 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] starting jobs: 1
2015-02-10 15:27:22,948 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [lower*upper] allocating threads: 1
2015-02-10 15:27:22,949 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2015-02-10 15:27:22,961 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,962 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:22,989 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] submitted hadoop job: job_local_0009
2015-02-10 15:27:22,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] tracking url: http://localhost:8080/
2015-02-10 15:27:22,993 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@16365c90
2015-02-10 15:27:22,995 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt
2015-02-10 15:27:22,997 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:22,997 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:23,370 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:23,373 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:23,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:23,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,389 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt"]
2015-02-10 15:27:23,390 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 15:27:23,393 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:23,396 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:23,398 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:23,399 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/upper.txt:0+19
2015-02-10 15:27:23,401 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0009_m_000000_0' done.
2015-02-10 15:27:23,403 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@78d2883b
2015-02-10 15:27:23,405 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt
2015-02-10 15:27:23,406 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:23,407 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:23,548 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:23,549 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:23,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:23,551 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,561 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt"]
2015-02-10 15:27:23,562 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 15:27:23,564 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:23,567 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:23,569 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0009_m_000001_0 is done. And is in the process of commiting
2015-02-10 15:27:23,571 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/lower.txt:0+19
2015-02-10 15:27:23,572 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0009_m_000001_0' done.
2015-02-10 15:27:23,580 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5cee644c
2015-02-10 15:27:23,580 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:23,582 INFO mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2015-02-10 15:27:23,583 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 15:27:23,584 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:23,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:23,586 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,594 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-02-10 15:27:23,595 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2015-02-10 15:27:23,607 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 15:27:23,607 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 15:27:23,615 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:23,616 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:23,618 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0009_r_000000_0 is allowed to commit now
2015-02-10 15:27:23,621 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.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup
2015-02-10 15:27:23,622 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:23,623 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0009_r_000000_0' done.
2015-02-10 15:27:23,633 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2015-02-10 15:27:23,644 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,656 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,658 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/complexcogroup
2015-02-10 15:27:23,669 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:23,670 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 15:27:23,685 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:23,686 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:23,686 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-02-10 15:27:23,686 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:23,687 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:23,687 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:23,687 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2015-02-10 15:27:23,699 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0010
2015-02-10 15:27:23,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:23,733 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@87e05c4
2015-02-10 15:27:23,734 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:23,736 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:23,740 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:23,741 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:23,748 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:23,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace"]
2015-02-10 15:27:23,751 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:23,753 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:23,754 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0010_m_000000_0 is allowed to commit now
2015-02-10 15:27:23,757 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.1.x/build/test/output/hadoop/basicpipesplatform/replace
2015-02-10 15:27:23,758 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:23,759 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0010_m_000000_0' done.
2015-02-10 15:27:23,770 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2015-02-10 15:27:23,781 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,783 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/replace
2015-02-10 15:27:23,796 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:23,797 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 15:27:23,817 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:23,817 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:23,817 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-02-10 15:27:23,818 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 15:27:23,818 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 15:27:23,818 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 15:27:23,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2015-02-10 15:27:23,830 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:23,858 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0011
2015-02-10 15:27:23,859 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:23,864 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6efde050
2015-02-10 15:27:23,866 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:23,868 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:23,869 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:24,036 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:24,036 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:24,038 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,052 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:24,057 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:24,060 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,061 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:24,062 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0011_m_000000_0' done.
2015-02-10 15:27:24,067 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6647108e
2015-02-10 15:27:24,067 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,069 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:24,069 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 15:27:24,070 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,071 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:24,071 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,079 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,079 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2"]
2015-02-10 15:27:24,090 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,092 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,093 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2015-02-10 15:27:24,096 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.1.x/build/test/output/hadoop/basicpipesplatform/count2
2015-02-10 15:27:24,097 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:24,098 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0011_r_000000_0' done.
2015-02-10 15:27:24,103 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2015-02-10 15:27:24,115 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,128 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,130 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count2
2015-02-10 15:27:24,147 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,148 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 15:27:24,170 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:24,170 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,170 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-02-10 15:27:24,171 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 15:27:24,171 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 15:27:24,171 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 15:27:24,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2015-02-10 15:27:24,184 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,223 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0012
2015-02-10 15:27:24,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:24,233 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5ac524dd
2015-02-10 15:27:24,234 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:24,236 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:24,236 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:24,370 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:24,370 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:24,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,372 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,383 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:24,387 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:24,388 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,390 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:24,390 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0012_m_000000_0' done.
2015-02-10 15:27:24,394 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@59bd523d
2015-02-10 15:27:24,394 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,395 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:24,396 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 15:27:24,396 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,397 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:24,397 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,404 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,404 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3"]
2015-02-10 15:27:24,412 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0012_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,413 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,413 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0012_r_000000_0 is allowed to commit now
2015-02-10 15:27:24,416 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.1.x/build/test/output/hadoop/basicpipesplatform/count3
2015-02-10 15:27:24,417 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:24,417 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0012_r_000000_0' done.
2015-02-10 15:27:24,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2015-02-10 15:27:24,434 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,447 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,449 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count3
2015-02-10 15:27:24,462 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,463 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 15:27:24,480 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting
2015-02-10 15:27:24,480 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,481 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-02-10 15:27:24,481 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] parallel execution is enabled: false
2015-02-10 15:27:24,481 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] starting jobs: 1
2015-02-10 15:27:24,481 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [count] allocating threads: 1
2015-02-10 15:27:24,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2015-02-10 15:27:24,494 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,518 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] submitted hadoop job: job_local_0013
2015-02-10 15:27:24,518 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [count] tracking url: http://localhost:8080/
2015-02-10 15:27:24,522 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@30a4effe
2015-02-10 15:27:24,523 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt
2015-02-10 15:27:24,524 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:24,525 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:24,663 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:24,664 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:24,665 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,665 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt"]
2015-02-10 15:27:24,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,677 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:24,681 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:24,683 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,684 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 15:27:24,685 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0013_m_000000_0' done.
2015-02-10 15:27:24,689 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3a47c130
2015-02-10 15:27:24,689 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,691 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:24,691 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 15:27:24,691 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,692 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:24,692 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,699 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-02-10 15:27:24,699 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4"]
2015-02-10 15:27:24,708 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0013_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,708 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,709 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0013_r_000000_0 is allowed to commit now
2015-02-10 15:27:24,713 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.1.x/build/test/output/hadoop/basicpipesplatform/count4
2015-02-10 15:27:24,715 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:24,716 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0013_r_000000_0' done.
2015-02-10 15:27:24,722 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2015-02-10 15:27:24,731 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,741 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,743 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/count4
2015-02-10 15:27:24,755 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,755 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 15:27:24,769 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:24,771 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:24,771 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-02-10 15:27:24,772 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:24,772 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:24,772 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:24,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2015-02-10 15:27:24,784 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,808 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0014
2015-02-10 15:27:24,809 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:24,812 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@63376afa
2015-02-10 15:27:24,813 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:24,815 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 15:27:24,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:24,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:24,824 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:24,825 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter"]
2015-02-10 15:27:24,827 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:24,827 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:24,828 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2015-02-10 15:27:24,831 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.1.x/build/test/output/hadoop/basicpipesplatform/filter
2015-02-10 15:27:24,831 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:24,832 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0014_m_000000_0' done.
2015-02-10 15:27:24,841 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2015-02-10 15:27:24,852 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,853 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/filter
2015-02-10 15:27:24,865 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 15:27:24,865 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 15:27:24,884 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting
2015-02-10 15:27:24,885 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:24,885 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-02-10 15:27:24,885 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] parallel execution is enabled: false
2015-02-10 15:27:24,885 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] starting jobs: 1
2015-02-10 15:27:24,885 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [test] allocating threads: 1
2015-02-10 15:27:24,886 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2015-02-10 15:27:24,898 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:24,922 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local_0015
2015-02-10 15:27:24,923 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2015-02-10 15:27:24,925 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@538787fd
2015-02-10 15:27:24,928 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt
2015-02-10 15:27:24,929 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 15:27:24,929 INFO mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 15:27:25,262 INFO mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 15:27:25,262 INFO mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 15:27:25,264 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 15:27:25,264 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 15:27:25,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt"]
2015-02-10 15:27:25,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:25,276 INFO mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 15:27:25,279 INFO mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 15:27:25,280 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:25,282 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/classes/test/data/apache.10.txt:0+1449
2015-02-10 15:27:25,282 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0015_m_000000_0' done.
2015-02-10 15:27:25,285 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@161e14f0
2015-02-10 15:27:25,286 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:25,287 INFO mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 15:27:25,287 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 15:27:25,287 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:25,288 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 15:27:25,288 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 15:27:25,296 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-02-10 15:27:25,297 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple"]
2015-02-10 15:27:25,302 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local_0015_r_000000_0 is done. And is in the process of commiting
2015-02-10 15:27:25,303 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) -
2015-02-10 15:27:25,304 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local_0015_r_000000_0 is allowed to commit now
2015-02-10 15:27:25,306 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.1.x/build/test/output/hadoop/basicpipesplatform/simple
2015-02-10 15:27:25,306 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(323)) - reduce > reduce
2015-02-10 15:27:25,307 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local_0015_r_000000_0' done.
2015-02-10 15:27:25,313 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2015-02-10 15:27:25,322 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 15:27:25,324 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.1.x/build/test/output//hadoop/basicpipesplatform/simple