fix: fix memory leak issue

This commit is contained in:
dapan1121 2022-11-21 17:34:50 +08:00
parent a6c3bc20f1
commit 8abdb21091
1 changed files with 2 additions and 0 deletions

View File

@ -385,6 +385,8 @@ int32_t qWorkerPreprocessQueryMsg(void *qWorkerMgmt, SRpcMsg *pMsg, bool chkGran
code = qwPreprocessQuery(QW_FPARAMS(), &qwMsg); code = qwPreprocessQuery(QW_FPARAMS(), &qwMsg);
QW_SCH_TASK_DLOG("prerocessQuery end, handle:%p, code:%x", pMsg->info.handle, code); QW_SCH_TASK_DLOG("prerocessQuery end, handle:%p, code:%x", pMsg->info.handle, code);
tFreeSSubQueryMsg(&msg);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }