diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 592deb3272c0db7d41a579c54b70d23207b14419..5296b0c3d1b352eb640efd71d6af484fe353d73c 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -663,6 +663,9 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) { memcpy(pRes->pRsp, rpcMsg->pCont, pRes->rspLen); } } else { + if (pRes->code == TSDB_CODE_SUCCESS) { + pRes->code = TSDB_CODE_RPC_UNEXPECTED_RESPONSE; + } tfree(pRes->pRsp); }