Author: cutting
Date: Tue Jul 26 14:28:00 2005
New Revision: 225402
URL: http://svn.apache.org/viewcvs?rev=225402&view=rev
Log:
Improved fix so that child will never spam parent with progress reports.
Modified:
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/MapTask.java
Modified:
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/MapTask.java
URL:
http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/MapTask.java?rev=225402&r1=225401&r2=225402&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/MapTask.java
(original)
+++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/MapTask.java
Tue Jul 26 14:28:00 2005
@@ -99,8 +99,7 @@
float progress = // compute progress
(float)Math.min((rawIn.getPos()-split.getStart())/end, 1.0f);
- if ((progress - lastProgress) > 0.01f ||
- progress >= (1.0f - 0.01f)) { // 100 progress reports
+ if ((progress - lastProgress) > 0.01f) { // 100 progress reports
umbilical.progress(getTaskId(), new FloatWritable(progress));
lastProgress = progress;
}
@@ -120,6 +119,8 @@
if (combining) { // flush combiner
((CombiningCollector)collector).flush();
}
+
+ umbilical.progress(getTaskId(), new FloatWritable(1.0f)); // done
} finally {
in.close(); // close input
