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/24 23:53:08 UTC

svn commit: r467502 - in /lucene/hadoop/trunk: CHANGES.txt src/test/org/apache/hadoop/mapred/MiniMRCluster.java

Author: cutting
Date: Tue Oct 24 14:53:08 2006
New Revision: 467502

URL: http://svn.apache.org/viewvc?view=rev&rev=467502
Log:
HADOOP-627.  Fix some synchronization problems in MiniMRCluster.  Contributed by Nigel.

Modified:
    lucene/hadoop/trunk/CHANGES.txt
    lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MiniMRCluster.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=467502&r1=467501&r2=467502
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue Oct 24 14:53:08 2006
@@ -47,6 +47,9 @@
 13. HADOOP-634.  Add missing license to many files.
     (Nigel Daley via cutting)
 
+14. HADOOP-627.  Fix some synchronization problems in MiniMRCluster
+    that sometimes caused unit tests to fail.  (Nigel Daley via cutting)
+
 
 Release 0.7.2 - 2006-10-18
 

Modified: lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MiniMRCluster.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MiniMRCluster.java?view=diff&rev=467502&r1=467501&r2=467502
==============================================================================
--- lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MiniMRCluster.java (original)
+++ lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MiniMRCluster.java Tue Oct 24 14:53:08 2006
@@ -78,11 +78,11 @@
      * An inner class to run the task tracker.
      */
     class TaskTrackerRunner implements Runnable {
-        TaskTracker tt;
+        volatile TaskTracker tt;
         // the localDirs for this taskTracker
         String[] localDir;
-        boolean isInitialized = false;
-        boolean isDead = false;
+        volatile boolean isInitialized = false;
+        volatile boolean isDead = false;
         int numDir;       
         TaskTrackerRunner(int numDir) {
           this.numDir = numDir;