From dacf25344b4e9899db456a4acd1c580135a3c588 Mon Sep 17 00:00:00 2001
From: shenyushi <shenyushi99@qq.com>
Date: Fri, 29 Dec 2023 09:35:51 +0800
Subject: [PATCH] Fmt.

---
 src/executor/operator_state.cpp   | 5 -----
 src/scheduler/fragment_task.cpp   | 4 ++--
 src/scheduler/task_scheduler.cppm | 2 +-
 3 files changed, 3 insertions(+), 8 deletions(-)

diff --git a/src/executor/operator_state.cpp b/src/executor/operator_state.cpp
index 35a74a45c8..f2ee0e3602 100644
--- a/src/executor/operator_state.cpp
+++ b/src/executor/operator_state.cpp
@@ -42,11 +42,6 @@ bool QueueSourceState::GetData() {
     SharedPtr<FragmentDataBase> fragment_data_base = nullptr;
     source_queue_.Dequeue(fragment_data_base);
 
-    OperatorState *next_op_state1 = this->next_op_state_;
-    if (next_op_state1->operator_type_ == PhysicalOperatorType::kFusion) {
-        int a = 1;
-    }
-
     switch (fragment_data_base->type_) {
         case FragmentDataType::kData: {
             auto *fragment_data = static_cast<FragmentData *>(fragment_data_base.get());
diff --git a/src/scheduler/fragment_task.cpp b/src/scheduler/fragment_task.cpp
index 32d65eb500..5b37623b04 100644
--- a/src/scheduler/fragment_task.cpp
+++ b/src/scheduler/fragment_task.cpp
@@ -60,7 +60,7 @@ void FragmentTask::OnExecute(i64) {
 
     bool execute_success{false};
     bool source_complete = source_op->Execute(fragment_context->query_context(), source_state_.get());
-    if (source_state_->error_message_.get() == nullptr) {
+    if(source_state_->error_message_.get() == nullptr) {
         // No source error
         Vector<PhysicalOperator *> &operator_refs = fragment_context->GetOperators();
 
@@ -120,8 +120,8 @@ bool FragmentTask::QuitFromWorkerLoop() {
         return false;
     }
     if (source_state_->state_type_ != SourceStateType::kQueue) {
+        // fragment's source is not from queue
         return false;
-        // Error<SchedulerException>("SourceStateType is not kQueue");
     }
     auto *queue_state = static_cast<QueueSourceState *>(source_state_.get());
 
diff --git a/src/scheduler/task_scheduler.cppm b/src/scheduler/task_scheduler.cppm
index 97d80a4013..6733d92caf 100644
--- a/src/scheduler/task_scheduler.cppm
+++ b/src/scheduler/task_scheduler.cppm
@@ -26,7 +26,7 @@ namespace infinity {
 class QueryContext;
 class PlanFragment;
 
-using FragmentTaskBlockQueue = BlockingQueue<FragmentTask *>;
+using FragmentTaskBlockQueue = BlockingQueue<FragmentTask*>;
 
 struct Worker {
     Worker(u64 cpu_id, UniquePtr<FragmentTaskBlockQueue> queue, UniquePtr<Thread> thread)