From 49165f8c3c49eccce627e9e343247feed9fef227 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 20 Sep 2023 16:49:55 +0800
Subject: [PATCH] fix(stream): add more check.

---
 source/libs/stream/src/stream.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/source/libs/stream/src/stream.c b/source/libs/stream/src/stream.c
index 676f3e1502..38f7a9e748 100644
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -241,6 +241,11 @@ int32_t streamProcessDispatchMsg(SStreamTask* pTask, SStreamDispatchReq* pReq, S
     }
   }
 
+  int8_t st = pTask->status.taskStatus;
+  if (st == TASK_STATUS__HALT) {
+    status = TASK_INPUT_STATUS__BLOCKED;
+  }
+
   {
     // do send response with the input status
     int32_t code = buildDispatchRsp(pTask, pReq, status, &pRsp->pCont);
@@ -255,7 +260,6 @@ int32_t streamProcessDispatchMsg(SStreamTask* pTask, SStreamDispatchReq* pReq, S
 
   tDeleteStreamDispatchReq(pReq);
 
-  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) {