test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 10:59:32 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Fix querynode consume ts lag metrics (#24119)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2023-05-16 09:59:26 +08:00 committed by GitHub
parent 836b862dd7
commit df7848cf79
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -32,6 +32,7 @@ import (
"github.com/milvus-io/milvus/pkg/mq/msgstream"
"github.com/milvus-io/milvus/pkg/util/merr"
"github.com/milvus-io/milvus/pkg/util/paramtable"
"github.com/milvus-io/milvus/pkg/util/tsoutil"
"github.com/milvus-io/milvus/pkg/util/typeutil"
)
@ -67,7 +68,7 @@ func (fNode *filterNode) Operate(in Msg) Msg {
metrics.QueryNodeConsumeTimeTickLag.
WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.InsertLabel, fmt.Sprint(fNode.collectionID)).
Set(float64(streamMsgPack.EndTs))
Set(float64(tsoutil.SubByNow(streamMsgPack.EndTs)))
//Get collection from collection manager
collection := fNode.manager.Collection.Get(fNode.collectionID)