Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-16775. update

This commit is contained in:
Haiyang.Hu 2022-09-25 20:52:03 +08:00
parent 9ca1469a3d
commit 67e2449bd9
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockPlacementPolicyRackFaultTolerant.java
View File

@ -223,7 +223,9 @@ public class BlockPlacementPolicyRackFaultTolerant extends BlockPlacementPolicyD
// if node is DECOMMISSIONING and try a node on local rack, otherwise choose randomly,
// Here is a point to explain, currently we only consider the scenario
// where maxNodesPerRack is 1.
boolean isInResult = results.contains(writer);
final Node tmpWriter = writer;
boolean isInResult = results.stream().anyMatch(datanodeStorageInfo ->
datanodeStorageInfo.getDatanodeDescriptor().getName().equals(tmpWriter.getName()));
if (!isInResult) {
writer = chooseLocalStorage(writer, excludedNodes, blocksize,
maxNodesPerRack, results, avoidStaleNodes, storageTypes, true)