From 658fafd03c68fb199a0d1994cd260539397f3cd8 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 8 Nov 2023 14:02:08 +0800
Subject: [PATCH] refactor: do some internal refactor.

---
 source/dnode/mnode/impl/src/mndStream.c  | 2 +-
 source/dnode/vnode/src/tq/tq.c           | 6 ++++--
 source/dnode/vnode/src/tq/tqStreamTask.c | 2 +-
 3 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 9f8d037268..e26b8e36a3 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -2571,7 +2571,7 @@ int32_t doKillActiveCheckpointTrans(SMnode *pMnode) {
   }
 
   if (transId == 0) {
-    mError("failed to find the checkpoint trans, reset not executed");
+    mDebug("failed to find the checkpoint trans, reset not executed");
     return TSDB_CODE_SUCCESS;
   }
 
diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index a8d25b6bb3..6f2f07f45b 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -1919,6 +1919,8 @@ int32_t tqProcessTaskUpdateReq(STQ* pTq, SRpcMsg* pMsg) {
       pMeta->startInfo.tasksWillRestart = 0;
       streamMetaWUnLock(pMeta);
     } else {
+      tqDebug("vgId:%d all %d task(s) nodeEp updated and closed", vgId, numOfTasks);
+
       streamMetaWUnLock(pMeta);
 #if 0
       tqStartStreamTaskAsync(pTq, true);
@@ -1950,13 +1952,13 @@ int32_t tqProcessTaskUpdateReq(STQ* pTq, SRpcMsg* pMsg) {
       }
 
       if (vnodeIsRoleLeader(pTq->pVnode) && !tsDisableStream) {
-        tqInfo("vgId:%d restart all stream tasks after all tasks being updated", vgId);
+        tqInfo("vgId:%d start all stream tasks after all being updated", vgId);
         tqResetStreamTaskStatus(pTq);
         tqStartStreamTaskAsync(pTq, false);
       } else {
         tqInfo("vgId:%d, follower node not start stream tasks", vgId);
       }
-
+      taosArrayDestroy(req.pNodeList);
       streamMetaWUnLock(pMeta);
 #endif
     }
diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c
index 44eb0351d7..0b8a5aadce 100644
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@@ -302,7 +302,7 @@ int32_t tqResetStreamTaskStatus(STQ* pTq) {
   int32_t      vgId = TD_VID(pTq->pVnode);
   int32_t      numOfTasks = taosArrayGetSize(pMeta->pTaskList);
 
-  tqDebug("vgId:%d start all %d stream task(s)", vgId, numOfTasks);
+  tqDebug("vgId:%d reset all %d stream task(s) status to be uninit", vgId, numOfTasks);
   if (numOfTasks == 0) {
     return TSDB_CODE_SUCCESS;
   }