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

---
 source/libs/stream/src/streamMeta.c | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 71ec7617e3..8067b66e9c 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -641,6 +641,7 @@ 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));
     return;
   }
@@ -648,6 +649,8 @@ void metaHbToMnode(void* param, void* tmrId) {
   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;
   }
 
@@ -656,6 +659,8 @@ 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;
   }
   tEncoderClear(&encoder);