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/26 22:32:20 UTC

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

Author: cutting
Date: Thu Oct 26 13:32:20 2006
New Revision: 468120

URL: http://svn.apache.org/viewvc?view=rev&rev=468120
Log:
HADOOP-638.  Fix an unsynchronized access to TaskTracker's internal state.  Contributed by Nigel.

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=468120&r1=468119&r2=468120
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Oct 26 13:32:20 2006
@@ -69,6 +69,9 @@
 18. HADOOP-642.  Change IPC client to specify an explicit connect
     timeout.  (Konstantin Shvachko via cutting)
 
+19. HADOOP-638.  Fix an unsynchronized access to TaskTracker's
+    internal state.  (Nigel Daley via cutting)
+
 
 Release 0.7.2 - 2006-10-18
 

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=468120&r1=468119&r2=468120
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java Thu Oct 26 13:32:20 2006
@@ -446,7 +446,7 @@
             killOverflowingTasks();
             
             //we've cleaned up, resume normal operation
-            if (!acceptNewTasks && tasks.isEmpty()) {
+            if (!acceptNewTasks && isIdle()) {
                 acceptNewTasks=true;
             }
           } catch (InterruptedException ie) {