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

fix: correct wrong querynode metric labels (#41344) (#41422)

Browse Source 
cherry-pick from master: https://github.com/milvus-io/milvus/pull/41344
related: https://github.com/milvus-io/milvus/issues/41343

Signed-off-by: Xiaowei Shi <shallwe.shih@gmail.com>
This commit is contained in:
Xiaowei Shi 2025-04-24 21:40:40 +08:00 committed by GitHub
parent db602da685
commit 2f78f25c7f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/querynodev2/pipeline/filter_node.go
View File

@ -63,11 +63,11 @@ func (fNode *filterNode) Operate(in Msg) Msg {
}
metrics.QueryNodeConsumerMsgCount.
WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.InsertLabel, fmt.Sprint(fNode.collectionID)).
WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.AllLabel, fmt.Sprint(fNode.collectionID)).
Inc()
metrics.QueryNodeConsumeTimeTickLag.
WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.InsertLabel, fmt.Sprint(fNode.collectionID)).
WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.TimetickLabel, fmt.Sprint(fNode.collectionID)).
Set(float64(tsoutil.SubByNow(streamMsgPack.EndTs)))
// Get collection from collection manager
@ -127,7 +127,7 @@ func (fNode *filterNode) filtrate(c *Collection, msg msgstream.TsMsg) error {
case commonpb.MsgType_Delete:
deleteMsg := msg.(*msgstream.DeleteMsg)
metrics.QueryNodeConsumeCounter.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.InsertLabel).Add(float64(deleteMsg.Size()))
metrics.QueryNodeConsumeCounter.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.DeleteLabel).Add(float64(deleteMsg.Size()))
for _, policy := range fNode.DeleteMsgPolicys {
err := policy(fNode, c, deleteMsg)
if err != nil {