From bd480f251c5b49ce0ca2eda1137c71613d48e18f Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 31 Oct 2023 14:12:44 +0800 Subject: [PATCH 1/2] change NumOfTaskQueueThreads size --- source/common/src/tglobal.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c index 9ca529e825..daee300b73 100644 --- a/source/common/src/tglobal.c +++ b/source/common/src/tglobal.c @@ -472,9 +472,9 @@ static int32_t taosAddClientCfg(SConfig *pCfg) { tsNumOfTaskQueueThreads = tsNumOfCores / 2; tsNumOfTaskQueueThreads = TMAX(tsNumOfTaskQueueThreads, 4); - if (tsNumOfTaskQueueThreads >= 10) { - tsNumOfTaskQueueThreads = 10; - } + // if (tsNumOfTaskQueueThreads >= 10) { + // tsNumOfTaskQueueThreads = 10; + // } if (cfgAddInt32(pCfg, "numOfTaskQueueThreads", tsNumOfTaskQueueThreads, 4, 1024, CFG_SCOPE_CLIENT) != 0) return -1; return 0; From af7e33e5c51862766b4c4eaee084efedbbb37795 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 1 Nov 2023 10:51:26 +0800 Subject: [PATCH 2/2] change NumOfTaskQueueThreads size --- source/common/src/tglobal.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c index daee300b73..d70c6b725e 100644 --- a/source/common/src/tglobal.c +++ b/source/common/src/tglobal.c @@ -472,9 +472,9 @@ static int32_t taosAddClientCfg(SConfig *pCfg) { tsNumOfTaskQueueThreads = tsNumOfCores / 2; tsNumOfTaskQueueThreads = TMAX(tsNumOfTaskQueueThreads, 4); - // if (tsNumOfTaskQueueThreads >= 10) { - // tsNumOfTaskQueueThreads = 10; - // } + if (tsNumOfTaskQueueThreads >= 50) { + tsNumOfTaskQueueThreads = 50; + } if (cfgAddInt32(pCfg, "numOfTaskQueueThreads", tsNumOfTaskQueueThreads, 4, 1024, CFG_SCOPE_CLIENT) != 0) return -1; return 0;