diff --git a/core/pipeline/Pipeline.cpp b/core/pipeline/Pipeline.cpp
index 7be446e4cf..40dec54bd6 100644
--- a/core/pipeline/Pipeline.cpp
+++ b/core/pipeline/Pipeline.cpp
@@ -431,9 +431,7 @@ void Pipeline::Stop(bool isRemoving) {
     ProcessQueueManager::GetInstance()->DisablePop(mName, isRemoving);
     WaitAllItemsInProcessFinished();
 
-    if (!isRemoving) {
-        FlushBatch();
-    }
+    FlushBatch();
 
     if (!mGoPipelineWithoutInput.isNull()) {
         // Go pipeline `Stop` will stop and delete