svn commit: r1072032 - in /hadoop/mapreduce/trunk: CHANGES.txt src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java

[szetszwo]

Author: szetszwo
Date: Fri Feb 18 15:58:33 2011
New Revision: 1072032

URL: http://svn.apache.org/viewvc?rev=1072032&view=rev
Log:
MAPREDUCE-2334. Update BlockPlacementPolicyRaid for the new method in 
BlockPlacementPolicy.

Modified:
    hadoop/mapreduce/trunk/CHANGES.txt
    
hadoop/mapreduce/trunk/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java

Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=1072032&r1=1072031&r2=1072032&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Fri Feb 18 15:58:33 2011
@@ -29,6 +29,9 @@ Trunk (unreleased changes)
 
     MAPREDUCE-1706. Log RAID recoveries on HDFS. (schen)
 
+    MAPREDUCE-2334. Update BlockPlacementPolicyRaid for the new method
+    in BlockPlacementPolicy.  (szetszwo)
+
   OPTIMIZATIONS
     
     MAPREDUCE-2026. Make JobTracker.getJobCounters() and

Modified: 
hadoop/mapreduce/trunk/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java
URL: 
http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java?rev=1072032&r1=1072031&r2=1072032&view=diff
==============================================================================
--- 
hadoop/mapreduce/trunk/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java
 (original)
+++ 
hadoop/mapreduce/trunk/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java
 Fri Feb 18 15:58:33 2011
@@ -108,6 +108,7 @@ public class BlockPlacementPolicyRaid ex
   @Override
   DatanodeDescriptor[] chooseTarget(String srcPath, int numOfReplicas,
       DatanodeDescriptor writer, List<DatanodeDescriptor> chosenNodes,
+      boolean returnChosenNodes,
       HashMap<Node, Node> excludedNodes, long blocksize) {
     try {
       if (excludedNodes == null) {
@@ -116,7 +117,7 @@ public class BlockPlacementPolicyRaid ex
       addExcludedNodes(srcPath, excludedNodes);
       DatanodeDescriptor[] result =
         defaultPolicy.chooseTarget(numOfReplicas, writer,
-          chosenNodes, excludedNodes, blocksize);
+          chosenNodes, returnChosenNodes, excludedNodes, blocksize);
       cachedLocatedBlocks.get(srcPath).
           add(new LocatedBlock(new Block(), result));
       return result;