fix(query): fix memory leak.

This commit is contained in:
Haojun Liao 2024-09-06 15:58:52 +08:00
parent 7bf9ca8e82
commit 6470cfc26e
2 changed files with 5 additions and 2 deletions

View File

@ -5677,7 +5677,11 @@ int32_t startDurationForGroupTableMergeScan(SOperatorInfo* pOperator) {
param->pOperator = pOperator;
SSortSource* ps = taosMemoryCalloc(1, sizeof(SSortSource));
QUERY_CHECK_NULL(ps, code, lino, _end, terrno);
if (ps == NULL) {
taosMemoryFree(param);
QUERY_CHECK_NULL(ps, code, lino, _end, terrno);
}
ps->param = param;
ps->onlyRef = false;
code = tsortAddSource(pInfo->pSortHandle, ps);

View File

@ -369,7 +369,6 @@ int32_t doOpenSortOperator(SOperatorInfo* pOperator) {
return terrno;
}
qInfo("---alloc:%p", pSource);
pSource->param = pOperator->pDownstream[0];
pSource->onlyRef = true;