From 5fe7563a1368be08d46260ded83f52fcb5403bf3 Mon Sep 17 00:00:00 2001
From: yihaoDeng <cyang@taosdata.com>
Date: Tue, 22 Aug 2023 21:13:02 +0800
Subject: [PATCH] fix mem leak

---
 source/libs/stream/src/streamMeta.c | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 8067b66e9c..28f4c7b7d8 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -641,15 +641,14 @@ void metaHbToMnode(void* param, void* tmrId) {
 
   tEncodeSize(tEncodeStreamHbMsg, &hbMsg, tlen, code);
   if (code < 0) {
-    taosArrayDestroy(hbMsg.pTaskStatus);
     qError("vgId:%d encode stream hb msg failed, code:%s", pMeta->vgId, tstrerror(code));
+    taosArrayDestroy(hbMsg.pTaskStatus);
     return;
   }
 
   void* buf = rpcMallocCont(tlen);
   if (buf == NULL) {
     qError("vgId:%d encode stream hb msg failed, code:%s", pMeta->vgId, tstrerror(TSDB_CODE_OUT_OF_MEMORY));
-
     taosArrayDestroy(hbMsg.pTaskStatus);
     return;
   }
@@ -659,7 +658,6 @@ void metaHbToMnode(void* param, void* tmrId) {
   if ((code = tEncodeStreamHbMsg(&encoder, &hbMsg)) < 0) {
     rpcFreeCont(buf);
     qError("vgId:%d encode stream hb msg failed, code:%s", pMeta->vgId, tstrerror(code));
-
     taosArrayDestroy(hbMsg.pTaskStatus);
     return;
   }