From 1e3f6357e89cb409c3fdfd4b11c9e0af89f17ae3 Mon Sep 17 00:00:00 2001
From: shenyushi <shenyushi99@qq.com>
Date: Thu, 28 Dec 2023 21:04:25 +0800
Subject: [PATCH] Fix bug.

---
 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());