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/10/05 23:31:49 UTC

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

Author: cutting
Date: Thu Oct  5 14:31:48 2006
New Revision: 453392

URL: http://svn.apache.org/viewvc?view=rev&rev=453392
Log:
HADOOP-506.  Ignore heartbeats from stale tasktrackers.  Contributed by Sanjay.

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

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=453392&r1=453391&r2=453392
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Oct  5 14:31:48 2006
@@ -139,6 +139,9 @@
     job statistics are not lost after 24 hours and/or when the
     jobtracker is restarted.  (Sanjay Dahiya via cutting)
 
+34. HADOOP-506.  Ignore heartbeats from stale task trackers.
+   (Sanjay Dahiya via cutting)
+
 
 Release 0.6.2 - 2006-09-18
 

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java?view=diff&rev=453392&r1=453391&r2=453392
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java Thu Oct  5 14:31:48 2006
@@ -751,6 +751,8 @@
                 } else {
                     // If not first contact, there should be some record of the tracker
                     if (!seenBefore) {
+                        LOG.warn("Status from unknown Tracker : " + trackerName);
+                        taskTrackers.remove(trackerName); 
                         return InterTrackerProtocol.UNKNOWN_TASKTRACKER;
                     }
                 }