From a57c646467c3567fe944fd8f60b050509ef0b798 Mon Sep 17 00:00:00 2001 From: Azat Khuzhin Date: Tue, 16 Feb 2021 10:05:56 +0300 Subject: [PATCH] Fix 01293_system_distribution_queue flakiness --- .../queries/0_stateless/01293_system_distribution_queue.sql | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/queries/0_stateless/01293_system_distribution_queue.sql b/tests/queries/0_stateless/01293_system_distribution_queue.sql index 7b37e70df9a..dc63dece960 100644 --- a/tests/queries/0_stateless/01293_system_distribution_queue.sql +++ b/tests/queries/0_stateless/01293_system_distribution_queue.sql @@ -10,15 +10,15 @@ select * from system.distribution_queue; select 'INSERT'; system stop distributed sends dist_01293; 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; 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'; 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 dist_01293;