From 90c2c57c0b0d19b4a604c5b1668147a3dbbf6cd4 Mon Sep 17 00:00:00 2001
From: zhjc1124 <zhjc1124@gmail.com>
Date: Thu, 1 Aug 2024 05:15:08 +0000
Subject: [PATCH] [CP] fix: group worker concurrency not enough

---
 src/observer/omt/ob_tenant.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/observer/omt/ob_tenant.cpp b/src/observer/omt/ob_tenant.cpp
index d79f6a6dc3..a3a6539832 100644
--- a/src/observer/omt/ob_tenant.cpp
+++ b/src/observer/omt/ob_tenant.cpp
@@ -487,7 +487,9 @@ void ObResourceGroup::check_worker_count()
       token = std::min(token, max_worker_cnt());
       token = std::max(token, target_min);
     } else {
-      target_min = std::min(req_queue_.size(), min_worker_cnt());
+      if (req_queue_.size() > 0) {
+        target_min = std::min(req_queue_.size() + workers_.get_size(), min_worker_cnt());
+      }
       if (blocking_cnt == 0 && req_queue_.size() == 0) {
         token = 0;
       } else {