Class cascading.BasicPipesPlatformTest

14

tests

0

failures

1m22.09s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 9.132s passed
testCount 6.193s passed
testCount2 6.123s passed
testCount3 6.108s passed
testCount4 6.588s passed
testFilter 3.088s passed
testFilterAll 3.088s passed
testReplace 3.083s passed
testSimple 6.869s passed
testSimpleChain 13.096s passed
testSimpleRelative 6.130s passed
testSimpleResult 6.334s passed
testSwap 3.141s passed
testUnGroup 3.118s passed

Standard output

2013-11-20 10:32:04,550 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 10:32:04,574 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 10:32:04,575 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2013-11-20 10:32:04,607 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 10:32:04,956 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:04,958 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:04,970 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: FF5FA23DEF3D4E6DB298307B3A619649
2013-11-20 10:32:05,187 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 10:32:05,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:05,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:05,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-11-20 10:32:05,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:05,192 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 2
2013-11-20 10:32:05,192 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:05,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/2)
2013-11-20 10:32:05,237 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 10:32:05,286 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:05,475 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0001
2013-11-20 10:32:05,534 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 10:32:05,542 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6e3e5a91
2013-11-20 10:32:05,550 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:32:05,558 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:05,566 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:05,700 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:05,700 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:05,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:05,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:05,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:05,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:05,791 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:05,802 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:05,805 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:08,520 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:32:08,521 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2013-11-20 10:32:08,531 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2dd1082f
2013-11-20 10:32:08,532 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:08,537 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:32:08,542 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 10:32:08,543 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:08,545 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:32:08,546 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:32:08,563 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:08,564 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][8705095182/test/]
2013-11-20 10:32:08,586 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:08,587 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:08,589 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2013-11-20 10:32:08,592 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/tmp/hadoop-teamcity/8705095182_test_C44EED5B028544F48D2FE8802C9A5537
2013-11-20 10:32:11,531 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:32:11,534 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_r_000000_0' done.
2013-11-20 10:32:11,546 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2013-11-20 10:32:11,567 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:11,647 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0002
2013-11-20 10:32:11,652 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7e63f09e
2013-11-20 10:32:11,653 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/8705095182_test_C44EED5B028544F48D2FE8802C9A5537/part-00000
2013-11-20 10:32:11,661 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:11,661 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:12,243 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:12,244 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:12,245 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:12,245 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:12,257 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][8705095182/test/]
2013-11-20 10:32:12,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:12,260 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:12,264 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:12,267 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:14,652 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/tmp/hadoop-teamcity/8705095182_test_C44EED5B028544F48D2FE8802C9A5537/part-00000:0+310
2013-11-20 10:32:14,653 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2013-11-20 10:32:14,658 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7e9b59a2
2013-11-20 10:32:14,659 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:14,660 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:32:14,661 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 202 bytes
2013-11-20 10:32:14,661 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:14,662 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:32:14,662 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:32:14,673 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:14,673 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-11-20 10:32:14,682 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:14,683 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:14,684 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2013-11-20 10:32:14,688 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplechain
2013-11-20 10:32:17,659 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:32:17,660 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_r_000000_0' done.
2013-11-20 10:32:17,678 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2013-11-20 10:32:17,698 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:17,700 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/simplechain
2013-11-20 10:32:17,720 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:17,721 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:17,743 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 10:32:17,744 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:32:17,745 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count"]
2013-11-20 10:32:17,746 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 10:32:17,747 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 10:32:17,747 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 10:32:17,748 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) .../basicpipesplatform/count
2013-11-20 10:32:17,765 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:17,837 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0003
2013-11-20 10:32:17,841 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@66c360a5
2013-11-20 10:32:17,843 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2013-11-20 10:32:17,844 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:17,845 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:17,968 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:17,970 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:17,976 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:17,977 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:17,987 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:32:17,987 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:32:17,992 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:17,998 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:18,001 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:20,842 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt:0+275
2013-11-20 10:32:20,843 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2013-11-20 10:32:20,848 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6a6014f7
2013-11-20 10:32:20,848 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:20,849 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:32:20,850 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 10:32:20,850 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:20,851 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:32:20,851 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:32:20,859 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:32:20,859 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count"]
2013-11-20 10:32:20,869 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:20,870 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:20,871 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2013-11-20 10:32:20,874 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count
2013-11-20 10:32:23,848 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:32:23,849 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_r_000000_0' done.
2013-11-20 10:32:23,856 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count/_temporary
2013-11-20 10:32:23,875 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:23,893 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:23,896 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/count
2013-11-20 10:32:23,913 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:23,914 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:23,932 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:23,933 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:23,933 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/swap"]
2013-11-20 10:32:23,933 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:23,934 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:32:23,934 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:23,934 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2013-11-20 10:32:23,957 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:24,004 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0004
2013-11-20 10:32:24,009 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@10320399
2013-11-20 10:32:24,011 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:32:24,013 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 10:32:24,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:24,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:24,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:24,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/swap"]
2013-11-20 10:32:24,031 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:24,032 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:24,032 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2013-11-20 10:32:24,036 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/swap
2013-11-20 10:32:27,009 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:32:27,010 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2013-11-20 10:32:27,023 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2013-11-20 10:32:27,036 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:27,038 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/swap
2013-11-20 10:32:27,051 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:27,052 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:27,073 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:27,073 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2013-11-20 10:32:27,073 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-11-20 10:32:27,074 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:27,074 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:32:27,074 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:27,075 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2013-11-20 10:32:27,090 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:27,123 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0005
2013-11-20 10:32:27,128 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7182c2d9
2013-11-20 10:32:27,131 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2013-11-20 10:32:27,133 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 10:32:27,139 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:27,139 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:27,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2013-11-20 10:32:27,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-11-20 10:32:27,150 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:27,150 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:27,151 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2013-11-20 10:32:27,155 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/ungrouped
2013-11-20 10:32:30,128 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower+upper.txt:0+30
2013-11-20 10:32:30,129 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2013-11-20 10:32:30,142 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2013-11-20 10:32:30,155 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:30,157 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/ungrouped
2013-11-20 10:32:30,168 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:30,169 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:30,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:30,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:30,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-11-20 10:32:30,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:30,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:32:30,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:30,192 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...esplatform/simplerelative
2013-11-20 10:32:30,207 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:30,238 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0006
2013-11-20 10:32:30,256 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3ab6f7f5
2013-11-20 10:32:30,258 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:32:30,259 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:30,260 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:30,377 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:30,377 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:30,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:30,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:30,389 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:30,389 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:30,392 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:30,395 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:30,397 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:33,255 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:32:33,256 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2013-11-20 10:32:33,261 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@19fcbac1
2013-11-20 10:32:33,261 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:33,263 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:32:33,264 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 10:32:33,265 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:33,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:32:33,266 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:32:33,275 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:33,275 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-11-20 10:32:33,283 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:33,284 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:33,285 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_r_000000_0 is allowed to commit now
2013-11-20 10:32:33,289 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplerelative
2013-11-20 10:32:36,261 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:32:36,263 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_r_000000_0' done.
2013-11-20 10:32:36,275 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2013-11-20 10:32:36,286 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:36,288 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/simplerelative
2013-11-20 10:32:36,505 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:36,506 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:36,537 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:36,538 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2013-11-20 10:32:36,538 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-11-20 10:32:36,538 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:36,539 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:32:36,539 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:36,539 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2013-11-20 10:32:36,554 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:36,587 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0007
2013-11-20 10:32:36,596 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@24eff2c
2013-11-20 10:32:36,597 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt
2013-11-20 10:32:36,599 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:36,600 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:36,723 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:36,723 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:36,725 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:36,725 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:36,737 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2013-11-20 10:32:36,737 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:36,871 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:36,874 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:36,876 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:39,596 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt:0+19
2013-11-20 10:32:39,597 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2013-11-20 10:32:39,601 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3a4c585f
2013-11-20 10:32:39,601 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:39,603 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:32:39,603 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 28 bytes
2013-11-20 10:32:39,603 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:39,604 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:32:39,604 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:32:39,615 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:32:39,615 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-11-20 10:32:39,621 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:39,621 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:39,622 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_r_000000_0 is allowed to commit now
2013-11-20 10:32:39,625 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simpleresult
2013-11-20 10:32:42,601 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:32:42,602 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_r_000000_0' done.
2013-11-20 10:32:42,611 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2013-11-20 10:32:42,622 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:42,623 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/simpleresult
2013-11-20 10:32:42,633 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:42,634 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:42,649 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:42,649 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:42,649 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-11-20 10:32:42,650 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:42,650 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:32:42,650 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:42,651 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2013-11-20 10:32:42,664 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:42,691 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0008
2013-11-20 10:32:42,695 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2d6acad2
2013-11-20 10:32:42,697 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:32:42,698 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 10:32:42,702 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:42,702 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:42,708 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:42,708 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-11-20 10:32:42,711 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:42,712 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:42,713 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-11-20 10:32:42,715 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filterall
2013-11-20 10:32:45,695 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:32:45,696 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2013-11-20 10:32:45,700 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2013-11-20 10:32:45,710 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:45,712 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/filterall
2013-11-20 10:32:45,722 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:45,723 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:45,751 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting
2013-11-20 10:32:45,752 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2013-11-20 10:32:45,752 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2013-11-20 10:32:45,752 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-11-20 10:32:45,752 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  parallel execution is enabled: false
2013-11-20 10:32:45,753 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  starting jobs: 1
2013-11-20 10:32:45,753 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper]  allocating threads: 1
2013-11-20 10:32:45,753 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2013-11-20 10:32:45,766 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:45,768 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:45,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] submitted hadoop job: job_local_0009
2013-11-20 10:32:45,798 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@23bca486
2013-11-20 10:32:45,799 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt
2013-11-20 10:32:45,800 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:45,801 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:46,150 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:46,150 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:46,153 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:46,153 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:46,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2013-11-20 10:32:46,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-11-20 10:32:46,167 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:46,170 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:46,171 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:48,798 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/lower.txt:0+19
2013-11-20 10:32:48,799 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000000_0' done.
2013-11-20 10:32:48,801 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@16ff6348
2013-11-20 10:32:48,803 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/upper.txt
2013-11-20 10:32:48,804 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:48,805 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:48,928 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:48,928 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:48,929 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:48,930 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:48,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2013-11-20 10:32:48,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-11-20 10:32:48,942 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:48,944 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:48,946 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000001_0 is done. And is in the process of commiting
2013-11-20 10:32:51,802 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/upper.txt:0+19
2013-11-20 10:32:51,802 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000001_0' done.
2013-11-20 10:32:51,810 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@b2e0e2f
2013-11-20 10:32:51,810 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:51,812 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2013-11-20 10:32:51,851 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2013-11-20 10:32:51,851 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:51,852 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:32:51,853 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:32:51,897 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-11-20 10:32:51,897 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-11-20 10:32:51,908 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 10:32:51,909 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 10:32:51,916 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:51,917 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:51,918 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0009_r_000000_0 is allowed to commit now
2013-11-20 10:32:51,921 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/complexcogroup
2013-11-20 10:32:54,810 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:32:54,811 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_r_000000_0' done.
2013-11-20 10:32:54,821 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2013-11-20 10:32:54,831 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:54,842 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:54,844 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/complexcogroup
2013-11-20 10:32:54,853 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:54,854 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:54,867 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:32:54,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:54,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/replace"]
2013-11-20 10:32:54,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:32:54,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:32:54,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:32:54,870 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2013-11-20 10:32:54,884 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:54,907 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0010
2013-11-20 10:32:54,911 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4eabaf8c
2013-11-20 10:32:54,913 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:32:54,914 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 10:32:54,918 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:54,918 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:54,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:32:54,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/replace"]
2013-11-20 10:32:54,930 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:32:54,931 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:32:54,931 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0010_m_000000_0 is allowed to commit now
2013-11-20 10:32:54,934 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/replace
2013-11-20 10:32:57,911 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:32:57,912 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0010_m_000000_0' done.
2013-11-20 10:32:57,916 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2013-11-20 10:32:57,926 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:57,928 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/replace
2013-11-20 10:32:57,937 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:32:57,938 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:32:57,954 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 10:32:57,955 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:32:57,955 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count2"]
2013-11-20 10:32:57,955 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 10:32:57,955 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 10:32:57,955 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 10:32:57,956 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2013-11-20 10:32:57,967 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:32:58,000 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0011
2013-11-20 10:32:58,018 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@26137fea
2013-11-20 10:32:58,019 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2013-11-20 10:32:58,020 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:32:58,021 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:32:58,139 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:32:58,139 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:32:58,140 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:32:58,141 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:32:58,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:32:58,148 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:32:58,151 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:32:58,155 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:32:58,156 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:01,018 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt:0+275
2013-11-20 10:33:01,019 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_m_000000_0' done.
2013-11-20 10:33:01,022 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7dc4cd9
2013-11-20 10:33:01,023 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:01,024 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:33:01,024 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 10:33:01,024 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:01,025 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:33:01,025 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:33:01,032 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:33:01,032 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count2"]
2013-11-20 10:33:01,040 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:01,040 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:01,041 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2013-11-20 10:33:01,044 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count2
2013-11-20 10:33:04,022 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:33:04,023 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_r_000000_0' done.
2013-11-20 10:33:04,031 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2013-11-20 10:33:04,040 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:04,050 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:04,052 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/count2
2013-11-20 10:33:04,061 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:33:04,061 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:33:04,076 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 10:33:04,077 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:33:04,077 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count3"]
2013-11-20 10:33:04,077 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 10:33:04,077 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 10:33:04,077 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 10:33:04,078 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2013-11-20 10:33:04,091 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:04,115 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0012
2013-11-20 10:33:04,119 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5f3c6654
2013-11-20 10:33:04,121 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2013-11-20 10:33:04,122 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:33:04,123 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:33:04,241 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:33:04,242 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:33:04,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:33:04,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:33:04,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:33:04,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:33:04,256 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:33:04,260 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:33:04,262 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:07,120 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt:0+275
2013-11-20 10:33:07,120 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_m_000000_0' done.
2013-11-20 10:33:07,124 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6b6d079a
2013-11-20 10:33:07,124 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:07,126 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:33:07,126 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 10:33:07,126 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:07,127 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:33:07,127 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:33:07,134 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:33:07,135 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count3"]
2013-11-20 10:33:07,142 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:07,142 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:07,143 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0012_r_000000_0 is allowed to commit now
2013-11-20 10:33:07,145 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count3
2013-11-20 10:33:10,124 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:33:10,125 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_r_000000_0' done.
2013-11-20 10:33:10,139 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2013-11-20 10:33:10,148 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:10,159 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:10,161 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/count3
2013-11-20 10:33:10,171 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:33:10,172 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:33:10,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-11-20 10:33:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:33:10,188 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count4"]
2013-11-20 10:33:10,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  parallel execution is enabled: false
2013-11-20 10:33:10,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  starting jobs: 1
2013-11-20 10:33:10,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [count]  allocating threads: 1
2013-11-20 10:33:10,190 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2013-11-20 10:33:10,201 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:10,224 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local_0013
2013-11-20 10:33:10,227 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@39341183
2013-11-20 10:33:10,228 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt
2013-11-20 10:33:10,229 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:33:10,230 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:33:10,347 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:33:10,348 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:33:10,349 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:33:10,349 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:33:10,355 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt"]
2013-11-20 10:33:10,356 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:33:10,359 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:33:10,362 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:33:10,364 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:13,227 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/ips.20.txt:0+275
2013-11-20 10:33:13,228 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_m_000000_0' done.
2013-11-20 10:33:13,720 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4defb0be
2013-11-20 10:33:13,720 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:13,721 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:33:13,721 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-11-20 10:33:13,722 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:13,722 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:33:13,723 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:33:13,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-11-20 10:33:13,729 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count4"]
2013-11-20 10:33:13,736 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:13,737 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:13,738 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0013_r_000000_0 is allowed to commit now
2013-11-20 10:33:13,740 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count4
2013-11-20 10:33:16,719 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:33:16,720 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_r_000000_0' done.
2013-11-20 10:33:16,726 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2013-11-20 10:33:16,737 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:16,748 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:16,750 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/count4
2013-11-20 10:33:16,760 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:33:16,761 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:33:16,776 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:33:16,777 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:33:16,777 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filter"]
2013-11-20 10:33:16,777 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:33:16,777 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:33:16,778 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:33:16,778 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2013-11-20 10:33:16,791 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:16,816 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0014
2013-11-20 10:33:16,820 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6a4d37e5
2013-11-20 10:33:16,821 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:33:16,822 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 10:33:16,825 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:33:16,826 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:33:16,831 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:33:16,832 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filter"]
2013-11-20 10:33:16,834 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:16,834 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:16,835 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2013-11-20 10:33:16,837 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filter
2013-11-20 10:33:19,820 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:33:19,821 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_m_000000_0' done.
2013-11-20 10:33:19,826 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2013-11-20 10:33:19,836 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:19,838 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/filter
2013-11-20 10:33:19,849 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 10:33:19,849 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 10:33:19,867 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-11-20 10:33:19,867 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:33:19,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simple"]
2013-11-20 10:33:19,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  parallel execution is enabled: false
2013-11-20 10:33:19,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  starting jobs: 1
2013-11-20 10:33:19,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [test]  allocating threads: 1
2013-11-20 10:33:19,869 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2013-11-20 10:33:19,880 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:19,903 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0015
2013-11-20 10:33:19,908 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@54bbb2d0
2013-11-20 10:33:19,912 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2013-11-20 10:33:19,913 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2013-11-20 10:33:19,914 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2013-11-20 10:33:20,268 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2013-11-20 10:33:20,269 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2013-11-20 10:33:20,271 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 10:33:20,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 10:33:20,280 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2013-11-20 10:33:20,281 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:33:20,284 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2013-11-20 10:33:20,287 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2013-11-20 10:33:20,288 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:22,908 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache.10.txt:0+1449
2013-11-20 10:33:22,909 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_m_000000_0' done.
2013-11-20 10:33:23,665 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@9fa8988
2013-11-20 10:33:23,665 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:23,666 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2013-11-20 10:33:23,667 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-11-20 10:33:23,667 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:23,668 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-11-20 10:33:23,669 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-11-20 10:33:23,676 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-11-20 10:33:23,677 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simple"]
2013-11-20 10:33:23,682 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_r_000000_0 is done. And is in the process of commiting
2013-11-20 10:33:23,683 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-11-20 10:33:23,685 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0015_r_000000_0 is allowed to commit now
2013-11-20 10:33:23,687 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simple
2013-11-20 10:33:26,665 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-11-20 10:33:26,667 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_r_000000_0' done.
2013-11-20 10:33:26,698 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2013-11-20 10:33:26,706 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 10:33:26,708 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/basicpipesplatform/simple