diff --git a/source/dnode/mnode/impl/src/mndDef.c b/source/dnode/mnode/impl/src/mndDef.c
index 81f434a1846c553863dfc9972ae136baaf6b6f5a..a81ab30455d18314dffcadafaa35207fbfaad0b5 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 5c0e735a8124d6ff781d775e656c24a69e550993..833f59fe8deee9e1ada7546045774734d01936b2 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;
 }