fix(stream): fix memory leak.

2025-01-12 01:50:54 +08:00 · 2025-01-12 01:50:54 +08:00 · 05a27eb7b0
parent a3eea6fe1c
commit 05a27eb7b0
1 changed files with 1 additions and 0 deletions
--- 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");
 }