database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[pipelineX](scanner) Use the actual instances num when ignore data distribution (#32081)

Browse Source
This commit is contained in:
Gabriel
2024-03-12 12:11:06 +08:00
committed by yiguolei
parent ffa904c487
commit 61928f7df5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
be/src/vec/exec/scan/scanner_context.cpp
View File

@ -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());