fix(stream): clear the handle after send msg.

This commit is contained in:
Haojun Liao 2024-02-21 18:17:31 +08:00
parent 6f8a54f27b
commit 4440243b17
1 changed files with 2 additions and 1 deletions

View File

@ -357,10 +357,11 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) {
taosArrayDestroy(pOrphanTasks);
{
pReq->info.handle = NULL; // disable auto rsp
SRpcMsg rsp = {.code = 0, .info = pReq->info, .contLen = sizeof(SMStreamHbRspMsg)};
rsp.pCont = rpcMallocCont(rsp.contLen);
tmsgSendRsp(&rsp);
pReq->info.handle = NULL; // disable auto rsp
}
return TSDB_CODE_SUCCESS;