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

Improve parallel_view_processing test

Browse Source
This commit is contained in:
Azat Khuzhin 2021-10-05 22:20:46 +03:00
parent 99ebdbb16e
commit ae5570e6d6
2 changed files with 38 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
tests/queries/0_stateless/01275_parallel_mv.reference
View File

@ -1,4 +1,27 @@
-- { echoOn }
set parallel_view_processing=1;
insert into testX select number from numbers(10) settings log_queries=1; -- { serverError FUNCTION_THROW_IF_VALUE_IS_NON_ZERO }
system flush logs;
select length(thread_ids) from system.query_log where current_database = currentDatabase() and type != 'QueryStart' and query like '%insert into testX %' and Settings['parallel_view_processing'] = '1';
8
select count() from testX;
10
select count() from testXA;
10
select count() from testXB;
0
select count() from testXC;
10
set parallel_view_processing=0;
insert into testX select number from numbers(10) settings log_queries=1; -- { serverError FUNCTION_THROW_IF_VALUE_IS_NON_ZERO }
system flush logs;
select length(thread_ids) from system.query_log where current_database = currentDatabase() and type != 'QueryStart' and query like '%insert into testX %' and Settings['parallel_view_processing'] = '0';
5
select count() from testX;
20
select count() from testXA;
20
select count() from testXB;
0
select count() from testXC;
20

16
tests/queries/0_stateless/01275_parallel_mv.sql
View File

@ -9,14 +9,28 @@ create materialized view testXA engine=MergeTree order by tuple() as select slee
create materialized view testXB engine=MergeTree order by tuple() as select sleep(2), throwIf(A=1) from testX;
create materialized view testXC engine=MergeTree order by tuple() as select sleep(1) from testX;
-- { echoOn }
set parallel_view_processing=1;
insert into testX select number from numbers(10); -- {serverError 395}
insert into testX select number from numbers(10) settings log_queries=1; -- { serverError FUNCTION_THROW_IF_VALUE_IS_NON_ZERO }
system flush logs;
select length(thread_ids) from system.query_log where current_database = currentDatabase() and type != 'QueryStart' and query like '%insert into testX %' and Settings['parallel_view_processing'] = '1';
select count() from testX;
select count() from testXA;
select count() from testXB;
select count() from testXC;
set parallel_view_processing=0;
insert into testX select number from numbers(10) settings log_queries=1; -- { serverError FUNCTION_THROW_IF_VALUE_IS_NON_ZERO }
system flush logs;
select length(thread_ids) from system.query_log where current_database = currentDatabase() and type != 'QueryStart' and query like '%insert into testX %' and Settings['parallel_view_processing'] = '0';
select count() from testX;
select count() from testXA;
select count() from testXB;
select count() from testXC;
-- { echoOff }
drop table testX;
drop view testXA;
drop view testXB;