diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c index ebdf3df720..d9aecd96d7 100644 --- a/source/common/src/tglobal.c +++ b/source/common/src/tglobal.c @@ -513,6 +513,7 @@ static int32_t taosAddClientCfg(SConfig *pCfg) { tsNumOfTaskQueueThreads = tsNumOfCores / 2; tsNumOfTaskQueueThreads = TMAX(tsNumOfTaskQueueThreads, 4); + if (tsNumOfTaskQueueThreads >= 50) { tsNumOfTaskQueueThreads = 50; } @@ -1743,4 +1744,4 @@ void taosSetAllDebugFlag(int32_t flag, bool rewrite) { uInfo("all debug flag are set to %d", flag); } -int8_t taosGranted() { return atomic_load_8(&tsGrant); } +int8_t taosGranted() { return atomic_load_8(&tsGrant); } \ No newline at end of file