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: