From 261bb8fbdbae390110db7c32ec48025a1e2d1534 Mon Sep 17 00:00:00 2001 From: wei liu Date: Wed, 17 Apr 2024 11:05:22 +0800 Subject: [PATCH] fix: Update segment's version in syncDistribution (#32320) issue: #31468 pr: #31643 Signed-off-by: Wei Liu --- internal/querynodev2/handlers.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/querynodev2/handlers.go b/internal/querynodev2/handlers.go index 7d01154d9f..41aca0ddc8 100644 --- a/internal/querynodev2/handlers.go +++ b/internal/querynodev2/handlers.go @@ -91,6 +91,9 @@ func (node *QueryNode) loadDeltaLogs(ctx context.Context, req *querypb.LoadSegme } continue } + // try to update segment version after load delta logs + // try to update segment version after wait segment loaded + node.manager.Segment.UpdateSegmentBy(segments.IncreaseVersion(req.GetVersion()), segments.WithType(segments.SegmentTypeSealed), segments.WithID(info.GetSegmentID())) } if finalErr != nil {