From 707b3c4a7a3855ddab77c60ed6c25b487038f61e Mon Sep 17 00:00:00 2001
From: zhangqiang <qiangzh95@gmail.com>
Date: Fri, 10 Oct 2025 14:37:24 +0800
Subject: [PATCH] [BugFix] Fix nullptr exception during remove expried load job
 (#63820)

Signed-off-by: sevev <qiangzh95@gmail.com>
---
 .../main/java/com/starrocks/load/loadv2/LoadMgr.java | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/fe/fe-core/src/main/java/com/starrocks/load/loadv2/LoadMgr.java b/fe/fe-core/src/main/java/com/starrocks/load/loadv2/LoadMgr.java
index 73b940a9a58..1c8184a4e09 100644
--- a/fe/fe-core/src/main/java/com/starrocks/load/loadv2/LoadMgr.java
+++ b/fe/fe-core/src/main/java/com/starrocks/load/loadv2/LoadMgr.java
@@ -400,11 +400,13 @@ public class LoadMgr implements MemoryTrackable {
 
         // 2. remove from dbIdToLabelToLoadJobs
         Map<String, List<LoadJob>> labelToLoadJobs = dbIdToLabelToLoadJobs.get(dbId);
-        List<LoadJob> sameLabelJobs = labelToLoadJobs.get(label);
-        if (sameLabelJobs != null) {
-            sameLabelJobs.remove(job);
-            if (sameLabelJobs.isEmpty()) {
-                labelToLoadJobs.remove(label);
+        if (labelToLoadJobs != null) {
+            List<LoadJob> sameLabelJobs = labelToLoadJobs.get(label);
+            if (sameLabelJobs != null) {
+                sameLabelJobs.remove(job);
+                if (sameLabelJobs.isEmpty()) {
+                    labelToLoadJobs.remove(label);
+                }
             }
             if (labelToLoadJobs.isEmpty()) {
                 dbIdToLabelToLoadJobs.remove(dbId);