diff --git a/tests/queries/0_stateless/03014_async_with_dedup_part_log_rmt.sql b/tests/queries/0_stateless/03014_async_with_dedup_part_log_rmt.sql index e14c1635853..6b441e951e1 100644 --- a/tests/queries/0_stateless/03014_async_with_dedup_part_log_rmt.sql +++ b/tests/queries/0_stateless/03014_async_with_dedup_part_log_rmt.sql @@ -10,7 +10,7 @@ INSERT INTO 03014_async_with_dedup_part_log VALUES (2); SYSTEM FLUSH LOGS; SELECT error, count() FROM system.part_log -WHERE table = '03014_async_with_dedup_part_log' and database = currentDatabase() +WHERE table = '03014_async_with_dedup_part_log' AND database = currentDatabase() AND event_type = 'NewPart' GROUP BY error ORDER BY error; @@ -19,6 +19,6 @@ INSERT INTO 03014_async_with_dedup_part_log VALUES (2); SYSTEM FLUSH LOGS; SELECT error, count() FROM system.part_log -WHERE table = '03014_async_with_dedup_part_log' and database = currentDatabase() +WHERE table = '03014_async_with_dedup_part_log' AND database = currentDatabase() AND event_type = 'NewPart' GROUP BY error ORDER BY error;