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/12/12 22:50:15 UTC

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

Author: cutting
Date: Tue Dec 12 13:50:14 2006
New Revision: 486342

URL: http://svn.apache.org/viewvc?view=rev&rev=486342
Log:
HADOOP-782.  Fully remove killed tasks.  Contributed by Arun.

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=486342&r1=486341&r2=486342
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue Dec 12 13:50:14 2006
@@ -66,6 +66,8 @@
 19. HADOOP-618.  Make JobSubmissionProtocol public.
     (Arun C Murthy via cutting)
 
+20. HADOOP-782.  Fully remove killed tasks.  (Arun C Murthy via cutting)
+
 
 Release 0.9.1 - 2006-12-06
 

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=486342&r1=486341&r2=486342
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java Tue Dec 12 13:50:14 2006
@@ -621,7 +621,7 @@
                 LOG.info(tip.getTask().getTaskId() + ": " + msg);
                 ReflectionUtils.logThreadInfo(LOG, "lost task", 30);
                 tip.reportDiagnosticInfo(msg);
-                tasksToCleanup.put(tip);
+                purgeTask(tip, false);
             }
         }
     }
@@ -718,7 +718,7 @@
                          " Killing task.";
             LOG.info(killMe.getTask().getTaskId() + ": " + msg);
             killMe.reportDiagnosticInfo(msg);
-            tasksToCleanup.put(killMe);
+            purgeTask(killMe, false);
           }
         }
       }