From 4801003d9a8e524977620ac40beb32c591de7ae5 Mon Sep 17 00:00:00 2001
From: Alex Duan <417921451@qq.com>
Date: Tue, 13 Dec 2022 20:38:58 +0800
Subject: [PATCH] fix(rpc): only submit and query return

---
 src/rpc/src/rpcMain.c | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index 3b1e30eac5..d3396e374e 100644
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -1516,7 +1516,9 @@ static void rpcProcessConnError(void *param, void *id) {
     rpcMsg.contLen = 0;
 
     if( pContext->numOfTry >= pContext->epSet.numOfEps && rpcMsg.code == TSDB_CODE_RPC_NETWORK_UNAVAIL) {
-      rpcMsg.code = TSDB_CODE_RPC_VGROUP_NOT_REACHED;
+      if(pContext->msgType == TSDB_MSG_TYPE_SUBMIT || pContext->msgType == TSDB_MSG_TYPE_QUERY) {
+        rpcMsg.code = TSDB_CODE_RPC_VGROUP_NOT_REACHED;
+      }
     }
 
     tWarn("%s %p, connection error. notify client query over. numOfTry=%d msgType=%d", pRpc->label, pContext->ahandle, pContext->numOfTry, pContext->msgType);
-- 
GitLab