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

[ddas]

Author: ddas
Date: Thu Aug 14 05:54:58 2008
New Revision: 685875

URL: http://svn.apache.org/viewvc?rev=685875&view=rev
Log:
HADOOP-3947. Fix a problem in tasktracker reinitialization. Contributed by 
Amareshwari Sriramadasu.

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

Modified: hadoop/core/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=685875&r1=685874&r2=685875&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Thu Aug 14 05:54:58 2008
@@ -1097,6 +1097,9 @@
     HADOOP-3901. Fix bin/hadoop to correctly set classpath under cygwin.
     (Tsz Wo (Nicholas) Sze via omalley)
 
+    HADOOP-3947. Fix a problem in tasktracker reinitialization. 
+    (Amareshwari Sriramadasu via ddas)
+
 Release 0.17.2 - 2008-08-11
 
   BUG FIXES

Modified: hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java?rev=685875&r1=685874&r2=685875&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java 
(original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTracker.java Thu 
Aug 14 05:54:58 2008
@@ -424,6 +424,7 @@
                              "Map-events fetcher for all reduce tasks " + "on 
" + 
                              taskTrackerName);
     mapEventsFetcher.start();
+    this.running = true;
   }
   
   public static Class<? extends TaskTrackerInstrumentation> 
getInstrumentationClass(Configuration conf) {
@@ -1365,7 +1366,6 @@
   public void run() {
     try {
       startCleanupThreads();
-      this.running = true;
       boolean denied = false;
       while (running && !shuttingDown && !denied) {
         boolean staleState = false;