This commit is contained in:
Igor Nikonov 2024-11-01 14:52:42 +00:00
parent 77bd0b2903
commit 31f7615088
2 changed files with 3 additions and 3 deletions

View File

@ -1263,7 +1263,7 @@ Planner::Planner(const QueryTreeNodePtr & query_tree_,
findQueryForParallelReplicas(query_tree, select_query_options),
findTableForParallelReplicas(query_tree, select_query_options),
collectFiltersForAnalysis(query_tree, select_query_options))))
, root_planner(true)
// , root_planner(true)
{
}
@ -1538,7 +1538,7 @@ void Planner::buildPlanForQueryNode()
JoinTreeQueryPlan join_tree_query_plan;
if (planner_context->getMutableQueryContext()->canUseTaskBasedParallelReplicas()
&& planner_context->getGlobalPlannerContext()->parallel_replicas_node == &query_node && !root_planner)
&& planner_context->getGlobalPlannerContext()->parallel_replicas_node == &query_node /* && !root_planner*/)
{
join_tree_query_plan = buildQueryPlanForParallelReplicas(query_node, planner_context, select_query_info.storage_limits);
}

View File

@ -82,7 +82,7 @@ private:
StorageLimitsList storage_limits;
std::set<std::string> used_row_policies;
QueryNodeToPlanStepMapping query_node_to_plan_step_mapping;
bool root_planner = false;
// bool root_planner = false;
};
}