diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index 8294bd779b47e3cce8c3194352bfe639ad9ef276..11015da48a1d1e18fdc2179f35e0a1d6f073998c 100644
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -269,7 +269,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;
   }