diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index 3b1e30eac5073ca389658a05f7e4d05aebb58949..d3396e374e6bcf890c3822281389115f9678b746 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);