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

fix

Browse Source
This commit is contained in:
Yatsishin Ilya 2021-11-11 16:28:50 +03:00
parent 9345b93486
commit d6048f0c18
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/integration/test_keeper_three_nodes_two_alive/test.py
View File

@ -53,9 +53,11 @@ def test_start_offline(started_cluster):
assert node3.contains_in_log("Cannot connect to ZooKeeper (or Keeper) before internal Keeper start") assert node3.contains_in_log("Cannot connect to ZooKeeper (or Keeper) before internal Keeper start")
node2_zk = get_fake_zk("node2") node2_zk = get_fake_zk("node2")
node2_zk.create("/test_dead", b"data") node2_zk.create("/c", b"data")
finally: finally:
p.map(start, [node1, node2, node3]) p.map(start, [node1, node2, node3])
get_fake_zk("node1").delete("/test_alive")
def test_start_non_existing(started_cluster): def test_start_non_existing(started_cluster):
@ -80,6 +82,8 @@ def test_start_non_existing(started_cluster):
node1.replace_in_config('/etc/clickhouse-server/config.d/enable_keeper1.xml', 'non_existing_node', 'node3') node1.replace_in_config('/etc/clickhouse-server/config.d/enable_keeper1.xml', 'non_existing_node', 'node3')
node2.replace_in_config('/etc/clickhouse-server/config.d/enable_keeper2.xml', 'non_existing_node', 'node3') node2.replace_in_config('/etc/clickhouse-server/config.d/enable_keeper2.xml', 'non_existing_node', 'node3')
p.map(start, [node1, node2, node3]) p.map(start, [node1, node2, node3])
node2_zk.delete("/test_non_exising")
def test_restart_third_node(started_cluster): def test_restart_third_node(started_cluster):
node1_zk = get_fake_zk("node1") node1_zk = get_fake_zk("node1")
@ -88,3 +92,4 @@ def test_restart_third_node(started_cluster):
node3.restart_clickhouse() node3.restart_clickhouse()
assert node3.contains_in_log("Connected to ZooKeeper (or Keeper) before internal Keeper start") assert node3.contains_in_log("Connected to ZooKeeper (or Keeper) before internal Keeper start")
node1_zk.delete("/test_restart")