Merge pull request ClickHouse#78779 from ClickHouse/slightly-better-test

Prevent `test_replicated_database/test.py::test_create_replicated_table` from being flaky

Author: nikitamikhaylov

tests/integration/test_replicated_database/test.py

@@ -94,41 +94,41 @@ def started_cluster():
 
 def test_flatten_nested(started_cluster):
     main_node.query(
-        "CREATE DATABASE create_replicated_table ENGINE = Replicated('/test/create_replicated_table', 'shard1', 'replica' || '1');"
+        "CREATE DATABASE flatten_nested ENGINE = Replicated('/test/flatten_nested', 'shard1', 'replica' || '1');"
     )
     dummy_node.query(
-        "CREATE DATABASE create_replicated_table ENGINE = Replicated('/test/create_replicated_table', 'shard1', 'replica2');"
+        "CREATE DATABASE flatten_nested ENGINE = Replicated('/test/flatten_nested', 'shard1', 'replica2');"
     )
 
     main_node.query(
-        "CREATE TABLE create_replicated_table.replicated_table (d Date, k UInt64, i32 Int32) ENGINE=ReplicatedMergeTree ORDER BY k PARTITION BY toYYYYMM(d);"
+        "CREATE TABLE flatten_nested.replicated_table (d Date, k UInt64, i32 Int32) ENGINE=ReplicatedMergeTree ORDER BY k PARTITION BY toYYYYMM(d);"
     )
 
     main_node.query(
-        "CREATE MATERIALIZED VIEW create_replicated_table.mv ENGINE=ReplicatedMergeTree ORDER BY tuple() AS select d, cast([(k, toString(i32))] as Nested(a UInt64, b String)) from create_replicated_table.replicated_table"
+        "CREATE MATERIALIZED VIEW flatten_nested.mv ENGINE=ReplicatedMergeTree ORDER BY tuple() AS select d, cast([(k, toString(i32))] as Nested(a UInt64, b String)) from flatten_nested.replicated_table"
     )
 
     main_node.query(
-        "CREATE TABLE create_replicated_table.no_flatten (n Nested(a UInt64, b String)) ENGINE=ReplicatedMergeTree ORDER BY tuple();",
+        "CREATE TABLE flatten_nested.no_flatten (n Nested(a UInt64, b String)) ENGINE=ReplicatedMergeTree ORDER BY tuple();",
         settings={"flatten_nested": 0},
     )
 
     snapshot_recovering_node.query(
-        "CREATE DATABASE create_replicated_table ENGINE = Replicated('/test/create_replicated_table', 'shard1', 'replica3');"
+        "CREATE DATABASE flatten_nested ENGINE = Replicated('/test/flatten_nested', 'shard1', 'replica3');"
     )
     snapshot_recovering_node.query(
-        "SYSTEM SYNC DATABASE REPLICA create_replicated_table"
+        "SYSTEM SYNC DATABASE REPLICA flatten_nested"
     )
 
     for node in [dummy_node, snapshot_recovering_node]:
         for table in ["replicated_table", "mv", "no_flatten"]:
             assert main_node.query(
-                f"show create create_replicated_table.{table}"
-            ) == node.query(f"show create create_replicated_table.{table}")
+                f"show create flatten_nested.{table}"
+            ) == node.query(f"show create flatten_nested.{table}")
 
-    main_node.query("DROP DATABASE create_replicated_table SYNC")
-    dummy_node.query("DROP DATABASE create_replicated_table SYNC")
-    snapshot_recovering_node.query("DROP DATABASE create_replicated_table SYNC")
+    main_node.query("DROP DATABASE flatten_nested SYNC")
+    dummy_node.query("DROP DATABASE flatten_nested SYNC")
+    snapshot_recovering_node.query("DROP DATABASE flatten_nested SYNC")
 
 
 def test_create_replicated_table(started_cluster):