This is an automated email from the ASF dual-hosted git repository.
ZanderXu pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new fad73328b21 HDFS-17925. AddedNodeStorage should be obtained from
availableReplicas (#8510)
fad73328b21 is described below
commit fad73328b212c4b64e0bcc0bb85bc069c2282160
Author: CapMoon <[email protected]>
AuthorDate: Wed May 27 14:35:45 2026 +0800
HDFS-17925. AddedNodeStorage should be obtained from availableReplicas
(#8510)
---
.../hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java
index 0958aaf5b81..7479ff390d3 100644
---
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java
+++
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyDefault.java
@@ -1287,7 +1287,7 @@ public List<DatanodeStorageInfo> chooseReplicasToDelete(
final DatanodeStorageInfo delNodeHintStorage =
DatanodeStorageInfo.getDatanodeStorageInfo(delCandidates, delNodeHint);
final DatanodeStorageInfo addedNodeStorage =
- DatanodeStorageInfo.getDatanodeStorageInfo(delCandidates, addedNode);
+ DatanodeStorageInfo.getDatanodeStorageInfo(availableReplicas,
addedNode);
while (delCandidates.size() - expectedNumOfReplicas >
excessReplicas.size()) {
final DatanodeStorageInfo cur;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
