Author: cutting
Date: Mon Jun  5 12:59:29 2006
New Revision: 411901

URL: http://svn.apache.org/viewvc?rev=411901&view=rev
Log:
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.

Modified:
    lucene/hadoop/trunk/CHANGES.txt
    lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=411901&r1=411900&r2=411901&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Mon Jun  5 12:59:29 2006
@@ -9,6 +9,10 @@
  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
 

Modified: 
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java?rev=411901&r1=411900&r2=411901&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java 
(original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java 
Mon Jun  5 12:59:29 2006
@@ -419,6 +419,7 @@
       // new, just wait for a bit
       try {
         if (numInFlight == 0 && numScheduled == 0) {
+          getTask().reportProgress(getTracker());
           Thread.sleep(5000);
         }
       } catch (InterruptedException e) { } // IGNORE


Reply via email to