From caeab0cc1fb5e93386c3c0c4d3074201fc0b0571 Mon Sep 17 00:00:00 2001 From: congqixia Date: Wed, 16 Oct 2024 14:03:31 +0800 Subject: [PATCH] enhance: Fill start pos & level for growing segment (#36888) Start position & level info is missing for growing segment loaded in watch dml channel operation. Level is important for metrics and start position is crucial for growing exclude logic. Signed-off-by: Congqi Xia --- internal/querynodev2/handlers.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/querynodev2/handlers.go b/internal/querynodev2/handlers.go index d3898679d3..3f04929b1f 100644 --- a/internal/querynodev2/handlers.go +++ b/internal/querynodev2/handlers.go @@ -96,6 +96,7 @@ func loadGrowingSegments(ctx context.Context, delegator delegator.ShardDelegator if len(segmentInfo.GetBinlogs()) > 0 { growingSegments = append(growingSegments, &querypb.SegmentLoadInfo{ SegmentID: segmentInfo.ID, + Level: segmentInfo.GetLevel(), PartitionID: segmentInfo.PartitionID, CollectionID: segmentInfo.CollectionID, BinlogPaths: segmentInfo.Binlogs, @@ -104,6 +105,7 @@ func loadGrowingSegments(ctx context.Context, delegator delegator.ShardDelegator Deltalogs: segmentInfo.Deltalogs, Bm25Logs: segmentInfo.Bm25Statslogs, InsertChannel: segmentInfo.InsertChannel, + StartPosition: segmentInfo.GetStartPosition(), }) } else { log.Info("skip segment which binlog is empty", zap.Int64("segmentID", segmentInfo.ID))