[CP] fix: group worker concurrency not enough

2024-08-01 05:15:08 +00:00
parent b1c071ea5f
commit 90c2c57c0b
1 changed files with 3 additions and 1 deletions
--- 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 {