fix(stream): fix memory leak.
This commit is contained in:
parent
82293406f1
commit
1e33a1f408
|
@ -139,6 +139,7 @@ int32_t mndInitStream(SMnode *pMnode) {
|
|||
|
||||
void mndCleanupStream(SMnode *pMnode) {
|
||||
taosArrayDestroy(execInfo.pTaskList);
|
||||
taosArrayDestroy(execInfo.pNodeList);
|
||||
taosHashCleanup(execInfo.pTaskMap);
|
||||
taosHashCleanup(execInfo.transMgmt.pDBTrans);
|
||||
taosHashCleanup(execInfo.pTransferStateStreams);
|
||||
|
|
Loading…
Reference in New Issue