diff --git a/core/processor/inner/ProcessorMergeMultilineLogNative.cpp b/core/processor/inner/ProcessorMergeMultilineLogNative.cpp index 6eafd261ff..da8dfc3ce0 100644 --- a/core/processor/inner/ProcessorMergeMultilineLogNative.cpp +++ b/core/processor/inner/ProcessorMergeMultilineLogNative.cpp @@ -94,7 +94,6 @@ void ProcessorMergeMultilineLogNative::Process(PipelineEventGroup& logGroup) { logGroup.DelMetadata(EventGroupMetaKey::HAS_PART_LOG); } *mSplitLines = logGroup.GetEvents().size(); - return; } bool ProcessorMergeMultilineLogNative::IsSupportedEvent(const PipelineEventPtr& e) const { diff --git a/core/processor/inner/ProcessorSplitLogStringNative.cpp b/core/processor/inner/ProcessorSplitLogStringNative.cpp index 79a9eb874c..8df6af83f9 100644 --- a/core/processor/inner/ProcessorSplitLogStringNative.cpp +++ b/core/processor/inner/ProcessorSplitLogStringNative.cpp @@ -83,8 +83,6 @@ void ProcessorSplitLogStringNative::Process(PipelineEventGroup& logGroup) { } *mSplitLines = newEvents.size(); logGroup.SwapEvents(newEvents); - - return; } bool ProcessorSplitLogStringNative::IsSupportedEvent(const PipelineEventPtr& e) const { diff --git a/core/processor/inner/ProcessorSplitMultilineLogStringNative.cpp b/core/processor/inner/ProcessorSplitMultilineLogStringNative.cpp index 10a919355b..d863844a65 100644 --- a/core/processor/inner/ProcessorSplitMultilineLogStringNative.cpp +++ b/core/processor/inner/ProcessorSplitMultilineLogStringNative.cpp @@ -92,6 +92,7 @@ void ProcessorSplitMultilineLogStringNative::Process(PipelineEventGroup& logGrou } mProcMatchedLinesCnt->Add(inputLines - unmatchLines); mProcUnmatchedLinesCnt->Add(unmatchLines); + *mSplitLines = newEvents.size(); logGroup.SwapEvents(newEvents); }