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

enhance: Init channel cp metric when DataCoord recover (#35353) 

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
pull/35385/head
XuanYang-cn 2024-08-09 10:08:18 +08:00 committed by GitHub
parent c0ee25afd8
commit 61a426bc6f
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/datacoord/meta.go
View File

@ -221,6 +221,9 @@ func (m *meta) reloadFromKV() error {
// for 2.2.2 issue https://github.com/milvus-io/milvus/issues/22181 // for 2.2.2 issue https://github.com/milvus-io/milvus/issues/22181
pos.ChannelName = vChannel pos.ChannelName = vChannel
m.channelCPs.checkpoints[vChannel] = pos m.channelCPs.checkpoints[vChannel] = pos
ts, _ := tsoutil.ParseTS(pos.Timestamp)
metrics.DataCoordCheckpointUnixSeconds.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), vChannel).
Set(float64(ts.Unix()))
} }
log.Info("DataCoord meta reloadFromKV done", zap.Duration("duration", record.ElapseSpan())) log.Info("DataCoord meta reloadFromKV done", zap.Duration("duration", record.ElapseSpan()))