From d3bac29a32dff4c0fb39f7592166d85395e77aca Mon Sep 17 00:00:00 2001 From: liuyao <54liuyao@163.com> Date: Thu, 6 Jul 2023 15:33:16 +0800 Subject: [PATCH] checkpoint --- source/libs/executor/src/timewindowoperator.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c index 7c56acbeff..cc3bcf514f 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); }