diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java index 8b3bbe9ae7..3be373f21e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Tablet.java @@ -563,7 +563,7 @@ public class Tablet extends MetaObject implements Writable { // 3. replica is under relocating if (stable < replicationNum) { - List replicaBeIds = replicas.stream().map(Replica::getBackendId).collect(Collectors.toList()); + Set replicaBeIds = replicas.stream().map(Replica::getBackendId).collect(Collectors.toSet()); List availableBeIds = aliveBeIds.stream().filter(systemInfoService::checkBackendScheduleAvailable) .collect(Collectors.toList()); if (replicaBeIds.containsAll(availableBeIds) diff --git a/fe/fe-core/src/main/java/org/apache/doris/system/SystemInfoService.java b/fe/fe-core/src/main/java/org/apache/doris/system/SystemInfoService.java index 5cc6b36f87..9cf9f5ad27 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/system/SystemInfoService.java +++ b/fe/fe-core/src/main/java/org/apache/doris/system/SystemInfoService.java @@ -77,7 +77,7 @@ public class SystemInfoService { private volatile ImmutableMap idToBackendRef = ImmutableMap.of(); private volatile ImmutableMap idToReportVersionRef = ImmutableMap.of(); - private volatile ImmutableMap pathHashToDishInfoRef = ImmutableMap.of(); + private volatile ImmutableMap pathHashToDiskInfoRef = ImmutableMap.of(); public static class HostInfo implements Comparable { public String host; @@ -848,7 +848,7 @@ public class SystemInfoService { */ public Status checkExceedDiskCapacityLimit(Multimap bePathsMap, boolean floodStage) { LOG.debug("pathBeMap: {}", bePathsMap); - ImmutableMap pathHashToDiskInfo = pathHashToDishInfoRef; + ImmutableMap pathHashToDiskInfo = pathHashToDiskInfoRef; for (Long beId : bePathsMap.keySet()) { for (Long pathHash : bePathsMap.get(beId)) { DiskInfo diskInfo = pathHashToDiskInfo.get(pathHash); @@ -865,7 +865,7 @@ public class SystemInfoService { // update the path info when disk report // there is only one thread can update path info, so no need to worry about concurrency control public void updatePathInfo(List addedDisks, List removedDisks) { - Map copiedPathInfos = Maps.newHashMap(pathHashToDishInfoRef); + Map copiedPathInfos = Maps.newHashMap(pathHashToDiskInfoRef); for (DiskInfo diskInfo : addedDisks) { copiedPathInfos.put(diskInfo.getPathHash(), diskInfo); } @@ -873,7 +873,7 @@ public class SystemInfoService { copiedPathInfos.remove(diskInfo.getPathHash()); } ImmutableMap newPathInfos = ImmutableMap.copyOf(copiedPathInfos); - pathHashToDishInfoRef = newPathInfos; + pathHashToDiskInfoRef = newPathInfos; LOG.debug("update path infos: {}", newPathInfos); }