diff --git a/source/libs/transport/inc/transComm.h b/source/libs/transport/inc/transComm.h
index 93f948f7ed..fa5cc2a09d 100644
--- a/source/libs/transport/inc/transComm.h
+++ b/source/libs/transport/inc/transComm.h
@@ -446,7 +446,7 @@ void        transDQDestroy(SDelayQueue* queue, void (*freeFunc)(void* arg));
 SDelayTask* transDQSched(SDelayQueue* queue, void (*func)(void* arg), void* arg, uint64_t timeoutMs);
 void        transDQCancel(SDelayQueue* queue, SDelayTask* task);
 
-bool transRepEpsetIsEqual(SReqEpSet* a, SReqEpSet* b);
+bool transReqEpsetIsEqual(SReqEpSet* a, SReqEpSet* b);
 
 bool transCompareReqAndUserEpset(SReqEpSet* a, SEpSet* b);
 /*
diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index 2b5906396a..bb54f9e2cb 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1592,7 +1592,7 @@ FORCE_INLINE int32_t cliMayCvtFqdnToIp(SReqEpSet* pEpSet, const SCvtAddr* pCvtAd
 FORCE_INLINE bool cliIsEpsetUpdated(int32_t code, SReqCtx* pCtx) {
   if (code != 0) return false;
 
-  return transRepEpsetIsEqual(pCtx->epSet, pCtx->origEpSet) ? false : true;
+  return transReqEpsetIsEqual(pCtx->epSet, pCtx->origEpSet) ? false : true;
 }
 
 FORCE_INLINE int32_t cliBuildExceptResp(SCliThrd* pThrd, SCliReq* pReq, STransMsg* pResp) {
diff --git a/source/libs/transport/src/transComm.c b/source/libs/transport/src/transComm.c
index 3c42a1ec83..453cb43ed3 100644
--- a/source/libs/transport/src/transComm.c
+++ b/source/libs/transport/src/transComm.c
@@ -667,7 +667,13 @@ void transPrintEpSet(SEpSet* pEpSet) {
   len += snprintf(buf + len, sizeof(buf) - len, "}");
   tTrace("%s, inUse:%d", buf, pEpSet->inUse);
 }
-bool transRepEpsetIsEqual(SReqEpSet* a, SReqEpSet* b) {
+bool transReqEpsetIsEqual(SReqEpSet* a, SReqEpSet* b) {
+  if (a == NULL && b == NULL) {
+    return true;
+  } else if (a == NULL || b == NULL) {
+    return false;
+  }
+
   if (a->numOfEps != b->numOfEps || a->inUse != b->inUse) {
     return false;
   }