diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/runner/InventoryIncrementalTasksRunner.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/runner/InventoryIncrementalTasksRunner.java
index a92c47218bd7a..08415b7ecba8c 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/runner/InventoryIncrementalTasksRunner.java
+++ b/kernel/data-pipeline/core/src/main/java/org/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.");
         }