hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject svn commit: r658994 - in /hadoop/core/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/JobTracker.java
Date Thu, 22 May 2008 04:06:20 GMT
Author: ddas
Date: Wed May 21 21:06:19 2008
New Revision: 658994

URL: http://svn.apache.org/viewvc?rev=658994&view=rev
Log:
HADOOP-3403. Fixes a problem in the JobTracker to do with handling of lost tasktrackers. Contributed
by Arun Murthy.

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

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=658994&r1=658993&r2=658994&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Wed May 21 21:06:19 2008
@@ -308,6 +308,9 @@
     accommodate collectors that don't support long values. (lohit vijayarenu
     via cdouglas)
 
+    HADOOP-3403. Fixes a problem in the JobTracker to do with handling of lost
+    tasktrackers. (Arun Murthy via ddas)
+
 Release 0.17.0 - 2008-05-18
 
   INCOMPATIBLE CHANGES

Modified: hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java?rev=658994&r1=658993&r2=658994&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java (original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java Wed May 21 21:06:19
2008
@@ -296,9 +296,9 @@
                   // tracker has already been destroyed.
                   if (newProfile != null) {
                     if (now - newProfile.getLastSeen() > TASKTRACKER_EXPIRY_INTERVAL)
{
-                      // Remove completely
-                      updateTaskTrackerStatus(trackerName, null);
+                      // Remove completely after marking the tasks as 'KILLED'
                       lostTaskTracker(leastRecent.getTrackerName());
+                      updateTaskTrackerStatus(trackerName, null);
                     } else {
                       // Update time by inserting latest profile
                       trackerExpiryQueue.add(newProfile);



Mime
View raw message