diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index 46eb040468..b43b8a1e0c 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -886,9 +886,11 @@ void cliAppCb(SCliConn* pConn, STransMsg* transMsg) {
   STrans*      pTransInst = pThrd->pTransInst;
 
   if (transMsg->code == TSDB_CODE_RPC_REDIRECT && pTransInst->retry != NULL) {
-    // impl retry
+    SMEpSet emsg = {0};
+    tDeserializeSMEpSet(transMsg->pCont, transMsg->contLen, &emsg);
+    pTransInst->retry(pTransInst, transMsg, &(emsg.epSet));
   } else {
-    (*pTransInst->cfp)(pTransInst->parent, transMsg, NULL);
+    pTransInst->cfp(pTransInst->parent, transMsg, NULL);
   }
 }