diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java index f46f7e9b7ed957..d26677790c7016 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java @@ -270,13 +270,11 @@ private Long getCachedBackend(long tableId) { // Another thread gets the same tableId but can not find this tableId. // So another thread needs to get the random backend. Long backendId = tableToBeMap.get(tableId); - Backend backend; - if (backendId != null) { - backend = Env.getCurrentSystemInfo().getBackend(backendId); - } else { + if (backendId == null) { return null; } - if (backend.isAlive() && !backend.isDecommissioned()) { + Backend backend = Env.getCurrentSystemInfo().getBackend(backendId); + if (backend != null && backend.isAlive() && !backend.isDecommissioned()) { return backend.getId(); } else { tableToBeMap.remove(tableId);