thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 12:32:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Prohibit any inner join.

Browse Source
This commit is contained in:
Nikolai Kochetov 2024-01-26 11:18:50 +00:00
parent b60228af3f
commit 7f2a5d38c5
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Planner/findParallelReplicasQuery.cpp
View File

@ -79,7 +79,13 @@ std::stack<const QueryNode *> getSupportingParallelReplicasQuery(const IQueryTre
{ {
const auto & join_node = query_tree_node->as<JoinNode &>(); const auto & join_node = query_tree_node->as<JoinNode &>();
auto join_kind = join_node.getKind(); auto join_kind = join_node.getKind();
if (join_kind != JoinKind::Inner && join_kind != JoinKind::Left) auto join_strictness = join_node.getStrictness();
bool can_parallelize_join =
join_kind == JoinKind::Left
|| (join_kind == JoinKind::Inner && join_strictness == JoinStrictness::All);
if (!can_parallelize_join)
return {}; return {};
query_tree_node = join_node.getLeftTableExpression().get(); query_tree_node = join_node.getLeftTableExpression().get();