diff --git a/source/libs/transport/src/trans.c b/source/libs/transport/src/trans.c
index 415a8766e34a0ff3ebf1e5c8c552aa9554e26ada..c6a5cfdc953d775215d7bb29f3e10e87bfa854df 100644
--- a/source/libs/transport/src/trans.c
+++ b/source/libs/transport/src/trans.c
@@ -63,6 +63,9 @@ void* rpcOpen(const SRpcInit* pInit) {
   pRpc->destroyFp = pInit->dfp;
 
   pRpc->numOfThreads = pInit->numOfThreads > TSDB_MAX_RPC_THREADS ? TSDB_MAX_RPC_THREADS : pInit->numOfThreads;
+  if (pRpc->numOfThreads <= 0) {
+    pRpc->numOfThreads = 1;
+  }
 
   uint32_t ip = 0;
   if (pInit->connType == TAOS_CONN_SERVER) {
diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index c9677019304499c443f4ce35993f6b3bb0961053..725f352e5c5938407b18a3dd225ffdeae1ae2605 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1476,7 +1476,7 @@ bool cliGenRetryRule(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {
   STransConnCtx* pCtx = pMsg->ctx;
   int32_t        code = pResp->code;
 
-  bool retry = pTransInst->retry(code, pResp->msgType - 1);
+  bool retry = pTransInst->retry != NULL ? pTransInst->retry(code, pResp->msgType - 1) : false;
   if (retry == false) {
     return false;
   }