Class cascading.SortedValuesPlatformTest

4

tests

0

failures

2m57.51s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparatorValues 15.195s passed
testCoGroupComparatorValuesReversed 16.144s passed
testComprehensiveGroupBy 2m26.15s passed
testSortFails 0.024s passed

Standard output

2015-02-10 14:08:48,932 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 14:08:48,980 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 14:08:48,981 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.SortedValuesPlatformTest
2015-02-10 14:08:49,018 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 14:08:49,422 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:08:49,424 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 14:08:49,439 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 36444AE541BB45D093840EC8F922E2E3
2015-02-10 14:08:49,703 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 14:08:49,706 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip] starting
2015-02-10 14:08:49,707 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2015-02-10 14:08:49,707 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 14:08:49,708 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcomparereversed"]
2015-02-10 14:08:49,708 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  parallel execution is enabled: false
2015-02-10 14:08:49,708 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  starting jobs: 1
2015-02-10 14:08:49,709 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  allocating threads: 1
2015-02-10 14:08:49,711 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [apache*ip] starting step: (1/1) ...rm/cogroupcomparereversed
2015-02-10 14:08:49,759 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 14:08:49,806 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 14:08:49,809 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:08:49,819 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:08:50,022 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [apache*ip] submitted hadoop job: job_local_0001
2015-02-10 14:08:50,024 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [apache*ip] tracking url: http://localhost:8080/
2015-02-10 14:08:50,088 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 14:08:50,097 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@69c01ba9
2015-02-10 14:08:50,104 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt
2015-02-10 14:08:50,111 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:08:50,119 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:08:50,285 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:08:50,285 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:08:50,307 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:08:50,307 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:08:50,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2015-02-10 14:08:50,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-02-10 14:08:50,496 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:08:56,074 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt:0+32599
2015-02-10 14:08:58,791 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:08:58,795 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:08:59,075 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt:0+32599
2015-02-10 14:08:59,077 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt:0+32599
2015-02-10 14:08:59,078 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2015-02-10 14:08:59,081 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@34cf935a
2015-02-10 14:08:59,083 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt
2015-02-10 14:08:59,085 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:08:59,086 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:08:59,103 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:08:59,104 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:08:59,107 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:08:59,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:08:59,128 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 14:08:59,129 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-02-10 14:08:59,135 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:00,119 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:00,122 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000001_0 is done. And is in the process of commiting
2015-02-10 14:09:02,081 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 14:09:02,083 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000001_0' done.
2015-02-10 14:09:02,096 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@85e57
2015-02-10 14:09:02,097 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:02,104 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2015-02-10 14:09:02,118 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 2 segments left of total size: 10047 bytes
2015-02-10 14:09:02,119 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:02,122 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:02,123 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:02,142 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-02-10 14:09:02,143 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcomparereversed"]
2015-02-10 14:09:02,161 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 14:09:02,162 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 14:09:03,982 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:03,983 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:03,985 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2015-02-10 14:09:03,989 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcomparereversed
2015-02-10 14:09:05,096 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:05,098 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_r_000000_0' done.
2015-02-10 14:09:05,113 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcomparereversed/_temporary
2015-02-10 14:09:05,123 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:05,160 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/cogroupcomparereversed
2015-02-10 14:09:05,179 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:05,180 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 14:09:05,224 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip] starting
2015-02-10 14:09:05,225 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2015-02-10 14:09:05,225 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 14:09:05,225 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcompareforward"]
2015-02-10 14:09:05,226 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  parallel execution is enabled: false
2015-02-10 14:09:05,226 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  starting jobs: 1
2015-02-10 14:09:05,226 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [apache*ip]  allocating threads: 1
2015-02-10 14:09:05,227 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [apache*ip] starting step: (1/1) ...orm/cogroupcompareforward
2015-02-10 14:09:05,244 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:05,245 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:05,291 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [apache*ip] submitted hadoop job: job_local_0002
2015-02-10 14:09:05,292 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [apache*ip] tracking url: http://localhost:8080/
2015-02-10 14:09:05,295 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@23ebe8ec
2015-02-10 14:09:05,297 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt
2015-02-10 14:09:05,299 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:05,299 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:05,322 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:05,327 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:05,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:05,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:05,347 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt"]
2015-02-10 14:09:05,347 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-02-10 14:09:05,409 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:11,295 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt:0+32599
2015-02-10 14:09:12,378 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:12,380 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:14,297 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt:0+32599
2015-02-10 14:09:14,298 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/apache.200.txt:0+32599
2015-02-10 14:09:14,301 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2015-02-10 14:09:14,303 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@21e8bf76
2015-02-10 14:09:14,304 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt
2015-02-10 14:09:14,306 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:14,306 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:14,324 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:14,324 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:14,326 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:14,326 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:14,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt"]
2015-02-10 14:09:14,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-02-10 14:09:14,347 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:14,854 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:14,856 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000001_0 is done. And is in the process of commiting
2015-02-10 14:09:17,303 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/ips.20.txt:0+275
2015-02-10 14:09:17,304 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000001_0' done.
2015-02-10 14:09:17,311 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6f77e5d4
2015-02-10 14:09:17,311 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:17,314 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 2 sorted segments
2015-02-10 14:09:17,322 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 2 segments left of total size: 10047 bytes
2015-02-10 14:09:17,322 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:17,324 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:17,324 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:17,338 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(apache*ip)[by: apache:[{1}:'octet'] ip:[{1}:'rawoctet']]
2015-02-10 14:09:17,338 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcompareforward"]
2015-02-10 14:09:17,343 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 14:09:17,343 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-10 14:09:18,909 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:18,910 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:18,910 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2015-02-10 14:09:18,913 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcompareforward
2015-02-10 14:09:20,311 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:20,312 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_r_000000_0' done.
2015-02-10 14:09:20,323 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/cogroupcompareforward/_temporary
2015-02-10 14:09:20,333 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:20,358 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/cogroupcompareforward
2015-02-10 14:09:20,372 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:20,373 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 14:09:20,395 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:20,395 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 14:09:20,421 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:20,421 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:20,421 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_false"]
2015-02-10 14:09:20,422 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:20,422 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:20,422 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:20,424 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ve/false_null_false_false
2015-02-10 14:09:20,439 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:20,483 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0003
2015-02-10 14:09:20,484 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:20,487 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5235b5e8
2015-02-10 14:09:20,488 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:20,489 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:20,490 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:20,507 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:20,507 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:20,511 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:20,511 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:20,522 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:20,522 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:20,528 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:20,532 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:20,534 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:23,487 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:09:23,489 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2015-02-10 14:09:23,493 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@470ae2bf
2015-02-10 14:09:23,493 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:23,495 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:09:23,495 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:09:23,496 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:23,497 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:23,497 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:23,507 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:23,507 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_false"]
2015-02-10 14:09:23,517 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:23,518 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:23,519 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2015-02-10 14:09:23,522 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_false
2015-02-10 14:09:26,493 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:26,494 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_r_000000_0' done.
2015-02-10 14:09:26,508 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_false/_temporary
2015-02-10 14:09:26,516 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:26,529 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:26,529 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 14:09:26,551 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:26,552 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:26,552 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_false"]
2015-02-10 14:09:26,552 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:26,553 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:26,553 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:26,554 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/true_null_false_false
2015-02-10 14:09:26,569 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:26,595 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0004
2015-02-10 14:09:26,595 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:26,599 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@679b622d
2015-02-10 14:09:26,601 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:26,602 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:26,602 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:26,758 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:26,758 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:26,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:26,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:26,770 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:26,771 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:26,777 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:27,488 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:27,490 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:29,599 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:09:29,600 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2015-02-10 14:09:29,604 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@706a48e4
2015-02-10 14:09:29,604 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:29,606 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:09:29,606 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:09:29,606 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:29,607 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:29,608 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:29,617 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:29,617 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_false"]
2015-02-10 14:09:29,627 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:29,628 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:29,629 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_r_000000_0 is allowed to commit now
2015-02-10 14:09:29,632 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_false
2015-02-10 14:09:32,603 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:32,604 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_r_000000_0' done.
2015-02-10 14:09:32,618 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_false/_temporary
2015-02-10 14:09:32,626 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:32,639 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:32,640 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 14:09:32,662 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:32,662 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:32,662 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_false"]
2015-02-10 14:09:32,663 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:32,663 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:32,663 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:32,664 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_true_false
2015-02-10 14:09:32,679 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:32,704 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0005
2015-02-10 14:09:32,704 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:32,708 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@36d8f5e8
2015-02-10 14:09:32,709 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:32,710 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:32,711 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:32,867 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:32,868 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:32,869 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:32,869 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:32,879 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:32,879 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:32,885 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:32,888 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:32,890 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:35,708 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:09:35,709 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2015-02-10 14:09:35,713 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2f5ca232
2015-02-10 14:09:35,713 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:35,714 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:09:35,715 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:09:35,715 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:35,716 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:35,716 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:35,725 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:35,725 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_false"]
2015-02-10 14:09:35,734 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:35,735 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:35,736 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_r_000000_0 is allowed to commit now
2015-02-10 14:09:35,739 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_false
2015-02-10 14:09:38,713 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:38,714 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_r_000000_0' done.
2015-02-10 14:09:38,727 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_false/_temporary
2015-02-10 14:09:38,735 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:38,747 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:38,748 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 14:09:38,769 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:38,769 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:38,769 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_false"]
2015-02-10 14:09:38,770 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:38,770 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:38,770 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:38,771 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_true_false
2015-02-10 14:09:38,785 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:38,810 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0006
2015-02-10 14:09:38,810 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:38,814 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2babbba1
2015-02-10 14:09:38,815 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:38,816 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:38,816 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:38,834 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:38,834 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:38,836 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:38,836 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:38,845 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:38,845 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:38,852 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:39,554 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:39,556 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:41,814 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:09:41,815 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2015-02-10 14:09:41,819 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@29cc3436
2015-02-10 14:09:41,819 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:41,821 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:09:41,821 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:09:41,822 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:41,823 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:41,823 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:41,831 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:41,831 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_false"]
2015-02-10 14:09:41,841 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:41,842 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:41,842 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_r_000000_0 is allowed to commit now
2015-02-10 14:09:41,845 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_false
2015-02-10 14:09:44,819 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:44,820 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_r_000000_0' done.
2015-02-10 14:09:44,844 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_false/_temporary
2015-02-10 14:09:44,854 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:44,867 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:44,867 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 14:09:44,889 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:44,889 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:44,889 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_false"]
2015-02-10 14:09:44,889 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:44,890 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:44,890 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:44,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...e/false_false_false_false
2015-02-10 14:09:44,905 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:44,930 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0007
2015-02-10 14:09:44,931 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:44,934 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3ba59727
2015-02-10 14:09:44,935 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:44,937 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:44,937 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:44,955 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:44,955 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:44,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:44,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:44,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:44,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:44,973 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:44,977 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:44,980 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:47,935 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:09:47,936 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2015-02-10 14:09:47,941 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1e292edb
2015-02-10 14:09:47,942 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:47,943 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:09:47,944 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:09:47,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:47,947 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:47,947 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:47,956 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:47,957 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_false"]
2015-02-10 14:09:47,967 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:47,968 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:47,969 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_r_000000_0 is allowed to commit now
2015-02-10 14:09:47,973 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_false
2015-02-10 14:09:50,941 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:50,943 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_r_000000_0' done.
2015-02-10 14:09:50,953 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_false/_temporary
2015-02-10 14:09:50,961 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:50,974 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:50,974 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 14:09:50,994 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:50,995 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:50,995 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_false"]
2015-02-10 14:09:50,996 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:50,996 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:50,996 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:50,997 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ve/true_false_false_false
2015-02-10 14:09:51,010 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:51,035 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0008
2015-02-10 14:09:51,036 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:51,040 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@550df8c7
2015-02-10 14:09:51,041 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:51,042 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:51,043 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:51,060 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:51,060 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:51,062 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:51,062 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:51,071 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:51,072 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:51,078 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:52,337 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:52,340 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:54,040 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:09:54,041 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2015-02-10 14:09:54,044 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6ad98e6
2015-02-10 14:09:54,044 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:54,046 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:09:54,047 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:09:54,047 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:54,048 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:09:54,048 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:09:54,056 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:54,056 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_false"]
2015-02-10 14:09:54,066 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:09:54,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:09:54,068 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_r_000000_0 is allowed to commit now
2015-02-10 14:09:54,071 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_false
2015-02-10 14:09:57,044 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:09:57,045 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_r_000000_0' done.
2015-02-10 14:09:57,052 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_false/_temporary
2015-02-10 14:09:57,059 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:57,072 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:09:57,073 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 14:09:57,093 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:09:57,093 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:57,093 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_false"]
2015-02-10 14:09:57,094 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:09:57,094 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:09:57,094 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:09:57,095 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/true_true_false_false
2015-02-10 14:09:57,108 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:09:57,133 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0009
2015-02-10 14:09:57,134 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:09:57,136 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@77026e40
2015-02-10 14:09:57,138 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:09:57,139 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:09:57,139 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:09:57,163 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:09:57,164 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:09:57,171 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:09:57,171 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:09:57,180 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:09:57,180 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:09:57,187 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:09:58,632 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:09:58,634 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:00,137 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:00,138 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000000_0' done.
2015-02-10 14:10:00,143 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@140de537
2015-02-10 14:10:00,143 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:00,145 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:00,145 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:10:00,146 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:00,147 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:00,147 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:00,155 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:00,155 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_false"]
2015-02-10 14:10:00,165 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:00,166 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:00,167 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0009_r_000000_0 is allowed to commit now
2015-02-10 14:10:00,170 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_false
2015-02-10 14:10:03,143 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:03,144 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_r_000000_0' done.
2015-02-10 14:10:03,150 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_false/_temporary
2015-02-10 14:10:03,157 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:03,169 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:03,170 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 14:10:03,188 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:03,188 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:03,189 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_false"]
2015-02-10 14:10:03,189 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:03,190 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:03,191 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:03,192 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ve/false_true_false_false
2015-02-10 14:10:03,205 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:03,227 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0010
2015-02-10 14:10:03,228 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:03,232 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@8ff557a
2015-02-10 14:10:03,234 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:03,235 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:03,235 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:03,254 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:03,254 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:03,256 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:03,256 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:03,266 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:03,266 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:03,273 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:04,026 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:04,028 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:06,232 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:06,233 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0010_m_000000_0' done.
2015-02-10 14:10:06,237 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@49d67b41
2015-02-10 14:10:06,238 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:06,240 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:06,241 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:10:06,241 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:06,243 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:06,243 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:06,251 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:06,252 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_false"]
2015-02-10 14:10:06,262 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0010_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:06,263 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:06,264 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0010_r_000000_0 is allowed to commit now
2015-02-10 14:10:06,267 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0010_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_false
2015-02-10 14:10:09,237 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:09,239 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0010_r_000000_0' done.
2015-02-10 14:10:09,245 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_false/_temporary
2015-02-10 14:10:09,252 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:09,264 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:09,265 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 14:10:09,282 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:09,283 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:09,283 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_false"]
2015-02-10 14:10:09,283 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:09,283 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:09,284 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:09,284 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_true_false
2015-02-10 14:10:09,298 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:09,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0011
2015-02-10 14:10:09,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:09,324 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@38c9aa93
2015-02-10 14:10:09,325 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:09,326 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:09,327 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:09,344 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:09,344 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:09,346 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:09,346 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:09,354 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:09,355 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:09,360 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:09,365 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:09,367 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:12,326 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:12,327 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_m_000000_0' done.
2015-02-10 14:10:12,331 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@38764254
2015-02-10 14:10:12,331 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:12,332 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:12,332 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:10:12,333 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:12,333 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:12,334 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:12,341 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:12,341 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_false"]
2015-02-10 14:10:12,351 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:12,352 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:12,353 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2015-02-10 14:10:12,356 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0011_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_false
2015-02-10 14:10:15,331 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:15,332 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0011_r_000000_0' done.
2015-02-10 14:10:15,342 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_false/_temporary
2015-02-10 14:10:15,350 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:15,362 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:15,362 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 14:10:15,379 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:15,379 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:15,380 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_false"]
2015-02-10 14:10:15,380 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:15,380 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:15,380 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:15,381 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_true_false
2015-02-10 14:10:15,392 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:15,409 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0012
2015-02-10 14:10:15,409 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:15,412 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@11513fd0
2015-02-10 14:10:15,413 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:15,414 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:15,414 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:15,502 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:15,502 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:15,504 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:15,504 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:15,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:15,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:15,521 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:16,659 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:16,661 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:18,412 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:18,413 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_m_000000_0' done.
2015-02-10 14:10:18,416 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1e1c66a
2015-02-10 14:10:18,417 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:18,418 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:18,419 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:10:18,419 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:18,420 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:18,420 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:18,427 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:18,428 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_false"]
2015-02-10 14:10:18,437 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0012_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:18,437 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:18,438 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0012_r_000000_0 is allowed to commit now
2015-02-10 14:10:18,440 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0012_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_false
2015-02-10 14:10:21,417 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:21,417 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0012_r_000000_0' done.
2015-02-10 14:10:21,423 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_false/_temporary
2015-02-10 14:10:21,430 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:21,442 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:21,442 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 14:10:21,459 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:21,459 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:21,459 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_false"]
2015-02-10 14:10:21,460 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:21,460 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:21,460 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:21,462 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_true_false
2015-02-10 14:10:21,473 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:21,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0013
2015-02-10 14:10:21,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:21,494 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@284d0371
2015-02-10 14:10:21,496 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:21,497 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:21,497 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:21,515 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:21,516 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:21,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:21,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:21,526 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:21,527 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:21,533 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:23,010 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:23,012 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:24,494 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:24,495 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_m_000000_0' done.
2015-02-10 14:10:24,498 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@32725f0e
2015-02-10 14:10:24,499 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:24,501 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:24,501 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:10:24,501 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:24,503 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:24,503 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:24,510 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:24,511 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_false"]
2015-02-10 14:10:24,520 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:24,520 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:24,521 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0013_r_000000_0 is allowed to commit now
2015-02-10 14:10:24,524 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_false
2015-02-10 14:10:27,499 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:27,500 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_r_000000_0' done.
2015-02-10 14:10:27,507 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_false/_temporary
2015-02-10 14:10:27,514 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:27,525 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:27,525 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 14:10:27,540 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:27,541 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:27,541 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_false"]
2015-02-10 14:10:27,542 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:27,542 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:27,542 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:27,543 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_true_false
2015-02-10 14:10:27,554 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:27,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0014
2015-02-10 14:10:27,572 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:27,575 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@624c19ae
2015-02-10 14:10:27,577 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:27,578 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:27,579 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:27,668 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:27,669 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:27,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:27,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:27,679 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:27,679 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:27,685 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:28,294 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:28,296 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:30,575 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:30,576 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_m_000000_0' done.
2015-02-10 14:10:30,579 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3af5f6dc
2015-02-10 14:10:30,579 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:30,581 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:30,581 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:10:30,582 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:30,582 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:30,583 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:30,590 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:30,590 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_false"]
2015-02-10 14:10:30,599 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:30,600 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:30,600 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0014_r_000000_0 is allowed to commit now
2015-02-10 14:10:30,611 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_false
2015-02-10 14:10:33,579 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:33,580 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_r_000000_0' done.
2015-02-10 14:10:33,593 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_false/_temporary
2015-02-10 14:10:33,600 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:33,610 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:33,611 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 14:10:33,625 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:33,626 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:33,626 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_true"]
2015-02-10 14:10:33,626 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:33,627 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:33,627 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:33,629 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/false_null_false_true
2015-02-10 14:10:33,639 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:33,656 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0015
2015-02-10 14:10:33,656 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:33,659 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3d601539
2015-02-10 14:10:33,660 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:33,661 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:33,662 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:33,747 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:33,747 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:33,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:33,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:33,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:33,758 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:33,763 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:33,766 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:33,767 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:36,660 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:36,660 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_m_000000_0' done.
2015-02-10 14:10:36,664 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@641ef158
2015-02-10 14:10:36,664 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:36,665 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:36,665 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:10:36,665 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:36,666 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:36,666 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:36,673 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:36,674 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_true"]
2015-02-10 14:10:36,683 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:36,684 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:36,684 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0015_r_000000_0 is allowed to commit now
2015-02-10 14:10:36,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/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_true
2015-02-10 14:10:39,664 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:39,665 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_r_000000_0' done.
2015-02-10 14:10:39,671 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_false_true/_temporary
2015-02-10 14:10:39,678 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:39,687 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:39,688 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 14:10:39,703 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:39,703 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:39,703 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_true"]
2015-02-10 14:10:39,704 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:39,704 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:39,704 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:39,705 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/true_null_false_true
2015-02-10 14:10:39,716 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:39,732 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0016
2015-02-10 14:10:39,732 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:39,735 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@42eab1f2
2015-02-10 14:10:39,736 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:39,737 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:39,738 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:39,755 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:39,755 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:39,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:39,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:39,765 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:39,765 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:39,773 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:39,775 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:39,777 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0016_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:42,736 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:42,737 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0016_m_000000_0' done.
2015-02-10 14:10:42,740 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1b4c7c5d
2015-02-10 14:10:42,741 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:42,743 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:42,743 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:10:42,744 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:42,746 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:42,746 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:42,753 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:42,753 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_true"]
2015-02-10 14:10:42,762 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0016_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:42,763 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:42,763 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0016_r_000000_0 is allowed to commit now
2015-02-10 14:10:42,766 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0016_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_true
2015-02-10 14:10:45,741 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:45,741 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0016_r_000000_0' done.
2015-02-10 14:10:45,754 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_false_true/_temporary
2015-02-10 14:10:45,760 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:45,770 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:45,770 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 14:10:45,784 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:45,784 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:45,784 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_true"]
2015-02-10 14:10:45,786 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:45,787 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:45,787 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:45,788 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/false_null_true_true
2015-02-10 14:10:45,799 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:45,815 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0017
2015-02-10 14:10:45,815 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:45,819 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3b005abc
2015-02-10 14:10:45,820 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:45,821 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:45,821 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:45,906 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:45,906 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:45,908 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:45,908 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:45,916 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:45,917 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:45,922 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:45,925 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:45,926 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0017_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:48,819 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:48,820 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0017_m_000000_0' done.
2015-02-10 14:10:48,823 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@60ebf00e
2015-02-10 14:10:48,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:48,824 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:48,824 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:10:48,825 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:48,825 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:48,825 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:48,832 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:48,832 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_true"]
2015-02-10 14:10:48,841 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0017_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:48,842 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:48,843 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0017_r_000000_0 is allowed to commit now
2015-02-10 14:10:48,845 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0017_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_true
2015-02-10 14:10:51,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:51,824 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0017_r_000000_0' done.
2015-02-10 14:10:51,835 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_null_true_true/_temporary
2015-02-10 14:10:51,842 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:51,852 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:51,852 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 14:10:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_true"]
2015-02-10 14:10:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:51,867 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:51,867 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:51,867 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...nsive/true_null_true_true
2015-02-10 14:10:51,878 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:51,894 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0018
2015-02-10 14:10:51,894 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:51,898 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@15d95643
2015-02-10 14:10:51,899 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:51,900 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:51,900 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:51,918 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:51,918 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:51,919 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:51,920 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:51,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:51,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:51,933 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:51,937 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:51,940 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0018_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:54,898 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:10:54,900 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0018_m_000000_0' done.
2015-02-10 14:10:54,903 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b553d28
2015-02-10 14:10:54,904 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:54,906 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:10:54,906 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 705 bytes
2015-02-10 14:10:54,907 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:54,908 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:10:54,909 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:10:54,916 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:54,916 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_true"]
2015-02-10 14:10:54,925 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0018_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:10:54,926 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:10:54,927 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0018_r_000000_0 is allowed to commit now
2015-02-10 14:10:54,929 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0018_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_true
2015-02-10 14:10:57,903 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:10:57,905 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0018_r_000000_0' done.
2015-02-10 14:10:57,912 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_null_true_true/_temporary
2015-02-10 14:10:57,919 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:57,929 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:10:57,929 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 14:10:57,942 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:10:57,942 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:57,943 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_true"]
2015-02-10 14:10:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:10:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:10:57,944 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:10:57,945 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ve/false_false_false_true
2015-02-10 14:10:57,955 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:10:57,971 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0019
2015-02-10 14:10:57,971 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:10:57,974 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@24e6d224
2015-02-10 14:10:57,976 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:10:57,977 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:10:57,977 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:10:58,063 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:10:58,063 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:10:58,064 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:10:58,064 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:10:58,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:10:58,074 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:10:58,079 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:10:58,084 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:10:58,085 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0019_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:00,975 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:00,975 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0019_m_000000_0' done.
2015-02-10 14:11:00,979 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@760663ec
2015-02-10 14:11:00,979 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:00,980 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:00,980 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:00,980 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:00,981 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:00,981 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:00,988 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:00,988 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_true"]
2015-02-10 14:11:00,996 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0019_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:00,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:00,997 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0019_r_000000_0 is allowed to commit now
2015-02-10 14:11:01,000 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0019_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_true
2015-02-10 14:11:03,979 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:03,980 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0019_r_000000_0' done.
2015-02-10 14:11:03,991 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_false_true/_temporary
2015-02-10 14:11:03,997 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:04,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:04,008 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 14:11:04,021 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:04,021 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:04,021 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_true"]
2015-02-10 14:11:04,022 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:04,022 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:04,023 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:04,023 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/true_false_false_true
2015-02-10 14:11:04,035 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:04,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0020
2015-02-10 14:11:04,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:04,055 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@31d70d74
2015-02-10 14:11:04,057 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:04,058 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:04,059 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:04,076 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:04,077 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:04,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:04,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:04,087 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:04,088 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:04,093 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:04,098 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:04,100 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0020_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:07,056 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:07,057 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0020_m_000000_0' done.
2015-02-10 14:11:07,061 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@b2eddc0
2015-02-10 14:11:07,062 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:07,064 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:07,064 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:07,065 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:07,067 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:07,067 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:07,074 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:07,075 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_true"]
2015-02-10 14:11:07,083 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0020_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:07,084 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:07,085 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0020_r_000000_0 is allowed to commit now
2015-02-10 14:11:07,087 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0020_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_true
2015-02-10 14:11:10,061 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:10,063 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0020_r_000000_0' done.
2015-02-10 14:11:10,071 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_false_true/_temporary
2015-02-10 14:11:10,077 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:10,086 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:10,087 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 14:11:10,099 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:10,100 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:10,100 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_true"]
2015-02-10 14:11:10,100 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:10,100 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:10,100 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:10,101 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/true_true_false_true
2015-02-10 14:11:10,113 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:10,129 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0021
2015-02-10 14:11:10,129 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:10,133 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6d09a8df
2015-02-10 14:11:10,134 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:10,135 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:10,136 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:10,156 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:10,157 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:10,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:10,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:10,170 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:10,170 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:10,177 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:10,181 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:10,183 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0021_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:13,133 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:13,135 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0021_m_000000_0' done.
2015-02-10 14:11:13,139 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@69e295f8
2015-02-10 14:11:13,139 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:13,141 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:13,142 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:13,142 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:13,144 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:13,144 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:13,151 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:13,151 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_true"]
2015-02-10 14:11:13,160 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0021_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:13,161 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:13,162 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0021_r_000000_0 is allowed to commit now
2015-02-10 14:11:13,164 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0021_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_true
2015-02-10 14:11:16,139 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:16,140 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0021_r_000000_0' done.
2015-02-10 14:11:16,153 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_false_true/_temporary
2015-02-10 14:11:16,159 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:16,169 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:16,169 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 14:11:16,181 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_true"]
2015-02-10 14:11:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:16,182 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:16,183 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/false_true_false_true
2015-02-10 14:11:16,194 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:16,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0022
2015-02-10 14:11:16,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:16,214 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@64134af1
2015-02-10 14:11:16,215 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:16,216 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:16,216 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:16,233 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:16,234 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:16,235 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:16,235 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:16,243 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:16,243 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:16,248 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:16,252 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:16,254 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0022_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:19,214 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:19,216 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0022_m_000000_0' done.
2015-02-10 14:11:19,219 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4d1b6341
2015-02-10 14:11:19,219 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:19,222 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:19,222 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:19,222 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:19,224 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:19,224 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:19,231 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:19,231 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_true"]
2015-02-10 14:11:19,239 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0022_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:19,239 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:19,240 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0022_r_000000_0 is allowed to commit now
2015-02-10 14:11:19,242 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0022_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_true
2015-02-10 14:11:22,219 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:22,220 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0022_r_000000_0' done.
2015-02-10 14:11:22,225 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_false_true/_temporary
2015-02-10 14:11:22,232 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:22,241 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:22,241 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 14:11:22,253 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:22,254 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:22,254 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_true"]
2015-02-10 14:11:22,254 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:22,254 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:22,254 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:22,255 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...ive/false_false_true_true
2015-02-10 14:11:22,265 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:22,281 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0023
2015-02-10 14:11:22,282 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:22,284 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1b609803
2015-02-10 14:11:22,285 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:22,286 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:22,287 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:22,318 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:22,319 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:22,320 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:22,320 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:22,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:22,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:22,332 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:22,336 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:22,337 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0023_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:25,285 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:25,286 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0023_m_000000_0' done.
2015-02-10 14:11:25,290 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5986f987
2015-02-10 14:11:25,290 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:25,291 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:25,292 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:25,292 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:25,293 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:25,293 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:25,300 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:25,300 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_true"]
2015-02-10 14:11:25,308 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0023_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:25,309 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:25,309 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0023_r_000000_0 is allowed to commit now
2015-02-10 14:11:25,311 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0023_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_true
2015-02-10 14:11:28,290 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:28,291 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0023_r_000000_0' done.
2015-02-10 14:11:28,297 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_false_true_true/_temporary
2015-02-10 14:11:28,303 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:28,312 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:28,312 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 14:11:28,324 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:28,324 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:28,324 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_true"]
2015-02-10 14:11:28,325 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:28,325 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:28,325 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:28,325 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/true_false_true_true
2015-02-10 14:11:28,335 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:28,351 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0024
2015-02-10 14:11:28,352 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:28,354 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@74e551a4
2015-02-10 14:11:28,355 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:28,356 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:28,356 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:28,374 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:28,374 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:28,376 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:28,376 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:28,383 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:28,383 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:28,388 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:28,393 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:28,394 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0024_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:31,355 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:31,356 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0024_m_000000_0' done.
2015-02-10 14:11:31,359 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7aaf1eb7
2015-02-10 14:11:31,359 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:31,361 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:31,362 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:31,362 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:31,364 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:31,364 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:31,370 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:31,371 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_true"]
2015-02-10 14:11:31,378 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0024_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:31,379 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:31,380 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0024_r_000000_0 is allowed to commit now
2015-02-10 14:11:31,382 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0024_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_true
2015-02-10 14:11:34,359 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:34,360 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0024_r_000000_0' done.
2015-02-10 14:11:34,372 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_false_true_true/_temporary
2015-02-10 14:11:34,378 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:34,387 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:34,387 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 14:11:34,399 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:34,399 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:34,399 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_true"]
2015-02-10 14:11:34,400 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:34,401 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:34,401 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:34,402 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...nsive/true_true_true_true
2015-02-10 14:11:34,412 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:34,428 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0025
2015-02-10 14:11:34,428 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:34,430 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@738a2a09
2015-02-10 14:11:34,431 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:34,432 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:34,433 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:34,453 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:34,453 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:34,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:34,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:34,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:34,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:34,469 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:34,473 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:34,475 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0025_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:37,431 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:37,432 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0025_m_000000_0' done.
2015-02-10 14:11:37,435 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@70751932
2015-02-10 14:11:37,435 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:37,437 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:37,437 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:37,438 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:37,439 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:37,439 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:37,445 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:37,445 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_true"]
2015-02-10 14:11:37,453 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0025_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:37,454 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:37,454 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0025_r_000000_0 is allowed to commit now
2015-02-10 14:11:37,457 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0025_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_true
2015-02-10 14:11:40,435 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:40,436 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0025_r_000000_0' done.
2015-02-10 14:11:40,441 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/true_true_true_true/_temporary
2015-02-10 14:11:40,447 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:40,456 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 14:11:40,457 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 14:11:40,468 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort] starting
2015-02-10 14:11:40,468 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:40,469 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  sink: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_true"]
2015-02-10 14:11:40,470 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  parallel execution is enabled: false
2015-02-10 14:11:40,470 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  starting jobs: 1
2015-02-10 14:11:40,471 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [comprehensivesort]  allocating threads: 1
2015-02-10 14:11:40,472 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] starting step: (1/1) ...sive/false_true_true_true
2015-02-10 14:11:40,482 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:40,497 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] submitted hadoop job: job_local_0026
2015-02-10 14:11:40,498 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [comprehensivesort] tracking url: http://localhost:8080/
2015-02-10 14:11:40,501 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@46d0cc3a
2015-02-10 14:11:40,502 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt
2015-02-10 14:11:40,503 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 1
2015-02-10 14:11:40,504 INFO  mapred.MapTask (MapTask.java:<init>(944)) - io.sort.mb = 100
2015-02-10 14:11:40,522 INFO  mapred.MapTask (MapTask.java:<init>(956)) - data buffer = 79691776/99614720
2015-02-10 14:11:40,522 INFO  mapred.MapTask (MapTask.java:<init>(957)) - record buffer = 262144/327680
2015-02-10 14:11:40,524 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 14:11:40,524 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 14:11:40,531 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt"]
2015-02-10 14:11:40,532 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:40,537 INFO  mapred.MapTask (MapTask.java:flush(1284)) - Starting flush of map output
2015-02-10 14:11:40,542 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1466)) - Finished spill 0
2015-02-10 14:11:40,543 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0026_m_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:43,501 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/classes/test/data/lhs+rhs-cross.txt:0+221
2015-02-10 14:11:43,503 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0026_m_000000_0' done.
2015-02-10 14:11:43,506 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@49017892
2015-02-10 14:11:43,507 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:43,509 INFO  mapred.Merger (Merger.java:merge(390)) - Merging 1 sorted segments
2015-02-10 14:11:43,509 INFO  mapred.Merger (Merger.java:merge(473)) - Down to the last merge-pass, with 1 segments left of total size: 964 bytes
2015-02-10 14:11:43,510 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:43,511 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.6.3
2015-02-10 14:11:43,511 INFO  hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-02-10 14:11:43,517 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(comprehensivesort)[by:[{1}:'num']]
2015-02-10 14:11:43,518 INFO  hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->['num', 'lower', 'upper']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_true"]
2015-02-10 14:11:43,525 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0026_r_000000_0 is done. And is in the process of commiting
2015-02-10 14:11:43,526 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 14:11:43,527 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0026_r_000000_0 is allowed to commit now
2015-02-10 14:11:43,529 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0026_r_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_true
2015-02-10 14:11:46,506 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2015-02-10 14:11:46,507 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0026_r_000000_0' done.
2015-02-10 14:11:46,517 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output/hadoop/sortedvaluesplatform/comprehensive/false_true_true_true/_temporary
2015-02-10 14:11:46,523 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 14:11:46,526 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_true_true_false
2015-02-10 14:11:46,526 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_null_false_true
2015-02-10 14:11:46,526 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_false_true_true
2015-02-10 14:11:46,526 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_null_false_true
2015-02-10 14:11:46,526 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_null_true_true
2015-02-10 14:11:46,527 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_true_false_false
2015-02-10 14:11:46,527 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_true_true_true
2015-02-10 14:11:46,527 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_true_false_true
2015-02-10 14:11:46,527 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_false_false_true
2015-02-10 14:11:46,528 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_false_false_true
2015-02-10 14:11:46,528 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_true_true_false
2015-02-10 14:11:46,528 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_true_false_false
2015-02-10 14:11:46,528 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_true_true_true
2015-02-10 14:11:46,528 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_null_false_false
2015-02-10 14:11:46,529 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_false_true_false
2015-02-10 14:11:46,529 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_false_false_false
2015-02-10 14:11:46,529 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_false_true_true
2015-02-10 14:11:46,529 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_null_true_true
2015-02-10 14:11:46,529 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_null_true_false
2015-02-10 14:11:46,530 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_false_true_false
2015-02-10 14:11:46,530 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_true_false_true
2015-02-10 14:11:46,530 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/false_null_true_false
2015-02-10 14:11:46,530 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_null_false_false
2015-02-10 14:11:46,530 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.0.x/build/test/output//hadoop/sortedvaluesplatform/comprehensive/true_false_false_false