HADOOP-262. Fix reduce tasks to report progress while they're waiting for map outputs so that they do not time out. Contributed by Mahadev.

git-svn-id: https://svn.apache.org/repos/asf/lucene/hadoop/trunk@411901 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -9,6 +9,10 @@ Trunk (unreleased changes)
  2. HADOOP-274.  Change applications to log to standard output rather
     than to a rolling log file like daemons.  (omalley via cutting)
 
+ 3. HADOOP-262.  Fix reduce tasks to report progress while they're
+    waiting for map outputs, so that they do not time out.
+    (Mahadev Konar via cutting)
+
 
 Release 0.3.0 - 2006-06-02
 

src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java

@@ -419,6 +419,7 @@ class ReduceTaskRunner extends TaskRunner {
       // new, just wait for a bit
       try {
         if (numInFlight == 0 && numScheduled == 0) {
+          getTask().reportProgress(getTracker());
           Thread.sleep(5000);
         }
       } catch (InterruptedException e) { } // IGNORE