hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cutt...@apache.org
Subject svn commit: r501946 - in /lucene/hadoop/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/TaskTracker.java
Date Wed, 31 Jan 2007 19:02:56 GMT
Author: cutting
Date: Wed Jan 31 11:02:55 2007
New Revision: 501946

URL: http://svn.apache.org/viewvc?view=rev&rev=501946
Log:
HADOOP-934.  Fix TaskTracker to catch metrics exceptions that were causing heartbeats to fail.

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

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=501946&r1=501945&r2=501946
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Wed Jan 31 11:02:55 2007
@@ -108,6 +108,9 @@
 33. HADOOP-959.  Fix namenode snapshot code added in HADOOP-227 to
     work on Windows.  (Dhruba Borthakur via cutting)
 
+34. HADOOP-934.  Fix TaskTracker to catch metrics exceptions that were
+    causing heartbeats to fail.  (Arun Murthy via cutting)
+
 
 Release 0.10.1 - 2007-01-10
 

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java?view=diff&rev=501946&r1=501945&r2=501946
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java Wed Jan 31 11:02:55
2007
@@ -22,6 +22,7 @@
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.ipc.*;
 import org.apache.hadoop.metrics.Metrics;
+import org.apache.hadoop.metrics.MetricsException;
 import org.apache.hadoop.util.*;
 import org.apache.hadoop.util.DiskChecker.DiskErrorException;
 
@@ -601,7 +602,11 @@
             } else {
               reduceTotal--;
             }
-            myMetrics.completeTask();
+            try {
+              myMetrics.completeTask();
+            } catch (MetricsException me) {
+              LOG.warn("Caught: " + StringUtils.stringifyException(me));
+            }
             runningTasks.remove(taskStatus.getTaskId());
           }
         }



Mime
View raw message