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?