clean hash after operator completed

This commit is contained in:
Bob Liu 2023-11-07 17:52:18 +08:00
parent 1b9be71d55
commit 1adffe016d
1 changed files with 3 additions and 0 deletions

View File

@ -422,6 +422,9 @@ static SSDataBlock* buildGroupResultDataBlockByHash(SOperatorInfo* pOperator) {
doFilter(pRes, pOperator->exprSupp.pFilterInfo, NULL);
if (!hasRemainResultByHash(pOperator)) {
setOperatorCompleted(pOperator);
// clean hash after completed
tSimpleHashCleanup(pInfo->aggSup.pResultRowHashTable);
pInfo->aggSup.pResultRowHashTable = NULL;
break;
}
if (pRes->info.rows > 0) {