From 8d297265114946ac0933d6e8c818b69963adde5f Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sun, 29 Sep 2024 14:18:24 +0800
Subject: [PATCH] fix(stream): fix memory leak.

---
 source/dnode/mnode/impl/src/mndStream.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 3ec99f6e44..29ed6ef37b 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -209,10 +209,11 @@ SSdbRow *mndStreamActionDecode(SSdbRaw *pRaw) {
   tDecoderInit(&decoder, buf, tlen + 1);
   if (tDecodeSStreamObj(&decoder, pStream, sver) < 0) {
     tDecoderClear(&decoder);
+    tFreeStreamObj(pStream);
     goto STREAM_DECODE_OVER;
   }
-  tDecoderClear(&decoder);
 
+  tDecoderClear(&decoder);
   terrno = TSDB_CODE_SUCCESS;
 
 STREAM_DECODE_OVER: