From 12986ff594e46a7400676624eb0faf0fdf2aa463 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 26 Jul 2023 09:25:30 +0800
Subject: [PATCH] fix(stream): fix memory leaks.

---
 source/libs/stream/src/streamExec.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index f27e7e6316..269e00bc01 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -415,6 +415,7 @@ static int32_t streamTransferStateToStreamTask(SStreamTask* pTask) {
   // free it and remove it from disk meta-store
   streamMetaUnregisterTask(pMeta, pTask->id.taskId);
   streamMetaRemoveTask(pMeta, taskId);
+  streamMetaReleaseTask(pMeta, pTask);
 
   // save to disk
   taosWLockLatch(&pMeta->lock);