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 2007/01/31 20:02:56 UTC
svn commit: r501946 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/TaskTracker.java
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());
}
}