admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

enhance: Save meta with txn limit (#43263) (#43288)

Browse Source 
pr: #43263

Signed-off-by: sunby <sunbingyi1992@gmail.com>
This commit is contained in:
Bingyi Sun 2025-07-14 19:32:50 +08:00 committed by GitHub
parent 6ef2351779
commit 0f736a4b16
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/metastore/kv/rootcoord/suffix_snapshot.go
View File

@ -543,8 +543,9 @@ func (ss *SuffixSnapshot) MultiSaveAndRemove(ctx context.Context, saves map[stri
updateList = append(updateList, removal)
}
// multi save execute map; if succeeds, update ts in the update list
err = ss.MetaKv.MultiSave(ctx, execute)
err = etcd.SaveByBatchWithLimit(execute, util.MaxEtcdTxnNum, func(partialKvs map[string]string) error {
return ss.MetaKv.MultiSave(ctx, partialKvs)
})
if err == nil {
for _, key := range updateList {
ss.lastestTS[key] = ts