thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #37679 from ClickHouse/fix-keeper-recovery-test

Browse Source 
Fix `test_keeper_force_recovery*` tests
This commit is contained in:
alesapin 2022-06-01 18:45:32 +02:00 committed by GitHub
commit b7e8bbb154
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration/test_keeper_force_recovery/test.py
View File

@ -132,7 +132,17 @@ def test_cluster_recovery(started_cluster):
nodes[0].stop_clickhouse()
add_data(node_zks[1], "/test_force_recovery_extra", "somedataextra")
# we potentially killed the leader node so we give time for election
for _ in range(100):
try:
node_zks[1] = get_fake_zk(nodes[1].name, timeout=30.0)
add_data(node_zks[1], "/test_force_recovery_extra", "somedataextra")
break
except Exception as ex:
time.sleep(0.5)
print(f"Retrying create on {nodes[1].name}, exception {ex}")
else:
raise Exception(f"Failed creating a node on {nodes[1].name}")
for node_zk in node_zks[2:CLUSTER_SIZE]:
wait_and_assert_data(node_zk, "/test_force_recovery_extra", "somedataextra")

12
tests/integration/test_keeper_force_recovery_single_node/test.py
View File

@ -121,7 +121,17 @@ def test_cluster_recovery(started_cluster):
nodes[0].stop_clickhouse()
add_data(node_zks[1], "/test_force_recovery_extra", "somedataextra")
# we potentially killed the leader node so we give time for election
for _ in range(100):
try:
node_zks[1] = get_fake_zk(nodes[1].name, timeout=30.0)
add_data(node_zks[1], "/test_force_recovery_extra", "somedataextra")
break
except Exception as ex:
time.sleep(0.5)
print(f"Retrying create on {nodes[1].name}, exception {ex}")
else:
raise Exception(f"Failed creating a node on {nodes[1].name}")
for node_zk in node_zks[2:CLUSTER_SIZE]:
wait_and_assert_data(node_zk, "/test_force_recovery_extra", "somedataextra")