This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new db2f2608a1d [pipelineX](scanner) Use the actual instances num when
ignore data distribution (#32081)
db2f2608a1d is described below
commit db2f2608a1d79b2ee6ed4427aa2cc34173c0a40e
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]
