fix(stream): fix memory leak.
This commit is contained in:
parent
9988720a1e
commit
a2a68ce256
|
@ -168,6 +168,8 @@ void mndCleanupStream(SMnode *pMnode) {
|
|||
taosArrayDestroy(execInfo.pTaskList);
|
||||
taosHashCleanup(execInfo.pTaskMap);
|
||||
taosThreadMutexDestroy(&execInfo.lock);
|
||||
taosHashCleanup(execInfo.transMgmt.pDBTrans);
|
||||
taosHashCleanup(execInfo.transMgmt.pWaitingList);
|
||||
mDebug("mnd stream exec info cleanup");
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue