From 858144145f5227ddc8b164028762b01b1175d90e Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Sun, 2 Apr 2023 23:39:59 +0800
Subject: [PATCH] fix:memory leak

---
 source/common/src/tmsg.c           | 1 +
 source/dnode/vnode/src/tq/tqRead.c | 1 +
 2 files changed, 2 insertions(+)

diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index 7a238440a7..371073ed76 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -7212,6 +7212,7 @@ void tDestroySSubmitReq2(SSubmitReq2 *pReq, int32_t flag) {
     tDestroySSubmitTbData(&aSubmitTbData[i], flag);
   }
   taosArrayDestroy(pReq->aSubmitTbData);
+  pReq->aSubmitTbData = NULL;
 }
 
 int32_t tEncodeSSubmitRsp2(SEncoder *pCoder, const SSubmitRsp2 *pRsp) {
diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c
index 4f92330000..54e4e393ec 100644
--- a/source/dnode/vnode/src/tq/tqRead.c
+++ b/source/dnode/vnode/src/tq/tqRead.c
@@ -290,6 +290,7 @@ void tqCloseReader(STqReader* pReader) {
   }
   // free hash
   taosHashCleanup(pReader->tbIdHash);
+  tDestroySSubmitReq2(&pReader->submit, TSDB_MSG_FLG_DECODE);
   taosMemoryFree(pReader);
 }