svn commit: r694476 - in /hadoop/core/trunk: CHANGES.txt src/hdfs/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java

[hairong]

Author: hairong
Date: Thu Sep 11 13:59:07 2008
New Revision: 694476

URL: http://svn.apache.org/viewvc?rev=694476&view=rev
Log:
HADOOP-4071. FSNameSystem.isReplicationInProgress should add an underReplicated 
block to the neededReplication queue using method add not update. Contributed 
by Hairong Kuang.

Modified:
    hadoop/core/trunk/CHANGES.txt
    
hadoop/core/trunk/src/hdfs/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=694476&r1=694475&r2=694476&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Thu Sep 11 13:59:07 2008
@@ -519,6 +519,10 @@
     HADOOP-4054. Remove duplicate lease removal during edit log loading.
     (hairong)
 
+    HADOOP-4071. FSNameSystem.isReplicationInProgress should add an
+    underReplicated block to the neededReplication queue using method 
+    "add" not "update". (hairong)
+
 Release 0.18.1 - Unreleased
 
   IMPROVEMENTS

Modified: 
hadoop/core/trunk/src/hdfs/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/hdfs/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java?rev=694476&r1=694475&r2=694476&view=diff
==============================================================================
--- 
hadoop/core/trunk/src/hdfs/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
 (original)
+++ 
hadoop/core/trunk/src/hdfs/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
 Thu Sep 11 13:59:07 2008
@@ -3506,11 +3506,10 @@
             // after the startDecommission method has been executed. These
             // blocks were in flight when the decommission was started.
             //
-            neededReplications.update(block, 
-                                      curReplicas,
-                                      num.decommissionedReplicas(),
-                                      curExpectedReplicas,
-                                      -1, 0);
+            neededReplications.add(block, 
+                                   curReplicas,
+                                   num.decommissionedReplicas(),
+                                   curExpectedReplicas);
           }
         }
       }