diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index 41c9ca2361..a5bb9e59d8 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -484,7 +484,7 @@ void streamMetaCloseImpl(void* arg) { taosHashCleanup(pMeta->pTaskDbUnique); taosHashCleanup(pMeta->pUpdateTaskSet); //taosHashCleanup(pMeta->pTaskBackendUnique); - //taosHashCleanup(pMeta->updateInfo.pTasks); + taosHashCleanup(pMeta->updateInfo.pTasks); taosHashCleanup(pMeta->startInfo.pReadyTaskSet); taosMemoryFree(pMeta->pHbInfo);