thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 10:02:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #52432 from amosbird/fix_52405

Browse Source 
Fix normal projection with merge table
This commit is contained in:
Alexey Milovidov 2023-07-23 18:27:51 +03:00 committed by GitHub
commit e3c85613c9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Processors/QueryPlan/Optimizations/optimizeUseNormalProjection.cpp
View File

@ -92,6 +92,10 @@ bool optimizeUseNormalProjections(Stack & stack, QueryPlan::Nodes & nodes)
break;
}
/// Dangling query plan node. This might be generated by StorageMerge.
if (iter->node->step.get() == reading)
return false;
const auto metadata = reading->getStorageMetadata();
const auto & projections = metadata->projections;
@ -105,8 +109,8 @@ bool optimizeUseNormalProjections(Stack & stack, QueryPlan::Nodes & nodes)
QueryDAG query;
{
auto & clild = iter->node->children[iter->next_child - 1];
if (!query.build(*clild))
auto & child = iter->node->children[iter->next_child - 1];
if (!query.build(*child))
return false;
if (query.dag)

1
tests/queries/0_stateless/01710_projection_query_plan_optimization_misc.reference Normal file
View File

@ -0,0 +1 @@
1 2

11
tests/queries/0_stateless/01710_projection_query_plan_optimization_misc.sql Normal file
View File

@ -0,0 +1,11 @@
drop table if exists t;
create table t (x Int32, codectest Int32) engine = MergeTree order by x;
alter table t add projection x (select * order by codectest);
insert into t values (1, 2);
select * from merge('', 't');
drop table t;