From c4045de4bb212aa5903435292786b293566434a4 Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Sun, 27 Nov 2022 21:27:15 +0800
Subject: [PATCH] fix: memory leak while subscribe

---
 source/dnode/mnode/impl/src/mndScheduler.c | 2 ++
 source/dnode/mnode/impl/src/mndTopic.c     | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/source/dnode/mnode/impl/src/mndScheduler.c b/source/dnode/mnode/impl/src/mndScheduler.c
index 3c1d3f09bf..f71bd1c626 100644
--- a/source/dnode/mnode/impl/src/mndScheduler.c
+++ b/source/dnode/mnode/impl/src/mndScheduler.c
@@ -585,6 +585,8 @@ int32_t mndSchedInitSubEp(SMnode* pMnode, const SMqTopicObj* pTopic, SMqSubscrib
     } else {
       pVgEp->qmsg = strdup("");
     }
+
+    sdbRelease(pSdb, pVgroup);
   }
 
   ASSERT(pSub->unassignedVgs->size > 0);
diff --git a/source/dnode/mnode/impl/src/mndTopic.c b/source/dnode/mnode/impl/src/mndTopic.c
index 522036afa2..f1db6a12fc 100644
--- a/source/dnode/mnode/impl/src/mndTopic.c
+++ b/source/dnode/mnode/impl/src/mndTopic.c
@@ -512,6 +512,8 @@ static int32_t mndCreateTopic(SMnode *pMnode, SRpcMsg *pReq, SCMCreateTopicReq *
         mndTransDrop(pTrans);
         return -1;
       }
+
+      sdbRelease(pSdb, pVgroup);
     }
   }
 
-- 
GitLab