From 0692a9954d7cc34e9f2d60a4a32ecb3e2b8480af Mon Sep 17 00:00:00 2001 From: nroskill Date: Fri, 7 Jul 2023 06:12:31 +0000 Subject: [PATCH] fix wrong blocking status --- src/observer/omt/ob_tenant.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/observer/omt/ob_tenant.cpp b/src/observer/omt/ob_tenant.cpp index 4120b06f38..7b5e7f895b 100644 --- a/src/observer/omt/ob_tenant.cpp +++ b/src/observer/omt/ob_tenant.cpp @@ -388,6 +388,7 @@ void ObResourceGroup::check_worker_count() workers_.remove(wnode); destroy_worker(w); } else if (w->has_req_flag() + && 0 != w->blocking_ts() && now - w->blocking_ts() >= threshold && enable_dynamic_worker) { ++token; @@ -1385,6 +1386,7 @@ void ObTenant::check_worker_count() workers_.remove(wnode); destroy_worker(w); } else if (w->has_req_flag() + && 0 != w->blocking_ts() && now - w->blocking_ts() >= threshold && w->is_default_worker() && enable_dynamic_worker) {