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