fix: use-after-free when remove pipeline but not clear flusher pointer (

#1859)
alibaba · Nov 6, 2024 · 67e0d7b · 67e0d7b
1 parent f117670
commit 67e0d7b
Showing 1 changed file with 1 addition and 3 deletions.
diff --git 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