From 9a4f469a3880950f6d0ce3bb5708f7af894b585f Mon Sep 17 00:00:00 2001 From: Azat Khuzhin Date: Fri, 29 Jan 2021 07:53:21 +0300 Subject: [PATCH] Fix 00753_distributed_system_columns_and_system_tables flakiness --- .../00753_distributed_system_columns_and_system_tables.sql | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/queries/0_stateless/00753_distributed_system_columns_and_system_tables.sql b/tests/queries/0_stateless/00753_distributed_system_columns_and_system_tables.sql index d5b4cce0dfc..fd9786be011 100644 --- a/tests/queries/0_stateless/00753_distributed_system_columns_and_system_tables.sql +++ b/tests/queries/0_stateless/00753_distributed_system_columns_and_system_tables.sql @@ -2,10 +2,10 @@ SELECT 'Check total_bytes/total_rows for Distributed'; CREATE TABLE check_system_tables_null (key Int) Engine=Null(); CREATE TABLE check_system_tables AS check_system_tables_null Engine=Distributed(test_shard_localhost, currentDatabase(), check_system_tables_null); SYSTEM STOP DISTRIBUTED SENDS check_system_tables; -SELECT total_bytes, total_rows FROM system.tables WHERE name = 'check_system_tables'; +SELECT total_bytes, total_rows FROM system.tables WHERE database = currentDatabase() AND name = 'check_system_tables'; INSERT INTO check_system_tables SELECT * FROM numbers(1) SETTINGS prefer_localhost_replica=0; -SELECT total_bytes>0, total_rows FROM system.tables WHERE name = 'check_system_tables'; +SELECT total_bytes>0, total_rows FROM system.tables WHERE database = currentDatabase() AND name = 'check_system_tables'; SYSTEM FLUSH DISTRIBUTED check_system_tables; -SELECT total_bytes, total_rows FROM system.tables WHERE name = 'check_system_tables'; +SELECT total_bytes, total_rows FROM system.tables WHERE database = currentDatabase() AND name = 'check_system_tables'; DROP TABLE check_system_tables_null; DROP TABLE check_system_tables;