From e1719f8de4c9f85c0322375ff6847c45e2a09201 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sun, 29 Sep 2024 18:23:07 +0800
Subject: [PATCH] fix(stream): release ref.

---
 source/dnode/vnode/src/tq/tqStreamTask.c | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c
index 3c0ff751da..c40ea66487 100644
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@@ -89,11 +89,13 @@ static void doStartScanWal(void* param, void* tmrId) {
           pTq->pVnode->restored);
 
   int32_t code = streamTaskSchedTask(&pTq->pVnode->msgCb, vgId, 0, 0, STREAM_EXEC_T_EXTRACT_WAL_DATA);
-  taosMemoryFree(pParam);
 
   if (code) {
     tqError("vgId:%d failed sched task to scan wal, code:%s", vgId, tstrerror(code));
   }
+
+  taosReleaseRef(streamMetaId, pParam->metaId);
+  taosMemoryFree(pParam);
 }
 
 int32_t tqScanWalInFuture(STQ* pTq, int32_t numOfTasks, int32_t idleDuration) {