From 14953818e600bfbd955e06d13b5257dc36affb34 Mon Sep 17 00:00:00 2001
From: meiyi <meiyi@selectdb.com>
Date: Tue, 12 Nov 2024 10:23:45 +0800
Subject: [PATCH] [fix](group commit) fix NPE in group commit select backend
 (#43629)

---
 .../java/org/apache/doris/load/GroupCommitManager.java    | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

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);