This commit is contained in:
Yatsishin Ilya 2021-07-15 15:49:52 +03:00
parent be9a0a9ca2
commit aa698f6c98

View File

@ -26,6 +26,7 @@ def start_cluster():
def test_mutate_and_upgrade(start_cluster):
for node in [node1, node2]:
node.query("DROP TABLE IF EXISTS mt")
node.query(
"CREATE TABLE mt (EventDate Date, id UInt64) ENGINE ReplicatedMergeTree('/clickhouse/tables/t', '{}') ORDER BY tuple()".format(
node.name))
@ -67,8 +68,13 @@ def test_mutate_and_upgrade(start_cluster):
assert node1.query("SELECT id FROM mt") == "1\n4\n"
assert node2.query("SELECT id FROM mt") == "1\n4\n"
for node in [node1, node2]:
node.query("DROP TABLE mt")
def test_upgrade_while_mutation(start_cluster):
node3.query("DROP TABLE IF EXISTS mt1")
node3.query(
"CREATE TABLE mt1 (EventDate Date, id UInt64) ENGINE ReplicatedMergeTree('/clickhouse/tables/t1', 'node3') ORDER BY tuple()")
@ -86,3 +92,5 @@ def test_upgrade_while_mutation(start_cluster):
# will delete nothing, but previous async mutation will finish with this query
assert_eq_with_retry(node3, "SELECT COUNT() from mt1", "50000\n")
node3.query("DROP TABLE mt1")