From 1786f7077d3ed8bb7bf5c0e3fc2cbfb8783668bc Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Mon, 13 Nov 2023 14:35:23 +0800
Subject: [PATCH] Merge branch '3.0' into enh/refactorBackend

---
 source/libs/stream/src/streamBackendRocksdb.c | 2 ++
 source/libs/stream/src/streamMeta.c           | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index b65e26be3b..3740d8fe56 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -3654,6 +3654,8 @@ void bkdMgtDestroy(SBkdMgt* bm) {
   }
 
   taosThreadRwlockDestroy(&bm->rwLock);
+  taosMemoryFree(bm->path);
+  taosHashCleanup(bm->pDbChkpTbl);
 
   taosMemoryFree(bm);
 }
diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index d144d5a58e..8fb10ddc01 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -500,6 +500,8 @@ void streamMetaCloseImpl(void* arg) {
   taosThreadMutexDestroy(&pMeta->backendMutex);
 
   taosCleanUpScheduler(pMeta->qHandle);
+  taosMemoryFree(pMeta->qHandle);
+
   bkdMgtDestroy(pMeta->bkdChkptMgt);
 
   pMeta->role = NODE_ROLE_UNINIT;