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

fix: Do compressBinlog to fix logID 0 (#34060) 

issue: https://github.com/milvus-io/milvus/issues/34059

Do compressBinlog to ensure that reloadFromKV will fill binlogs' logID
after datacoord restarts.

---------

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/34081/head
yihao.dai 2024-06-22 16:14:01 +08:00 committed by GitHub
parent e0e06fc9e0
commit fb870d2426
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/metastore/kv/datacoord/kv_catalog.go
View File

@ -217,29 +217,23 @@ func (kc *Catalog) applyBinlogInfo(segments []*datapb.SegmentInfo, insertLogs, d
for _, segmentInfo := range segments {
if len(segmentInfo.Binlogs) == 0 {
segmentInfo.Binlogs = insertLogs[segmentInfo.ID]
} else {
err = binlog.CompressFieldBinlogs(segmentInfo.Binlogs)
if err != nil {
return err
}
if err = binlog.CompressFieldBinlogs(segmentInfo.Binlogs); err != nil {
return err
}
if len(segmentInfo.Deltalogs) == 0 {
segmentInfo.Deltalogs = deltaLogs[segmentInfo.ID]
} else {
err = binlog.CompressFieldBinlogs(segmentInfo.Deltalogs)
if err != nil {
return err
}
if err = binlog.CompressFieldBinlogs(segmentInfo.Deltalogs); err != nil {
return err
}
if len(segmentInfo.Statslogs) == 0 {
segmentInfo.Statslogs = statsLogs[segmentInfo.ID]
} else {
err = binlog.CompressFieldBinlogs(segmentInfo.Statslogs)
if err != nil {
return err
}
if err = binlog.CompressFieldBinlogs(segmentInfo.Statslogs); err != nil {
return err
}
}
return nil