mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-07 19:31:51 +08:00
fix use same logidx in different field (#27492)
Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
This commit is contained in:
parent
07809880b2
commit
ec830e1240
@ -467,7 +467,6 @@ func (m *rendezvousFlushManager) flushBufferData(data *BufferData, segmentID Uni
|
||||
|
||||
// binlogs
|
||||
for _, blob := range binLogBlobs {
|
||||
defer func() { logidx++ }()
|
||||
fieldID, err := strconv.ParseInt(blob.GetKey(), 10, 64)
|
||||
if err != nil {
|
||||
log.Error("Flush failed ... cannot parse string to fieldID ..", zap.Error(err))
|
||||
@ -485,6 +484,8 @@ func (m *rendezvousFlushManager) flushBufferData(data *BufferData, segmentID Uni
|
||||
LogPath: key,
|
||||
LogSize: int64(fieldMemorySize[fieldID]),
|
||||
}
|
||||
|
||||
logidx += 1
|
||||
}
|
||||
|
||||
// pk stats binlog
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user