diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c index 8bc3c9064e..9a64387e82 100644 --- a/source/dnode/mnode/impl/src/mndSubscribe.c +++ b/source/dnode/mnode/impl/src/mndSubscribe.c @@ -395,6 +395,7 @@ static int32_t processRemoveAddVgs(SMnode *pMnode, SMqRebOutputObj *pOutput) { return totalVgNum; END: + sdbRelease(pMnode->pSdb, pVgroup); taosMemoryFree(pVgEp); taosArrayDestroyP(newVgs, (FDelete)tDeleteSMqVgEp); return code;