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

Fix 01293_system_distribution_queue flakiness

Browse Source
This commit is contained in:
Azat Khuzhin 2021-02-16 10:05:56 +03:00
parent 9a4f469a38
commit a57c646467
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/queries/0_stateless/01293_system_distribution_queue.sql
View File

@ -10,15 +10,15 @@ select * from system.distribution_queue;
select 'INSERT'; select 'INSERT';
system stop distributed sends dist_01293; system stop distributed sends dist_01293;
insert into dist_01293 select * from numbers(10); insert into dist_01293 select * from numbers(10);
select is_blocked, error_count, data_files, data_compressed_bytes>100 from system.distribution_queue; select is_blocked, error_count, data_files, data_compressed_bytes>100 from system.distribution_queue where database = currentDatabase();
system flush distributed dist_01293; system flush distributed dist_01293;
select 'FLUSH'; select 'FLUSH';
select is_blocked, error_count, data_files, data_compressed_bytes from system.distribution_queue; select is_blocked, error_count, data_files, data_compressed_bytes from system.distribution_queue where database = currentDatabase();
select 'UNBLOCK'; select 'UNBLOCK';
system start distributed sends dist_01293; system start distributed sends dist_01293;
select is_blocked, error_count, data_files, data_compressed_bytes from system.distribution_queue; select is_blocked, error_count, data_files, data_compressed_bytes from system.distribution_queue where database = currentDatabase();
drop table null_01293; drop table null_01293;
drop table dist_01293; drop table dist_01293;