thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Twick number of threads

Browse Source
This commit is contained in:
Igor Nikonov 2024-07-02 15:06:19 +00:00
parent 6b3750ff83
commit 105d39b09f
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Planner/PlannerJoinTree.cpp
View File

@ -958,6 +958,18 @@ JoinTreeQueryPlan buildQueryPlanForTableExpression(QueryTreeNodePtr table_expres
table_expression_query_info.storage_limits, table_expression_query_info.storage_limits,
std::move(reading_step)); std::move(reading_step));
query_plan = std::move(query_plan_parallel_replicas); query_plan = std::move(query_plan_parallel_replicas);
if (settings.parallel_replicas_local_plan)
{
const auto old_max_threads = query_plan.getMaxThreads();
query_plan.setMaxThreads(old_max_threads * 2);
LOG_TRACE(
getLogger("Planner"),
"Increase max threads from {} to {} to have similar number of threads to remote plan",
old_max_threads,
query_plan.getMaxThreads());
}
} }
else else
{ {