From 37ea86f8ed0238dd32e0c3394a60775d1e93d392 Mon Sep 17 00:00:00 2001
From: Alex Duan <417921451@qq.com>
Date: Tue, 20 Dec 2022 21:13:33 +0800
Subject: [PATCH] fix(rpc): add msgType condition

---
 source/libs/transport/src/transCli.c | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index e8b8c95eb1..bf43b0c0d0 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1673,7 +1673,14 @@ int cliAppCb(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {
   // check whole vnodes is offline on this vgroup
   if (pResp->code == TSDB_CODE_RPC_NETWORK_UNAVAIL || pResp->code == TSDB_CODE_RPC_BROKEN_LINK) {
     if (pCtx->epsetRetryCnt >= pCtx->epSet.numOfEps || pCtx->retryStep > 0) {
-        pResp->code = TSDB_CODE_RPC_VGROUP_NOT_CONNECTED;
+      switch (pMsg->msg.msgType) {
+        case TDMT_VND_BATCH_META:
+        case TDMT_VND_SUBMIT:
+        case TDMT_SCH_QUERY:
+        case TDMT_SCH_MERGE_QUERY:
+          pResp->code = TSDB_CODE_RPC_VGROUP_NOT_CONNECTED;
+          break;
+      }
     }
   }