未验证 提交 a1321223 编写于 作者: W wei liu 提交者: GitHub

fix time unit in insert/delete cost metrics value (#25893)

Signed-off-by: NWei Liu <wei.liu@zilliz.com>
上级 a6808e64
...@@ -132,7 +132,7 @@ func (sd *shardDelegator) ProcessInsert(insertRecords map[int64]*InsertData) { ...@@ -132,7 +132,7 @@ func (sd *shardDelegator) ProcessInsert(insertRecords map[int64]*InsertData) {
) )
} }
metrics.QueryNodeProcessCost.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.InsertLabel). metrics.QueryNodeProcessCost.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.InsertLabel).
Observe(float64(tr.ElapseSpan())) Observe(float64(tr.ElapseSpan().Milliseconds()))
} }
// ProcessDelete handles delete data in delegator. // ProcessDelete handles delete data in delegator.
...@@ -234,7 +234,7 @@ func (sd *shardDelegator) ProcessDelete(deleteData []*DeleteData, ts uint64) { ...@@ -234,7 +234,7 @@ func (sd *shardDelegator) ProcessDelete(deleteData []*DeleteData, ts uint64) {
} }
metrics.QueryNodeProcessCost.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.DeleteLabel). metrics.QueryNodeProcessCost.WithLabelValues(fmt.Sprint(paramtable.GetNodeID()), metrics.DeleteLabel).
Observe(float64(tr.ElapseSpan())) Observe(float64(tr.ElapseSpan().Milliseconds()))
} }
// applyDelete handles delete record and apply them to corresponding workers. // applyDelete handles delete record and apply them to corresponding workers.
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册