From e04b23cef2e1b6be844b3778f53913235dffe5ae Mon Sep 17 00:00:00 2001 From: wayblink Date: Thu, 13 Jul 2023 17:52:30 +0800 Subject: [PATCH] Reduce log frequency in timetick_sender (#25542) Signed-off-by: wayblink --- internal/datanode/timetick_sender.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/datanode/timetick_sender.go b/internal/datanode/timetick_sender.go index 4e853494ef..139a7c7a96 100644 --- a/internal/datanode/timetick_sender.go +++ b/internal/datanode/timetick_sender.go @@ -139,7 +139,7 @@ func (m *timeTickSender) cleanStatesCache(sendedLastTss map[string]uint64) { m.mu.Lock() defer m.mu.Unlock() sizeBeforeClean := len(m.channelStatesCaches) - log.With(zap.Any("sendedLastTss", sendedLastTss), zap.Int("sizeBeforeClean", sizeBeforeClean)) + log := log.With(zap.Any("sendedLastTss", sendedLastTss), zap.Int("sizeBeforeClean", sizeBeforeClean)) for channelName, sendedLastTs := range sendedLastTss { channelCache, ok := m.channelStatesCaches[channelName] if ok { @@ -154,12 +154,12 @@ func (m *timeTickSender) cleanStatesCache(sendedLastTss map[string]uint64) { delete(m.channelStatesCaches, channelName) } } - log.Debug("timeTickSender channelStatesCaches", zap.Int("sizeAfterClean", len(m.channelStatesCaches))) + log.RatedDebug(30, "timeTickSender channelStatesCaches", zap.Int("sizeAfterClean", len(m.channelStatesCaches))) } func (m *timeTickSender) sendReport(ctx context.Context, submitTs Timestamp) error { toSendMsgs, sendLastTss := m.mergeDatanodeTtMsg() - log.Debug("timeTickSender send datanode timetick message", zap.Any("toSendMsgs", toSendMsgs), zap.Any("sendLastTss", sendLastTss)) + log.RatedDebug(30, "timeTickSender send datanode timetick message", zap.Any("toSendMsgs", toSendMsgs), zap.Any("sendLastTss", sendLastTss)) err := retry.Do(ctx, func() error { statusResp, err := m.dataCoord.ReportDataNodeTtMsgs(ctx, &datapb.ReportDataNodeTtMsgsRequest{ Base: commonpbutil.NewMsgBase(