diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c index 7c56acbeffdea1b2b5884a5783fef8f83339ea98..cc3bcf514f94e465349597ccb7dfe06a57257484 100644 --- a/source/libs/executor/src/timewindowoperator.c +++ b/source/libs/executor/src/timewindowoperator.c @@ -3124,6 +3124,8 @@ void destroyStreamSessionAggOperatorInfo(void* param) { tSimpleHashCleanup(pInfo->pStDeleted); taosArrayDestroy(pInfo->historyWins); + blockDataDestroy(pInfo->pCheckpointRes); + taosMemoryFreeClear(param); } @@ -4378,6 +4380,8 @@ void destroyStreamStateOperatorInfo(void* param) { blockDataDestroy(pInfo->pDelRes); taosArrayDestroy(pInfo->historyWins); tSimpleHashCleanup(pInfo->pSeDeleted); + blockDataDestroy(pInfo->pCheckpointRes); + taosMemoryFreeClear(param); }