thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 17:12:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix typo

Browse Source
This commit is contained in:
Yatsishin Ilya 2023-07-07 11:05:42 +00:00
parent aac8eda40a
commit 50bda59a0d
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
tests/integration/test_s3_zero_copy_replication/test.py
View File

@ -48,7 +48,7 @@ def get_large_objects_count(cluster, size=100, folder="data"):
return counter
def check_objects_exisis(cluster, object_list, folder="data"):
def check_objects_exist(cluster, object_list, folder="data"):
minio = cluster.minio_client
for obj in object_list:
if obj:
@ -466,7 +466,7 @@ def s3_zero_copy_unfreeze_base(cluster, unfreeze_query_template):
assert objects01 == objects02
check_objects_exisis(cluster, objects01)
check_objects_exist(cluster, objects01)
node1.query("TRUNCATE TABLE unfreeze_test")
node2.query("SYSTEM SYNC REPLICA unfreeze_test", timeout=30)
@ -477,12 +477,12 @@ def s3_zero_copy_unfreeze_base(cluster, unfreeze_query_template):
assert objects01 == objects11
assert objects01 == objects12
check_objects_exisis(cluster, objects11)
check_objects_exist(cluster, objects11)
node1.query(f"{unfreeze_query_template} 'freeze_backup1'")
wait_mutations(node1, "unfreeze_test", 10)
check_objects_exisis(cluster, objects12)
check_objects_exist(cluster, objects12)
node2.query(f"{unfreeze_query_template} 'freeze_backup2'")
wait_mutations(node2, "unfreeze_test", 10)
@ -540,8 +540,8 @@ def s3_zero_copy_drop_detached(cluster, unfreeze_query_template):
wait_mutations(node1, "drop_detached_test", 10)
wait_mutations(node2, "drop_detached_test", 10)
check_objects_exisis(cluster, objects1)
check_objects_exisis(cluster, objects2)
check_objects_exist(cluster, objects1)
check_objects_exist(cluster, objects2)
node2.query(
"ALTER TABLE drop_detached_test DROP DETACHED PARTITION '1'",
@ -551,8 +551,8 @@ def s3_zero_copy_drop_detached(cluster, unfreeze_query_template):
wait_mutations(node1, "drop_detached_test", 10)
wait_mutations(node2, "drop_detached_test", 10)
check_objects_exisis(cluster, objects1)
check_objects_exisis(cluster, objects2)
check_objects_exist(cluster, objects1)
check_objects_exist(cluster, objects2)
node1.query(
"ALTER TABLE drop_detached_test DROP DETACHED PARTITION '1'",
@ -562,7 +562,7 @@ def s3_zero_copy_drop_detached(cluster, unfreeze_query_template):
wait_mutations(node1, "drop_detached_test", 10)
wait_mutations(node2, "drop_detached_test", 10)
check_objects_exisis(cluster, objects1)
check_objects_exist(cluster, objects1)
check_objects_not_exisis(cluster, objects_diff)
node1.query(
@ -573,7 +573,7 @@ def s3_zero_copy_drop_detached(cluster, unfreeze_query_template):
wait_mutations(node1, "drop_detached_test", 10)
wait_mutations(node2, "drop_detached_test", 10)
check_objects_exisis(cluster, objects1)
check_objects_exist(cluster, objects1)
node2.query(
"ALTER TABLE drop_detached_test DROP DETACHED PARTITION '0'",
@ -682,7 +682,7 @@ def test_s3_zero_copy_keeps_data_after_mutation(started_cluster):
wait_for_active_parts(node2, 4, "zero_copy_mutation")
objects1 = node1.get_table_objects("zero_copy_mutation")
check_objects_exisis(cluster, objects1)
check_objects_exist(cluster, objects1)
node1.query(
"""
@ -710,7 +710,7 @@ def test_s3_zero_copy_keeps_data_after_mutation(started_cluster):
nodeY = node2
objectsY = nodeY.get_table_objects("zero_copy_mutation")
check_objects_exisis(cluster, objectsY)
check_objects_exist(cluster, objectsY)
nodeX.query(
"""
@ -745,7 +745,7 @@ def test_s3_zero_copy_keeps_data_after_mutation(started_cluster):
"""
)
check_objects_exisis(cluster, objectsY)
check_objects_exist(cluster, objectsY)
nodeY.query(
"""