From 072cbf035398f29fee0287eb57e951248c28a3f2 Mon Sep 17 00:00:00 2001 From: aoiasd <45024769+aoiasd@users.noreply.github.com> Date: Tue, 20 Jun 2023 14:22:42 +0800 Subject: [PATCH] Fix read quota queue len calculate twice (#24440) Signed-off-by: aoiasd --- internal/rootcoord/quota_center.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/internal/rootcoord/quota_center.go b/internal/rootcoord/quota_center.go index 2d88eab344..88451092f6 100644 --- a/internal/rootcoord/quota_center.go +++ b/internal/rootcoord/quota_center.go @@ -363,10 +363,9 @@ func (q *QuotaCenter) calculateReadRates() { return ri.UnsolvedQueue + ri.ReadyQueue + ri.ReceiveChan + ri.ExecuteChan } for _, metric := range q.queryNodeMetrics { - searchNQSum := sum(metric.SearchQueue) - queryTasksSum := sum(metric.QueryQueue) - nqInQueue := searchNQSum + queryTasksSum // We think of the NQ of query request as 1. - if nqInQueue >= nqInQueueThreshold { + // We think of the NQ of query request as 1. + // search use same queue with query + if sum(metric.SearchQueue) >= nqInQueueThreshold { limitCollectionSet.Insert(metric.Effect.CollectionIDs...) } }