diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java index 0e12367210..6e4e9a96f4 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java @@ -102,7 +102,7 @@ public class InternalSchemaInitializer extends Thread { return; } while (true) { - int backendNum = Env.getCurrentSystemInfo().getBackendNumFromDiffHosts(true); + int backendNum = Env.getCurrentSystemInfo().getStorageBackendNumFromDiffHosts(true); if (FeConstants.runningUnitTest) { backendNum = Env.getCurrentSystemInfo().getAllBackendIds().size(); } 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 0dc314240b..56ef540a24 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 @@ -417,11 +417,11 @@ public class SystemInfoService { } // return num of backends that from different hosts - public int getBackendNumFromDiffHosts(boolean aliveOnly) { + public int getStorageBackendNumFromDiffHosts(boolean aliveOnly) { Set hosts = Sets.newHashSet(); ImmutableMap idToBackend = idToBackendRef; for (Backend backend : idToBackend.values()) { - if (aliveOnly && !backend.isAlive()) { + if ((aliveOnly && !backend.isAlive()) || backend.isComputeNode()) { continue; } hosts.add(backend.getHost());