From 1adffe016df8a62f8e1f906cc6d9a2322dd34049 Mon Sep 17 00:00:00 2001 From: Bob Liu Date: Tue, 7 Nov 2023 17:52:18 +0800 Subject: [PATCH] clean hash after operator completed --- source/libs/executor/src/groupoperator.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/libs/executor/src/groupoperator.c b/source/libs/executor/src/groupoperator.c index df910ae4f4..eb18278870 100644 --- a/source/libs/executor/src/groupoperator.c +++ b/source/libs/executor/src/groupoperator.c @@ -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) {