rename task list

CalvinKirs · Dec 16, 2024 · 8493993 · 8493993
1 parent 1f57aff
commit 8493993
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java
@@ -209,10 +209,12 @@ public void run() throws JobException {
 
     @Override
     public void onFail() throws JobException {
-        if (isCanceled.get()) {
+        if (null != isCanceled && isCanceled.get()) {
             return;
         }
-        isFinished.set(true);
+        if (null != isFinished) {
+            isFinished.set(true);
+        }
         super.onFail();
     }