diff --git a/source/client/src/clientMsgHandler.c b/source/client/src/clientMsgHandler.c index 79d61423a7..448bf156f0 100644 --- a/source/client/src/clientMsgHandler.c +++ b/source/client/src/clientMsgHandler.c @@ -31,6 +31,13 @@ int genericRspCallback(void* param, const SDataBuf* pMsg, int32_t code) { int processConnectRsp(void* param, const SDataBuf* pMsg, int32_t code) { SRequestObj* pRequest = param; + if (code != TSDB_CODE_SUCCESS) { + pRequest->code = code; + terrno = code; + + sem_post(&pRequest->body.rspSem); + return code; + } STscObj *pTscObj = pRequest->pTscObj;