From 28c5189c6d2a627c0fab9d7cb5c1de82d0c5f4c6 Mon Sep 17 00:00:00 2001 From: wei liu Date: Fri, 6 Dec 2024 18:22:40 +0800 Subject: [PATCH] enhance: Refine the error msg for filter node (#38278) Signed-off-by: Wei Liu --- internal/querynodev2/pipeline/filter_node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/querynodev2/pipeline/filter_node.go b/internal/querynodev2/pipeline/filter_node.go index d13e2bc5a0812..628f077059752 100644 --- a/internal/querynodev2/pipeline/filter_node.go +++ b/internal/querynodev2/pipeline/filter_node.go @@ -118,8 +118,8 @@ func (fNode *filterNode) filtrate(c *Collection, msg msgstream.TsMsg) error { // check segment whether excluded ok := fNode.delegator.VerifyExcludedSegments(insertMsg.SegmentID, insertMsg.EndTimestamp) if !ok { - m := fmt.Sprintf("Segment excluded, id: %d", insertMsg.GetSegmentID()) - return merr.WrapErrSegmentLack(insertMsg.GetSegmentID(), m) + m := fmt.Sprintf("skip msg due to segment=%d has been excluded", insertMsg.GetSegmentID()) + return merr.WrapErrServiceInternal(m) } return nil