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