From 7624c2b949f1e29da563f8febe6b73434e2f4765 Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Mon, 4 Sep 2023 09:59:10 +0800 Subject: [PATCH] Improve rated log in insertBufferNode (#26788) Signed-off-by: bigsheeper --- internal/datanode/flow_graph_insert_buffer_node.go | 2 +- internal/rootcoord/quota_center.go | 3 --- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go index 01e72ea453..5b77ead0e3 100644 --- a/internal/datanode/flow_graph_insert_buffer_node.go +++ b/internal/datanode/flow_graph_insert_buffer_node.go @@ -459,7 +459,7 @@ func (ibNode *insertBufferNode) Sync(fgMsg *flowGraphMsg, seg2Upload []UniqueID, zap.Bool("auto", task.auto), zap.Any("position", endPosition), zap.String("channel", ibNode.channelName), - ) + ).WithRateGroup("ibNode.sync", 1, 60) // check if segment is syncing segment := ibNode.channel.getSegment(task.segmentID) if !task.dropped && !task.flushed && segment.isSyncing() { diff --git a/internal/rootcoord/quota_center.go b/internal/rootcoord/quota_center.go index d2931ae853..f56ddee250 100644 --- a/internal/rootcoord/quota_center.go +++ b/internal/rootcoord/quota_center.go @@ -412,9 +412,6 @@ func (q *QuotaCenter) calculateReadRates() { q.guaranteeMinRate(getCollectionRateLimitConfig(collectionProps, common.CollectionSearchRateMinKey), internalpb.RateType_DQLSearch, collection) q.guaranteeMinRate(getCollectionRateLimitConfig(collectionProps, common.CollectionQueryRateMinKey), internalpb.RateType_DQLQuery, collection) } - - log.RatedInfo(10, "QueryNodeMetrics when cool-off", - zap.Any("metrics", q.queryNodeMetrics)) } // TODO: unify search and query?