FMT

apache · Dec 3, 2024 · f7693f0 · f7693f0
1 parent 1af6167
commit f7693f0
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/be/src/vec/exec/scan/scanner_context.cpp b/be/src/vec/exec/scan/scanner_context.cpp
@@ -340,10 +340,11 @@ Status ScannerContext::get_block_from_queue(RuntimeState* state, vectorized::Blo
         LOG_INFO("[{}] scanner context {} is finished", print_id(_query_id), ctx_id);
     } else {
         LOG_INFO(
-                "[{}] scanner context {} is not finished, _num_finished_scanners {}, _num_scheduled_scanners {}, all scanners "
+                "[{}] scanner context {} is not finished, _num_finished_scanners {}, "
+                "_num_scheduled_scanners {}, all scanners "
                 "{}, _tasks_queue size {}",
-                print_id(_query_id), ctx_id, _num_finished_scanners, _num_scheduled_scanners, _all_scanners.size(),
-                _tasks_queue.size());
+                print_id(_query_id), ctx_id, _num_finished_scanners, _num_scheduled_scanners,
+                _all_scanners.size(), _tasks_queue.size());
     }
     *eos = done();
 
@@ -515,7 +516,8 @@ Status ScannerContext::schedule_scan_task(std::shared_ptr<ScanTask> current_scan
         if (first_pull) {
             task_to_run = pull_next_scan_task(current_scan_task, current_concurrency);
             if (task_to_run == nullptr) {
-                if (current_scan_task && current_scan_task->cached_blocks.empty() && !current_scan_task->is_eos()) {
+                if (current_scan_task && current_scan_task->cached_blocks.empty() &&
+                    !current_scan_task->is_eos()) {
                     // Current scan task is not eos, but we can not resubmit it.
                     // This usally happens when we should downgrade the concurrency.
                     DCHECK(task_to_run == nullptr);