From ce2cbd4ab5940fd29a44f60cd0875c70adafbc51 Mon Sep 17 00:00:00 2001
From: wangjiaming0909 <604227650@qq.com>
Date: Tue, 9 Apr 2024 11:37:08 +0800
Subject: [PATCH] fix stream fill history not finished

---
 source/libs/stream/src/streamTask.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c
index 7badbfa9f3..40cdeb401f 100644
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@@ -733,6 +733,7 @@ bool streamTaskIsAllUpstreamClosed(SStreamTask* pTask) {
 bool streamTaskSetSchedStatusWait(SStreamTask* pTask) {
   bool ret = false;
 
+  // double check
   taosThreadMutexLock(&pTask->lock);
   if (pTask->status.schedStatus == TASK_SCHED_STATUS__INACTIVE) {
     pTask->status.schedStatus = TASK_SCHED_STATUS__WAITING;