diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index 160e4ca8e6d6f12df6aa2d93ab28645eaa289b9e..813a7983e4328748582b051899a3f76d817ace56 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1427,10 +1427,10 @@ bool cliResetEpset(STransConnCtx* pCtx, STransMsg* pResp, bool hasEpSet) {
   } else {
     SEpSet epSet;
 
-    assert(pResp->contLen == sizeof(epSet));
+    // assert(pResp->contLen == sizeof(epSet));
     int32_t valid = tDeserializeSEpSet(pResp->pCont, pResp->contLen, &epSet);
     if (valid < 0) {
-      assert(0);
+      // assert(0);
     }
     if (!transEpSetIsEqual(&pCtx->epSet, &epSet)) {
       tDebug("epset not equal, retry new epset");
@@ -1454,6 +1454,11 @@ bool cliGenRetryRule(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {
   if (retry == false) {
     return false;
   }
+  if (pCtx->retryInit) {
+    if (-1 != pCtx->retryMaxTimeout && taosGetTimestampMs() - pCtx->retryInitTimestamp >= pCtx->retryMaxTimeout) {
+      return false;
+    }
+  }
 
   bool noDelay = false;