fix update batch

apache · Aug 28, 2024 · 2fc6fca · 2fc6fca
1 parent 86e4456
commit 2fc6fca
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/...anager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java b/...anager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java
@@ -144,9 +144,12 @@ public void onFailure() {
                 }
             }
         }
-
-        taskMapper.updateStateByIds(taskPOList);
-        stageMapper.updateStateByIds(stagePOList);
+        if (!taskPOList.isEmpty()) {
+            taskMapper.updateStateByIds(taskPOList);
+        }
+        if (!stagePOList.isEmpty()) {
+            stageMapper.updateStateByIds(stagePOList);
+        }
         jobMapper.updateById(jobPO);
     }