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