fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2025-02-07 11:11:22 +08:00
parent a5cdf3320c
commit 68faa300af
1 changed files with 1 additions and 0 deletions

View File

@ -541,6 +541,7 @@ int32_t vmStartWorker(SVnodeMgmt *pMgmt) {
void vmStopWorker(SVnodeMgmt *pMgmt) {
tQueryAutoQWorkerCleanup(&pMgmt->queryPool);
tAutoQWorkerCleanup(&pMgmt->streamPool);
tWWorkerCleanup(&pMgmt->streamCtrlPool);
tWWorkerCleanup(&pMgmt->fetchPool);
dDebug("vnode workers are closed");
}