fix(stream): fix the invalid free.

This commit is contained in:
Haojun Liao 2023-08-18 22:40:04 +08:00
parent 4b10393c81
commit 718bb4a881
1 changed files with 1 additions and 0 deletions

View File

@ -766,6 +766,7 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i
}
streamFreeQitem(pTask->msgInfo.pData);
pTask->msgInfo.pData = NULL;
return TSDB_CODE_SUCCESS;
}