You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cu...@apache.org on 2006/06/05 21:59:29 UTC
svn commit: r411901 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/ReduceTaskRunner.java
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