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

Fix deltalog savebinlogpath save log (#15092) 

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
pull/15095/head
XuanYang-cn 2022-01-10 15:45:34 +08:00 committed by GitHub
parent ee60e95310
commit 45f1f97ac4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/datanode/flush_manager.go
View File

@ -678,17 +678,21 @@ func flushNotifyFunc(dsService *dataSyncService, opts ...retry.Option) notifyMet
// TODO silverxia change to graceful stop datanode
panic(pack.err)
}
fieldInsert := []*datapb.FieldBinlog{}
fieldStats := []*datapb.FieldBinlog{}
deltaInfos := []*datapb.FieldBinlog{}
checkPoints := []*datapb.CheckPoint{}
var (
fieldInsert = []*datapb.FieldBinlog{}
fieldStats = []*datapb.FieldBinlog{}
deltaInfos = make([]*datapb.FieldBinlog, 1)
checkPoints = []*datapb.CheckPoint{}
)
for k, v := range pack.insertLogs {
fieldInsert = append(fieldInsert, &datapb.FieldBinlog{FieldID: k, Binlogs: []*datapb.Binlog{v}})
}
for k, v := range pack.statsLogs {
fieldStats = append(fieldStats, &datapb.FieldBinlog{FieldID: k, Binlogs: []*datapb.Binlog{v}})
}
deltaInfos = append(deltaInfos, &datapb.FieldBinlog{Binlogs: pack.deltaLogs})
deltaInfos[0] = &datapb.FieldBinlog{Binlogs: pack.deltaLogs}
// only current segment checkpoint info,
updates, _ := dsService.replica.getSegmentStatisticsUpdates(pack.segmentID)
@ -706,7 +710,7 @@ func flushNotifyFunc(dsService *dataSyncService, opts ...retry.Option) notifyMet
zap.Any("startPos", startPos),
zap.Int("Length of Field2BinlogPaths", len(fieldInsert)),
zap.Int("Length of Field2Stats", len(fieldStats)),
zap.Int("Length of Field2Deltalogs", len(deltaInfos)),
zap.Int("Length of Field2Deltalogs", len(deltaInfos[0].GetBinlogs())),
zap.String("vChannelName", dsService.vchannelName),
)