From e9d3198e052388c6c8bf9c73a3a54d8ce6f9f524 Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Sun, 25 Jun 2023 10:57:10 +0800
Subject: [PATCH] mem leak

---
 source/dnode/mnode/impl/src/mndDef.c  | 2 +-
 source/dnode/vnode/src/tq/tqRestore.c | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndDef.c b/source/dnode/mnode/impl/src/mndDef.c
index 81f434a184..a81ab30455 100644
--- a/source/dnode/mnode/impl/src/mndDef.c
+++ b/source/dnode/mnode/impl/src/mndDef.c
@@ -175,7 +175,7 @@ void tFreeStreamObj(SStreamObj *pStream) {
   taosMemoryFree(pStream->ast);
   taosMemoryFree(pStream->physicalPlan);
 
-  if (pStream->outputSchema.nCols) {
+  if (pStream->outputSchema.nCols || pStream->outputSchema.pSchema) {
     taosMemoryFree(pStream->outputSchema.pSchema);
   }
 
diff --git a/source/dnode/vnode/src/tq/tqRestore.c b/source/dnode/vnode/src/tq/tqRestore.c
index 5c0e735a81..833f59fe8d 100644
--- a/source/dnode/vnode/src/tq/tqRestore.c
+++ b/source/dnode/vnode/src/tq/tqRestore.c
@@ -83,6 +83,7 @@ int32_t tqStreamTasksStatusCheck(STQ* pTq) {
     streamTaskCheckDownstreamTasks(pTask);
     streamMetaReleaseTask(pMeta, pTask);
   }
+  taosArrayDestroy(pTaskList);
 
   return 0;
 }
-- 
GitLab