diff --git a/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java b/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
index 455984089b..df88a0c005 100644
--- a/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
+++ b/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
@@ -149,7 +149,9 @@ public class LoadManager implements Writable{
                     .stream().filter(entity -> entity.getState() != JobState.CANCELLED).findFirst()
                     .get().getTransactionId();
         } catch (UserException e) {
-            loadJob.cancelJobWithoutCheck(new FailMsg(LOAD_RUN_FAIL, e.getMessage()), false);
+            if (loadJob != null) {
+                loadJob.cancelJobWithoutCheck(new FailMsg(LOAD_RUN_FAIL, e.getMessage()), false);
+            }
             throw e;
         } finally {
             writeUnlock();