Temporary fix for test

This commit is contained in:
Igor Nikonov 2022-12-19 23:11:15 +00:00
parent 1e53b3be38
commit 3ffe73331e
2 changed files with 28 additions and 16 deletions

View File

@ -86,18 +86,19 @@ ExpressionTransform
(ReadFromMergeTree)
MergeTreeInOrder × 4 0 → 1
(ReadFromRemote)
-- set query_plan_remove_redundant_order_by=0; -- disable it temporary
select a, count() from dist_t_different_dbs group by a order by a limit 5 offset 500;
500 2000
501 2000
502 2000
503 2000
504 2000
500 1001
501 1001
502 1001
503 1001
504 1001
select a, count() from dist_t_different_dbs group by a, b order by a limit 5 offset 500;
500 2000
501 2000
502 2000
503 2000
504 2000
500 1001
501 1001
502 1001
503 1001
504 1001
-- { echoOn } --
explain pipeline select a from dist_pr_t group by a order by a limit 5 offset 500;
(Expression)

View File

@ -1,5 +1,13 @@
-- Tags: no-parallel
drop table if exists pr_t;
drop table if exists dist_pr_t;
drop table if exists dist_t_different_dbs;
drop table if exists shard_1.t_different_dbs;
drop table if exists t_different_dbs;
drop table if exists dist_t;
drop table if exists t;
create table t(a UInt64, b UInt64) engine=MergeTree order by a;
system stop merges t;
insert into t select number, number from numbers_mt(1e6);
@ -43,8 +51,10 @@ create table dist_t_different_dbs as t engine = Distributed(test_cluster_two_sha
-- { echoOn } --
explain pipeline select a, count() from dist_t_different_dbs group by a order by a limit 5 offset 500;
set query_plan_remove_redundant_order_by=0; -- disable it temporary
select a, count() from dist_t_different_dbs group by a order by a limit 5 offset 500;
select a, count() from dist_t_different_dbs group by a, b order by a limit 5 offset 500;
set query_plan_remove_redundant_order_by=1; -- enable back
-- { echoOff } --
@ -64,9 +74,10 @@ select a, count() from dist_pr_t group by a, b order by a limit 5 offset 500;
-- { echoOff } --
drop table dist_pr_t;
drop table dist_t_different_dbs;
drop table shard_1.t_different_dbs;
drop table t_different_dbs;
drop table dist_t;
drop table t;
-- drop table if exists pr_t;
-- drop table dist_pr_t;
-- drop table dist_t_different_dbs;
-- drop table shard_1.t_different_dbs;
-- drop table t_different_dbs;
-- drop table dist_t;
-- drop table t;