milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: Update segment's version in syncDistribution (#32320) 

issue: #31468
pr: #31643

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
pull/32393/head
wei liu 2024-04-17 11:05:22 +08:00 committed by GitHub
parent a52deabe87
commit 261bb8fbdb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/querynodev2/handlers.go
View File

@ -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 {