This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 61928f7df53f5ffbaf2794cee8b2fc56100b90f7 Author: Gabriel <[email protected]> AuthorDate: Tue Mar 12 12:11:06 2024 +0800 [pipelineX](scanner) Use the actual instances num when ignore data distribution (#32081) --- be/src/vec/exec/scan/scanner_context.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/be/src/vec/exec/scan/scanner_context.cpp b/be/src/vec/exec/scan/scanner_context.cpp index 82e95708ef8..3058708b2d9 100644 --- a/be/src/vec/exec/scan/scanner_context.cpp +++ b/be/src/vec/exec/scan/scanner_context.cpp @@ -76,7 +76,8 @@ ScannerContext::ScannerContext(RuntimeState* state, const TupleDescriptor* outpu _max_thread_num = _state->num_scanner_threads() > 0 ? _state->num_scanner_threads() : config::doris_scanner_thread_pool_thread_num / - state->query_parallel_instance_num(); + (_local_state ? num_parallel_instances + : state->query_parallel_instance_num()); _max_thread_num *= num_parallel_instances; _max_thread_num = _max_thread_num == 0 ? 1 : _max_thread_num; _max_thread_num = std::min(_max_thread_num, (int32_t)scanners.size()); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
