fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2023-11-22 18:28:38 +08:00
parent b419650116
commit 60fa7cccbf
1 changed files with 2 additions and 0 deletions

View File

@ -147,6 +147,8 @@ void mndCleanupStream(SMnode *pMnode) {
taosHashCleanup(execInfo.pTaskMap);
taosHashCleanup(execInfo.transMgmt.pDBTrans);
taosThreadMutexDestroy(&execInfo.lock);
taosHashCleanup(execInfo.transMgmt.pDBTrans);
taosHashCleanup(execInfo.transMgmt.pWaitingList);
mDebug("mnd stream exec info cleanup");
}