Update IncrementalExecuteCallback

apache · Sep 20, 2023 · 3bcacc2 · 3bcacc2
1 parent 787d1e9
commit 3bcacc2
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/...apache/shardingsphere/data/pipeline/core/task/runner/InventoryIncrementalTasksRunner.java b/...apache/shardingsphere/data/pipeline/core/task/runner/InventoryIncrementalTasksRunner.java
@@ -150,7 +150,7 @@ private final class InventoryTaskExecuteCallback implements ExecuteCallback {
         @Override
         public void onSuccess() {
             if (jobItemContext.isStopping()) {
-                log.info("onSuccess, stopping true, ignore");
+                log.info("Inventory task onSuccess, stopping true, ignore");
                 return;
             }
             inventorySuccessCallback();
@@ -166,10 +166,6 @@ private final class IncrementalExecuteCallback implements ExecuteCallback {
 
         @Override
         public void onSuccess() {
-            if (jobItemContext.isStopping()) {
-                log.info("onSuccess, stopping true, ignore");
-                return;
-            }
             log.info("onSuccess, all incremental tasks finished.");
         }