From 20b505a4829a475a6ecf64ec8862b26a8938cb22 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 19 Sep 2024 19:30:26 +0800 Subject: [PATCH] fix invalid retr3 --- source/dnode/mgmt/node_mgmt/src/dmTransport.c | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/source/dnode/mgmt/node_mgmt/src/dmTransport.c b/source/dnode/mgmt/node_mgmt/src/dmTransport.c index abebf576fe..e204b5d4aa 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c +++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c @@ -24,10 +24,8 @@ static inline void dmBuildMnodeRedirectRsp(SDnode *pDnode, SRpcMsg *pMsg) { SEpSet epSet = {0}; dmGetMnodeEpSetForRedirect(&pDnode->data, pMsg, &epSet); - if (epSet.numOfEps == 0) { - pMsg->code = TSDB_CODE_MNODE_NOT_FOUND; - return; - } else if (epSet.numOfEps == 1) { + if (epSet.numOfEps <= 1) { + pMsg->pCont = NULL; pMsg->code = TSDB_CODE_MNODE_NOT_FOUND; return; }