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 {