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;