From d896ede4b1de20a900010cf91869e99ffe506e51 Mon Sep 17 00:00:00 2001
From: shenyushi <shenyushi99@qq.com>
Date: Fri, 29 Dec 2023 09:23:00 +0800
Subject: [PATCH] Fix bug that source operator of stream fragment is not
 kQueue.

---
 src/scheduler/fragment_task.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/scheduler/fragment_task.cpp b/src/scheduler/fragment_task.cpp
index 395c52f0ff..32d65eb500 100644
--- a/src/scheduler/fragment_task.cpp
+++ b/src/scheduler/fragment_task.cpp
@@ -120,7 +120,8 @@ bool FragmentTask::QuitFromWorkerLoop() {
         return false;
     }
     if (source_state_->state_type_ != SourceStateType::kQueue) {
-        Error<SchedulerException>("SourceStateType is not kQueue");
+        return false;
+        // Error<SchedulerException>("SourceStateType is not kQueue");
     }
     auto *queue_state = static_cast<QueueSourceState *>(source_state_.get());