diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SimpleScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SimpleScheduler.java index 0cafcae58c..cb8a4ecc34 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SimpleScheduler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SimpleScheduler.java @@ -178,7 +178,8 @@ public class SimpleScheduler { } blacklistBackends.put(backendID, Pair.of(Config.blacklist_duration_second + 1, reason)); - LOG.warn("add backend {} to black list. reason: {}", backendID, reason); + // Should print the exception stack, so that we will know when it is added to blacklist. + LOG.warn("add backend {} to black list. reason: {}", backendID, reason, new Exception()); } public static boolean isAvailable(Backend backend) { diff --git a/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java b/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java index f8e4429a16..dd70589f69 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java +++ b/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java @@ -237,7 +237,8 @@ public class BeSelectionPolicy { @Override public String toString() { - return String.format("computeNode=%s | query=%s | load=%s | schedule=%s | tags=%s(%s) | medium=%s", + return String.format("computeNode=%s | query=%s | load=%s | schedule=%s | tags=%s |" + + "resource_downgrade=%s | medium=%s", preferComputeNode, needQueryAvailable, needLoadAvailable, needScheduleAvailable, resourceTags.stream().map(tag -> tag.toString()).collect(Collectors.joining(",")), this.allowResourceTagDowngrade, storageMedium); 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 0ca452992f..662455c87d 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 @@ -563,7 +563,7 @@ public class SystemInfoService { StringBuilder sb = new StringBuilder(" Backends details: "); for (Tag tag : replicaAlloc.getAllocMap().keySet()) { sb.append("backends with tag ").append(tag).append(" is "); - sb.append(idToBackendRef.values().stream().filter(be -> be.getLocationTag() == tag) + sb.append(idToBackendRef.values().stream().filter(be -> be.getLocationTag().equals(tag)) .map(Backend::getDetailsForCreateReplica) .collect(Collectors.toList())); sb.append(", ");