Преглед изворни кода

HADOOP-782. Fully remove killed tasks. Contributed by Arun.

git-svn-id: https://svn.apache.org/repos/asf/lucene/hadoop/trunk@486342 13f79535-47bb-0310-9956-ffa450edef68
Doug Cutting пре 18 година
родитељ
комит
40ce05e521
2 измењених фајлова са 4 додато и 2 уклоњено
  1. 2 0
      CHANGES.txt
  2. 2 2
      src/java/org/apache/hadoop/mapred/TaskTracker.java

+ 2 - 0
CHANGES.txt

@@ -66,6 +66,8 @@ Trunk (unreleased changes)
 19. HADOOP-618.  Make JobSubmissionProtocol public.
 19. HADOOP-618.  Make JobSubmissionProtocol public.
     (Arun C Murthy via cutting)
     (Arun C Murthy via cutting)
 
 
+20. HADOOP-782.  Fully remove killed tasks.  (Arun C Murthy via cutting)
+
 
 
 Release 0.9.1 - 2006-12-06
 Release 0.9.1 - 2006-12-06
 
 

+ 2 - 2
src/java/org/apache/hadoop/mapred/TaskTracker.java

@@ -621,7 +621,7 @@ public class TaskTracker
                 LOG.info(tip.getTask().getTaskId() + ": " + msg);
                 LOG.info(tip.getTask().getTaskId() + ": " + msg);
                 ReflectionUtils.logThreadInfo(LOG, "lost task", 30);
                 ReflectionUtils.logThreadInfo(LOG, "lost task", 30);
                 tip.reportDiagnosticInfo(msg);
                 tip.reportDiagnosticInfo(msg);
-                tasksToCleanup.put(tip);
+                purgeTask(tip, false);
             }
             }
         }
         }
     }
     }
@@ -718,7 +718,7 @@ public class TaskTracker
                          " Killing task.";
                          " Killing task.";
             LOG.info(killMe.getTask().getTaskId() + ": " + msg);
             LOG.info(killMe.getTask().getTaskId() + ": " + msg);
             killMe.reportDiagnosticInfo(msg);
             killMe.reportDiagnosticInfo(msg);
-            tasksToCleanup.put(killMe);
+            purgeTask(killMe, false);
           }
           }
         }
         }
       }
       }