diff --git a/core/processor/ProcessorSplitLogStringNative.cpp b/core/processor/ProcessorSplitLogStringNative.cpp index e1c5083f5e..edf7c72119 100644 --- a/core/processor/ProcessorSplitLogStringNative.cpp +++ b/core/processor/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/ProcessorSplitMultilineLogStringNative.cpp b/core/processor/ProcessorSplitMultilineLogStringNative.cpp index 12df049b34..2157c1e39c 100644 --- a/core/processor/ProcessorSplitMultilineLogStringNative.cpp +++ b/core/processor/ProcessorSplitMultilineLogStringNative.cpp @@ -92,6 +92,7 @@ void ProcessorSplitMultilineLogStringNative::Process(PipelineEventGroup& logGrou } mProcMatchedLinesCnt->Add(inputLines - unmatchLines); mProcUnmatchedLinesCnt->Add(unmatchLines); + *mSplitLines = newEvents.size(); logGroup.SwapEvents(newEvents); }