Fmt.

infiniflow · Dec 29, 2023 · dacf253 · dacf253
1 parent d896ede
commit dacf253
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 8 deletions.
diff --git 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
@@ -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
@@ -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)