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

Regression for Distributed-over-Distributed when nested table has only one shard

Browse Source
This commit is contained in:
Azat Khuzhin 2020-04-01 21:38:01 +03:00
parent b441e8a408
commit 1777e2fd6b
2 changed files with 50 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/queries/0_stateless/01223_dist_on_dist.reference
View File

@ -82,3 +82,20 @@ GROUP BY ORDER BY distributed_aggregation_memory_efficient/group_by_two_level_th
0 0
1 1
2 2
COUNT
132
distributed_group_by_no_merge
33
33
33
33
only one shard in nested
66
distributed_group_by_no_merge
33
33
merge()
66
distributed_group_by_no_merge
33
33

36
tests/queries/0_stateless/01223_dist_on_dist.sql
View File

@ -1,6 +1,11 @@
create table if not exists data_01223 (key Int) Engine=Memory(); drop table if exists merge_dist_01223;
create table if not exists dist_layer_01223 as data_01223 Engine=Distributed(test_cluster_two_shards, currentDatabase(), data_01223); drop table if exists dist_01223;
create table if not exists dist_01223 as data_01223 Engine=Distributed(test_cluster_two_shards, currentDatabase(), dist_layer_01223); drop table if exists dist_layer_01223;
drop table if exists data_01223;
create table data_01223 (key Int) Engine=Memory();
create table dist_layer_01223 as data_01223 Engine=Distributed(test_cluster_two_shards, currentDatabase(), data_01223);
create table dist_01223 as data_01223 Engine=Distributed(test_cluster_two_shards, currentDatabase(), dist_layer_01223);
select * from dist_01223; select * from dist_01223;
@ -53,6 +58,31 @@ group_by_two_level_threshold=1,
group_by_two_level_threshold_bytes=1, group_by_two_level_threshold_bytes=1,
distributed_aggregation_memory_efficient=1; distributed_aggregation_memory_efficient=1;
select 'COUNT';
select count() from dist_01223;
select 'distributed_group_by_no_merge';
select count() from dist_01223 settings distributed_group_by_no_merge=1;
drop table dist_01223;
drop table dist_layer_01223;
-- only one shard in nested
select 'only one shard in nested';
create table dist_layer_01223 as data_01223 Engine=Distributed(test_shard_localhost, currentDatabase(), data_01223);
create table dist_01223 as data_01223 Engine=Distributed(test_cluster_two_shards, currentDatabase(), dist_layer_01223);
select count() from dist_01223;
select 'distributed_group_by_no_merge';
select count() from dist_01223 settings distributed_group_by_no_merge=1;
-- wrap with merge()
select 'merge()';
create table merge_dist_01223 as dist_01223 engine=Merge(currentDatabase(), 'dist_01223');
select count() from merge_dist_01223;
select 'distributed_group_by_no_merge';
select count() from merge_dist_01223 settings distributed_group_by_no_merge=1;
drop table merge_dist_01223;
drop table dist_01223; drop table dist_01223;
drop table dist_layer_01223; drop table dist_layer_01223;
drop table data_01223; drop table data_01223;