You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2023/02/18 09:16:59 UTC
[doris] 02/02: f
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch sanqi
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 24cbcdc7b20d507cee0a389ef4c10a74a90f565e
Author: yiguolei <yi...@gmail.com>
AuthorDate: Sat Feb 18 17:16:30 2023 +0800
f
---
be/src/vec/exec/scan/scanner_scheduler.cpp | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/be/src/vec/exec/scan/scanner_scheduler.cpp b/be/src/vec/exec/scan/scanner_scheduler.cpp
index d62909b5bd..3b6defafc3 100644
--- a/be/src/vec/exec/scan/scanner_scheduler.cpp
+++ b/be/src/vec/exec/scan/scanner_scheduler.cpp
@@ -71,9 +71,9 @@ Status ScannerScheduler::init(ExecEnv* env) {
}
// 2. local scan thread pool
- _local_scan_thread_pool.reset(new PriorityWorkStealingThreadPool(
- config::doris_scanner_thread_pool_thread_num, env->store_paths().size(),
- config::doris_scanner_thread_pool_queue_size, "local_scan"));
+ _local_scan_thread_pool.reset(
+ new PriorityThreadPool(config::doris_scanner_thread_pool_thread_num,
+ config::doris_scanner_thread_pool_queue_size, "local_scan"));
// 3. remote scan thread pool
_remote_scan_thread_pool.reset(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org