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;
|