From 61928f7df53f5ffbaf2794cee8b2fc56100b90f7 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Tue, 12 Mar 2024 12:11:06 +0800 Subject: [PATCH] [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 82e95708ef..3058708b2d 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());