From f3df37bf284aa3ee2df908c7b6fc17b046dd3d2a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Thu, 15 Jun 2023 17:56:58 +0800
Subject: [PATCH] fix(stream): fix memory leak.

---
 source/dnode/mnode/impl/src/mndDef.c          | 1 +
 source/libs/executor/src/timewindowoperator.c | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/source/dnode/mnode/impl/src/mndDef.c b/source/dnode/mnode/impl/src/mndDef.c
index af82040760..dfd54ab254 100644
--- a/source/dnode/mnode/impl/src/mndDef.c
+++ b/source/dnode/mnode/impl/src/mndDef.c
@@ -176,6 +176,7 @@ void tFreeStreamObj(SStreamObj *pStream) {
   }
 
   taosArrayDestroy(pStream->tasks);
+  taosArrayDestroy(pStream->pHTasksList);
 
   // tagSchema.pSchema
   if (pStream->tagSchema.nCols > 0) {
diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c
index 50b9ca1c31..23932dcbc7 100644
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -2903,12 +2903,14 @@ void destroyStreamSessionAggOperatorInfo(void* param) {
     }
     taosArrayDestroy(pInfo->pChildren);
   }
+
   colDataDestroy(&pInfo->twAggSup.timeWindowData);
   blockDataDestroy(pInfo->pDelRes);
   blockDataDestroy(pInfo->pWinBlock);
   blockDataDestroy(pInfo->pUpdateRes);
   tSimpleHashCleanup(pInfo->pStDeleted);
 
+  taosArrayDestroy(pInfo->historyWins);
   taosMemoryFreeClear(param);
 }