mirror of https://github.com/milvus-io/milvus.git
Remove too frequent timetick log (#6682)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>pull/6702/head
parent
9b1708f6e5
commit
26f890b5f5
|
@ -523,6 +523,15 @@ var (
|
|||
Name: "release_dql_message_stream_total",
|
||||
Help: "Counter of release dql message stream",
|
||||
}, []string{"status"})
|
||||
|
||||
// ProxyDmlChannelTimeTick used to count the time tick value of dml channels
|
||||
ProxyDmlChannelTimeTick = prometheus.NewGaugeVec(
|
||||
prometheus.GaugeOpts{
|
||||
Namespace: milvusNamespace,
|
||||
Subsystem: subSystemProxy,
|
||||
Name: "dml_channels_time_tick",
|
||||
Help: "Time tick of dml channels",
|
||||
}, []string{"pchan"})
|
||||
)
|
||||
|
||||
//RegisterProxy register Proxy metrics
|
||||
|
@ -570,6 +579,8 @@ func RegisterProxy() {
|
|||
prometheus.MustRegister(ProxyGetDdChannelCounter)
|
||||
|
||||
prometheus.MustRegister(ProxyReleaseDQLMessageStreamCounter)
|
||||
|
||||
prometheus.MustRegister(ProxyDmlChannelTimeTick)
|
||||
}
|
||||
|
||||
//RegisterQueryCoord register QueryCoord metrics
|
||||
|
|
|
@ -20,6 +20,8 @@ import (
|
|||
"sync/atomic"
|
||||
"time"
|
||||
|
||||
"github.com/milvus-io/milvus/internal/metrics"
|
||||
|
||||
"go.uber.org/zap"
|
||||
|
||||
"github.com/milvus-io/milvus/internal/allocator"
|
||||
|
@ -300,8 +302,6 @@ func (node *Proxy) sendChannelsTimeTickLoop() {
|
|||
}
|
||||
}
|
||||
|
||||
log.Debug("send timestamp statistics of pchan", zap.Any("channels", channels), zap.Any("tss", tss))
|
||||
|
||||
req := &internalpb.ChannelTimeTickMsg{
|
||||
Base: &commonpb.MsgBase{
|
||||
MsgType: commonpb.MsgType_TimeTick, // todo
|
||||
|
@ -314,6 +314,12 @@ func (node *Proxy) sendChannelsTimeTickLoop() {
|
|||
DefaultTimestamp: maxTs,
|
||||
}
|
||||
|
||||
for idx, channel := range channels {
|
||||
ts := tss[idx]
|
||||
metrics.ProxyDmlChannelTimeTick.WithLabelValues(channel).Set(float64(ts))
|
||||
}
|
||||
metrics.ProxyDmlChannelTimeTick.WithLabelValues("DefaultTimestamp").Set(float64(maxTs))
|
||||
|
||||
status, err := node.rootCoord.UpdateChannelTimeTick(node.ctx, req)
|
||||
if err != nil {
|
||||
log.Warn("sendChannelsTimeTickLoop.UpdateChannelTimeTick", zap.Error(err))
|
||||
|
|
Loading…
Reference in New Issue