Skip to content

Commit 8add74a

Browse files
committed
fix
1 parent 7c7ebd9 commit 8add74a

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

be/src/exec/scan/scanner.h

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -152,11 +152,6 @@ class Scanner {
152152
_update_scan_cpu_timer();
153153
start_wait_worker_timer();
154154
}
155-
// Called when submitting the scanner to the thread pool queue.
156-
// Only starts the wait timer without touching the CPU timer, because the CPU
157-
// timer uses CLOCK_THREAD_CPUTIME_ID which must be read on the same thread
158-
// that started it.
159-
void start_queue_wait() { _start_wait_worker_timer(); }
160155
int64_t get_time_cost_ns() const { return _per_scanner_timer; }
161156

162157
int64_t projection_time() const { return _projection_timer; }

be/src/exec/scan/scanner_scheduler.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,9 @@ Status ScannerScheduler::submit(std::shared_ptr<ScannerContext> ctx,
6868
}
6969

7070
scan_task->set_state(ScanTask::State::IN_FLIGHT);
71+
// Only starts the wait timer without touching the CPU timer, because the CPU
72+
// timer uses CLOCK_THREAD_CPUTIME_ID which must be read on the same thread
73+
// that started it.
7174
scanner_delegate->_scanner->start_wait_worker_timer();
7275
TabletStorageType type = scanner_delegate->_scanner->get_storage_type();
7376
auto sumbit_task = [&]() {

0 commit comments

Comments
 (0)