From 05a27eb7b06a956ffd55f1e99a28520352099283 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 12 Jan 2025 01:50:54 +0800 Subject: [PATCH] fix(stream): fix memory leak. --- source/dnode/mgmt/mgmt_vnode/src/vmWorker.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c b/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c index 4b278d533d..4cdf77c7e2 100644 --- a/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c +++ b/source/dnode/mgmt/mgmt_vnode/src/vmWorker.c @@ -542,5 +542,6 @@ void vmStopWorker(SVnodeMgmt *pMgmt) { tQueryAutoQWorkerCleanup(&pMgmt->queryPool); tAutoQWorkerCleanup(&pMgmt->streamPool); tWWorkerCleanup(&pMgmt->fetchPool); + tWWorkerCleanup(&pMgmt->streamCtrlPool); dDebug("vnode workers are closed"); }