MAPREDUCE-2334. Update BlockPlacementPolicyRaid for the new method in BlockPlacementPolicy.
git-svn-id: https://svn.apache.org/repos/asf/hadoop/mapreduce/trunk@1072032 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/CHANGES.txt b/CHANGES.txt
index dca46e6..548aab2 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -29,6 +29,9 @@
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
diff --git a/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java b/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java
index b314b1b..e639b5c 100644
--- a/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java
+++ b/src/contrib/raid/src/java/org/apache/hadoop/hdfs/server/namenode/BlockPlacementPolicyRaid.java
@@ -108,6 +108,7 @@
@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 @@
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;
