diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index c53062a98a6aacaf3b20494a896c5645cedf2102..9275003e898835379fc912badb7e0a6fdad70e49 100644
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -270,7 +270,8 @@ void *rpcOpen(const SRpcInit *pInit) {
   if (pInit->label) tstrncpy(pRpc->label, pInit->label, sizeof(pRpc->label));
   pRpc->connType = pInit->connType;
   if (pRpc->connType == TAOS_CONN_CLIENT) {
-    pRpc->numOfThreads = pInit->numOfThreads;
+    pRpc->numOfThreads =
+        pInit->numOfThreads > TSDB_MAX_RPC_THREADS * 2 ? TSDB_MAX_RPC_THREADS * 2 : pInit->numOfThreads;
   } else {
     pRpc->numOfThreads = pInit->numOfThreads > TSDB_MAX_RPC_THREADS ? TSDB_MAX_RPC_THREADS : pInit->numOfThreads;
   }