fix(stream): fix memory leak.

2024-07-21 03:10:21 +08:00 · 2024-07-21 03:10:21 +08:00 · 6cc0096534
parent 70191f6a5d
commit 6cc0096534
1 changed files with 1 additions and 0 deletions
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@ -365,6 +365,7 @@ int32_t doScanWalForAllTasks(SStreamMeta* pStreamMeta, bool* pScanIdle) {
      code = streamTrySchedExec(pTask);
      if (code != TSDB_CODE_SUCCESS) {
        streamMetaReleaseTask(pStreamMeta, pTask);
+        taosArrayDestroy(pTaskList);
        return -1;
      }
    }