thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-30 19:42:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix distributed JOINs

Browse Source
This commit is contained in:
Dmitry Novik 2023-05-25 15:58:08 +00:00
parent b86516131b
commit 85e5ed79e5
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Storages/StorageDistributed.cpp
View File

@ -1006,16 +1006,7 @@ QueryTreeNodePtr buildQueryTreeDistributed(SelectQueryInfo & query_info,
global_in_or_join_node.subquery_depth);
temporary_table_expression_node->setAlias(join_right_table_expression->getAlias());
auto in_second_argument_query_node = std::make_shared<QueryNode>(Context::createCopy(query_context));
in_second_argument_query_node->setIsSubquery(true);
in_second_argument_query_node->getProjectionNode() = std::make_shared<ListNode>();
in_second_argument_query_node->getProjection().getNodes() = { std::make_shared<MatcherNode>() };
in_second_argument_query_node->getJoinTree() = std::move(temporary_table_expression_node);
QueryAnalysisPass query_analysis_pass;
query_analysis_pass.run(in_second_argument_query_node, query_context);
replacement_map.emplace(join_right_table_expression.get(), std::move(in_second_argument_query_node));
replacement_map.emplace(join_right_table_expression.get(), std::move(temporary_table_expression_node));
continue;
}
else if (auto * in_function_node = global_in_or_join_node.query_node->as<FunctionNode>())