From e7d18e616dfc4e3b3e9b99bbac70b98999c30c7c Mon Sep 17 00:00:00 2001
From: wangjiaming0909 <604227650@qq.com>
Date: Fri, 2 Aug 2024 11:27:13 +0800
Subject: [PATCH] fix queryQworkerPool only allowed one extra thread to handle
 nonblocking queries

---
 source/util/src/tworker.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/util/src/tworker.c b/source/util/src/tworker.c
index d66628d46d..258d53c335 100644
--- a/source/util/src/tworker.c
+++ b/source/util/src/tworker.c
@@ -995,7 +995,7 @@ static int32_t tQueryAutoQWorkerAddWorker(SQueryAutoQWorkerPool *pool) {
 static int32_t tQueryAutoQWorkerBeforeBlocking(void *p) {
   SQueryAutoQWorkerPool *pPool = p;
   if (tQueryAutoQWorkerTrySignalWaitingAfterBlock(p) || tQueryAutoQWorkerTrySignalWaitingBeforeProcess(p) ||
-      tQueryAutoQWorkerTryDecActive(p, 1)) {
+      tQueryAutoQWorkerTryDecActive(p, pPool->num)) {
   } else {
     int32_t code = tQueryAutoQWorkerAddWorker(pPool);
     if (code != TSDB_CODE_SUCCESS) {