From c403a15f36d49841cd9d9ac948d4f7e1284fd6ea Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 20 Sep 2023 16:32:27 +0800
Subject: [PATCH] fix(stream): check the status before exec stream task when
 handling the dispatch requests.

---
 source/libs/stream/src/stream.c | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/source/libs/stream/src/stream.c b/source/libs/stream/src/stream.c
index 5a7e14c629..676f3e1502 100644
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -255,10 +255,14 @@ int32_t streamProcessDispatchMsg(SStreamTask* pTask, SStreamDispatchReq* pReq, S
 
   tDeleteStreamDispatchReq(pReq);
 
-  int8_t schedStatus = streamTaskSetSchedStatusWait(pTask);
-  if (schedStatus == TASK_SCHED_STATUS__INACTIVE) {
-    streamTryExec(pTask);
+  int8_t st = pTask->status.taskStatus;
+  if (st == TASK_STATUS__NORMAL || st == TASK_STATUS__SCAN_HISTORY || st == TASK_STATUS__CK) {
+    int8_t schedStatus = streamTaskSetSchedStatusWait(pTask);
+    if (schedStatus == TASK_SCHED_STATUS__INACTIVE) {
+      streamTryExec(pTask);
+    }
   }
+
   return 0;
 }