From a685c1394a4316fe0c1dfc9a472c4f6be14f6ee9 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Thu, 31 Oct 2024 15:20:18 +0800
Subject: [PATCH] refactor: do some internal refactor.

---
 include/libs/stream/tstream.h       | 1 -
 source/libs/stream/src/streamMeta.c | 4 ++--
 source/libs/stream/src/streamTask.c | 2 --
 3 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/include/libs/stream/tstream.h b/include/libs/stream/tstream.h
index 449df5207f..81be70e35f 100644
--- a/include/libs/stream/tstream.h
+++ b/include/libs/stream/tstream.h
@@ -455,7 +455,6 @@ struct SStreamTask {
 
   // the followings attributes don't be serialized
   SScanhistorySchedInfo schedHistoryInfo;
-  int32_t               refCnt;
   int32_t               transferStateAlignCnt;
   struct SStreamMeta*   pMeta;
   SSHashObj*            pNameMap;
diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 2a271b9960..93c205005f 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -529,7 +529,7 @@ void streamMetaClear(SStreamMeta* pMeta) {
 
     // release the ref by timer
     if (p->info.delaySchedParam != 0 && p->info.fillHistory == 0) {  // one more ref in timer
-      stDebug("s-task:%s stop schedTimer, and (before) desc ref:%d", p->id.idStr, p->refCnt);
+      stDebug("s-task:%s stop schedTimer", p->id.idStr);
       streamTmrStop(p->schedInfo.pDelayTimer);
       p->info.delaySchedParam = 0;
     }
@@ -929,7 +929,7 @@ int32_t streamMetaUnregisterTask(SStreamMeta* pMeta, int64_t streamId, int32_t t
     }
 
     if (pTask->info.delaySchedParam != 0 && pTask->info.fillHistory == 0) {
-      stDebug("s-task:%s stop schedTimer, and (before) desc ref:%d", pTask->id.idStr, pTask->refCnt);
+      stDebug("s-task:%s stop schedTimer", pTask->id.idStr);
       streamTmrStop(pTask->schedInfo.pDelayTimer);
       pTask->info.delaySchedParam = 0;
     }
diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c
index 297dd6e72f..08870a5443 100644
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@@ -423,9 +423,7 @@ int32_t streamTaskInit(SStreamTask* pTask, SStreamMeta* pMeta, SMsgCb* pMsgCb, i
     return code;
   }
 
-  pTask->refCnt = 1;
   pTask->id.refId = 0;
-
   pTask->inputq.status = TASK_INPUT_STATUS__NORMAL;
   pTask->outputq.status = TASK_OUTPUT_STATUS__NORMAL;