fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2024-02-01 12:05:07 +08:00
parent cb2ea4a721
commit 4088e1cbff
1 changed files with 2 additions and 1 deletions

View File

@ -7418,10 +7418,11 @@ void tFreeSCMCreateStreamReq(SCMCreateStreamReq *pReq) {
if (NULL == pReq) {
return;
}
taosArrayDestroy(pReq->pTags);
taosMemoryFreeClear(pReq->sql);
taosMemoryFreeClear(pReq->ast);
taosArrayDestroy(pReq->pTags);
taosArrayDestroy(pReq->fillNullCols);
taosArrayDestroy(pReq->pVgroupVerList);
}
int32_t tEncodeSRSmaParam(SEncoder *pCoder, const SRSmaParam *pRSmaParam) {