From 3c575cefadbd0ddf92b88d62b6745585319f9a60 Mon Sep 17 00:00:00 2001 From: henryzhx8 Date: Mon, 17 Jun 2024 07:31:10 +0000 Subject: [PATCH 1/2] fix split line shennong log profile --- core/processor/inner/ProcessorSplitLogStringNative.cpp | 2 -- core/processor/inner/ProcessorSplitMultilineLogStringNative.cpp | 1 + 2 files changed, 1 insertion(+), 2 deletions(-) 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); } From 868321405b665570364070063061d51b0ec74013 Mon Sep 17 00:00:00 2001 From: henryzhx8 Date: Mon, 17 Jun 2024 07:55:37 +0000 Subject: [PATCH 2/2] polish --- core/processor/inner/ProcessorMergeMultilineLogNative.cpp | 1 - 1 file changed, 1 deletion(-) 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 {