From c93c54b58055aa4cee5913a418de68def127b30a Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 8 May 2024 19:03:21 +0800 Subject: [PATCH] fix: increase default query thread number --- source/common/src/tglobal.c | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c index 87b72bdead..9223aa3c7a 100644 --- a/source/common/src/tglobal.c +++ b/source/common/src/tglobal.c @@ -60,15 +60,15 @@ int32_t tsTimeToGetAvailableConn = 500000; int32_t tsKeepAliveIdle = 60; int32_t tsNumOfCommitThreads = 2; -int32_t tsNumOfTaskQueueThreads = 10; -int32_t tsNumOfMnodeQueryThreads = 4; +int32_t tsNumOfTaskQueueThreads = 16; +int32_t tsNumOfMnodeQueryThreads = 16; int32_t tsNumOfMnodeFetchThreads = 1; int32_t tsNumOfMnodeReadThreads = 1; -int32_t tsNumOfVnodeQueryThreads = 4; +int32_t tsNumOfVnodeQueryThreads = 16; float tsRatioOfVnodeStreamThreads = 0.5F; int32_t tsNumOfVnodeFetchThreads = 4; int32_t tsNumOfVnodeRsmaThreads = 2; -int32_t tsNumOfQnodeQueryThreads = 4; +int32_t tsNumOfQnodeQueryThreads = 16; int32_t tsNumOfQnodeFetchThreads = 1; int32_t tsNumOfSnodeStreamThreads = 4; int32_t tsNumOfSnodeWriteThreads = 1; @@ -554,7 +554,7 @@ static int32_t taosAddClientCfg(SConfig *pCfg) { if (cfgAddInt32(pCfg, "keepAliveIdle", tsKeepAliveIdle, 1, 7200000, CFG_SCOPE_BOTH, CFG_DYN_ENT_BOTH) != 0) return -1; tsNumOfTaskQueueThreads = tsNumOfCores; - tsNumOfTaskQueueThreads = TMAX(tsNumOfTaskQueueThreads, 10); + tsNumOfTaskQueueThreads = TMAX(tsNumOfTaskQueueThreads, 16); if (cfgAddInt32(pCfg, "numOfTaskQueueThreads", tsNumOfTaskQueueThreads, 4, 1024, CFG_SCOPE_CLIENT, CFG_DYN_NONE) != 0) return -1; @@ -645,7 +645,7 @@ static int32_t taosAddServerCfg(SConfig *pCfg) { return -1; tsNumOfVnodeQueryThreads = tsNumOfCores * 2; - tsNumOfVnodeQueryThreads = TMAX(tsNumOfVnodeQueryThreads, 4); + tsNumOfVnodeQueryThreads = TMAX(tsNumOfVnodeQueryThreads, 16); if (cfgAddInt32(pCfg, "numOfVnodeQueryThreads", tsNumOfVnodeQueryThreads, 4, 1024, CFG_SCOPE_SERVER, CFG_DYN_NONE) != 0) return -1; @@ -666,7 +666,7 @@ static int32_t taosAddServerCfg(SConfig *pCfg) { return -1; tsNumOfQnodeQueryThreads = tsNumOfCores * 2; - tsNumOfQnodeQueryThreads = TMAX(tsNumOfQnodeQueryThreads, 4); + tsNumOfQnodeQueryThreads = TMAX(tsNumOfQnodeQueryThreads, 16); if (cfgAddInt32(pCfg, "numOfQnodeQueryThreads", tsNumOfQnodeQueryThreads, 4, 1024, CFG_SCOPE_SERVER, CFG_DYN_NONE) != 0) return -1; @@ -918,7 +918,7 @@ static int32_t taosUpdateServerCfg(SConfig *pCfg) { pItem = cfgGetItem(tsCfg, "numOfVnodeQueryThreads"); if (pItem != NULL && pItem->stype == CFG_STYPE_DEFAULT) { tsNumOfVnodeQueryThreads = numOfCores * 2; - tsNumOfVnodeQueryThreads = TMAX(tsNumOfVnodeQueryThreads, 4); + tsNumOfVnodeQueryThreads = TMAX(tsNumOfVnodeQueryThreads, 16); pItem->i32 = tsNumOfVnodeQueryThreads; pItem->stype = stype; } @@ -948,7 +948,7 @@ static int32_t taosUpdateServerCfg(SConfig *pCfg) { pItem = cfgGetItem(tsCfg, "numOfQnodeQueryThreads"); if (pItem != NULL && pItem->stype == CFG_STYPE_DEFAULT) { tsNumOfQnodeQueryThreads = numOfCores * 2; - tsNumOfQnodeQueryThreads = TMAX(tsNumOfQnodeQueryThreads, 4); + tsNumOfQnodeQueryThreads = TMAX(tsNumOfQnodeQueryThreads, 16); pItem->i32 = tsNumOfQnodeQueryThreads; pItem->stype = stype; }