From 748df84238d5f06e23253f95c68e3244db7a494f Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Mon, 24 Jan 2022 06:57:00 +0000
Subject: [PATCH] fix memory leakage

---
 source/dnode/vnode/src/meta/metaBDBImpl.c     | 1 +
 source/dnode/vnode/src/tq/tq.c                | 1 +
 source/dnode/vnode/src/vnd/vnodeArenaMAImpl.c | 1 +
 source/dnode/vnode/src/vnd/vnodeQuery.c       | 5 +----
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/source/dnode/vnode/src/meta/metaBDBImpl.c b/source/dnode/vnode/src/meta/metaBDBImpl.c
index c8c5759bd2..dfdc144750 100644
--- a/source/dnode/vnode/src/meta/metaBDBImpl.c
+++ b/source/dnode/vnode/src/meta/metaBDBImpl.c
@@ -587,6 +587,7 @@ char *metaTbCursorNext(SMTbCursor *pTbCur) {
       pBuf = value.data;
       metaDecodeTbInfo(pBuf, &tbCfg);
       if (tbCfg.type == META_SUPER_TABLE) {
+        free(tbCfg.name);
         free(tbCfg.stbCfg.pTagSchema);
         continue;
       } else if (tbCfg.type == META_CHILD_TABLE) {
diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index 243b8d1b66..f3ebd5b284 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -82,6 +82,7 @@ STQ* tqOpen(const char* path, SWal* pWal, SMeta* pMeta, STqCfg* tqConfig, SMemAl
 
 void tqClose(STQ* pTq) {
   if (pTq) {
+    tfree(pTq->path);
     free(pTq);
   }
   // TODO
diff --git a/source/dnode/vnode/src/vnd/vnodeArenaMAImpl.c b/source/dnode/vnode/src/vnd/vnodeArenaMAImpl.c
index a2e3a0dc56..14b9a5124f 100644
--- a/source/dnode/vnode/src/vnd/vnodeArenaMAImpl.c
+++ b/source/dnode/vnode/src/vnd/vnodeArenaMAImpl.c
@@ -114,3 +114,4 @@ static void vArenaNodeFree(SVArenaNode *pNode) {
   if (pNode) {
     free(pNode);
   }
+}
diff --git a/source/dnode/vnode/src/vnd/vnodeQuery.c b/source/dnode/vnode/src/vnd/vnodeQuery.c
index be30df6e3c..9c89e36903 100644
--- a/source/dnode/vnode/src/vnd/vnodeQuery.c
+++ b/source/dnode/vnode/src/vnd/vnodeQuery.c
@@ -217,6 +217,7 @@ static int32_t vnodeGetTableList(SVnode *pVnode, SRpcMsg *pMsg) {
     STR_TO_VARSTR(p, n);
 
     p += (TSDB_TABLE_NAME_LEN + VARSTR_HEADER_SIZE);
+    free(n);
   }
 
   pFetchRsp->numOfRows = htonl(numOfTables);
@@ -231,10 +232,6 @@ static int32_t vnodeGetTableList(SVnode *pVnode, SRpcMsg *pMsg) {
   };
 
   rpcSendResponse(&rpcMsg);
-  for (int i = 0; i < taosArrayGetSize(pArray); i++) {
-    name = *(char **)taosArrayGet(pArray, i);
-    free(name);
-  }
 
   taosArrayDestroyEx(pArray, freeItemHelper);
   return 0;