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;