fix(stream): fix memory leak.

2024-08-16 17:08:58 +08:00 · 2024-08-16 17:08:58 +08:00 · adc583a936
parent 37e820c865
commit adc583a936
1 changed files with 1 additions and 1 deletions
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@ -1051,7 +1051,7 @@ void streamMetaLoadAllTasks(SStreamMeta* pMeta) {
    } else {
      // todo this should replace the existed object put by replay creating stream task msg from mnode
      stError("s-task:0x%x already added into table meta by replaying WAL, need check", pTask->id.taskId);
-      taosMemoryFree(pTask);
+      tFreeStreamTask(pTask);
      continue;
    }