svn commit: r409265 - in /lucene/hadoop/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/Task.java

[cu...@apache.org]

Author: cutting
Date: Wed May 24 16:17:22 2006
New Revision: 409265

URL: http://svn.apache.org/viewvc?rev=409265&view=rev
Log:
HADOOP-251.  Make tasks processes tolerant of failed progress reports to their parent process.  Contributed by Owen.

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

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=409265&r1=409264&r2=409265&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Wed May 24 16:17:22 2006
@@ -62,6 +62,9 @@
     reduce nodes by performing multiple transfers in parallel, each on
     a separate socket.  (Sameer Paranjpye via cutting)
 
+17. HADOOP-251.  Fix task processes to be tolerant of failed progress
+    reports to their parent process.  (omalley via cutting)
+
 
 Release 0.2.1 - 2006-05-12
 

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/Task.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/Task.java?rev=409265&r1=409264&r2=409265&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/Task.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/Task.java Wed May 24 16:17:22 2006
@@ -21,9 +21,13 @@
 import org.apache.hadoop.util.*;
 
 import java.io.*;
+import java.util.logging.Logger;
 
 /** Base class for tasks. */
 abstract class Task implements Writable, Configurable {
+  private static final Logger LOG =
+    LogFormatter.getLogger("org.apache.hadoop.mapred.TaskRunner");
+
   ////////////////////////////////////////////
   // Fields
   ////////////////////////////////////////////
@@ -101,15 +105,18 @@
     reportProgress(umbilical);
   }
 
-  public void reportProgress(TaskUmbilicalProtocol umbilical)
-    throws IOException {
+  public void reportProgress(TaskUmbilicalProtocol umbilical) {
     long now = System.currentTimeMillis();
     if (now > nextProgressTime)  {
       synchronized (this) {
         nextProgressTime = now + PROGRESS_INTERVAL;
         float progress = taskProgress.get();
         String status = taskProgress.toString();
-        umbilical.progress(getTaskId(), progress, status);
+        try {
+          umbilical.progress(getTaskId(), progress, status);
+        } catch (IOException ie) {
+          LOG.warning(StringUtils.stringifyException(ie));
+        }
       }
     }
   }