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

Done

Browse Source
This commit is contained in:
Nikita Mikhaylov 2022-12-27 17:03:57 +00:00
parent 1cb7d4e46e
commit ce6264b684
2 changed files with 29 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration/runner
View File

@ -413,11 +413,11 @@ if __name__ == "__main__":
subprocess.check_call(f"docker kill {' '.join(containers)}", shell=True)
print(f"Containers {containers} killed")
# Avoid overlaps with previous runs
subprocess.check_call("dmesg --clear", shell=True)
# # Avoid overlaps with previous runs
# subprocess.check_call("dmesg --clear", shell=True)
print(("Running pytest container as: '" + cmd + "'."))
subprocess.check_call(cmd, shell=True)
# Dump dmesg (to capture possible OOMs)
subprocess.check_call("dmesg -T", shell=True)
# # Dump dmesg (to capture possible OOMs)
# subprocess.check_call("dmesg -T", shell=True)

33
tests/integration/test_keeper_multinode_simple/test.py
View File

@ -63,6 +63,10 @@ def test_read_write_multinode(started_cluster):
node2_zk = get_fake_zk("node2")
node3_zk = get_fake_zk("node3")
# Cleanup
if node1_zk.exists("/test_read_write_multinode_node1") != None:
node1_zk.delete("/test_read_write_multinode_node1")
node1_zk.create("/test_read_write_multinode_node1", b"somedata1")
node2_zk.create("/test_read_write_multinode_node2", b"somedata2")
node3_zk.create("/test_read_write_multinode_node3", b"somedata3")
@ -105,6 +109,10 @@ def test_watch_on_follower(started_cluster):
node2_zk = get_fake_zk("node2")
node3_zk = get_fake_zk("node3")
# Cleanup
if node1_zk.exists("/test_data_watches") != None:
node1_zk.delete("/test_data_watches")
node1_zk.create("/test_data_watches")
node2_zk.set("/test_data_watches", b"hello")
node3_zk.set("/test_data_watches", b"world")
@ -163,6 +171,10 @@ def test_session_expiration(started_cluster):
node3_zk = get_fake_zk("node3", timeout=3.0)
print("Node3 session id", node3_zk._session_id)
# Cleanup
if node3_zk.exists("/test_ephemeral_node") != None:
node3_zk.delete("/test_ephemeral_node")
node3_zk.create("/test_ephemeral_node", b"world", ephemeral=True)
with PartitionManager() as pm:
@ -201,13 +213,18 @@ def test_follower_restart(started_cluster):
try:
wait_nodes()
node1_zk = get_fake_zk("node1")
node1_zk.create("/test_restart_node", b"hello")
node3.restart_clickhouse(kill=True)
node3_zk = get_fake_zk("node3")
# Cleanup
if node1_zk.exists("/test_restart_node") != None:
node1_zk.delete("/test_restart_node")
node1_zk.create("/test_restart_node", b"hello")
node3.restart_clickhouse(kill=True)
wait_nodes()
node3_zk = get_fake_zk("node3")
# got data from log
assert node3_zk.get("/test_restart_node")[0] == b"hello"
@ -225,11 +242,11 @@ def test_follower_restart(started_cluster):
def test_simple_replicated_table(started_cluster):
wait_nodes()
for i, node in enumerate([node1, node2, node3]):
node.query("DROP TABLE IF EXISTS t SYNC")
node.query(
"CREATE TABLE t (value UInt64) ENGINE = ReplicatedMergeTree('/clickhouse/t', '{}') ORDER BY tuple()".format(
i + 1
)
f"CREATE TABLE t (value UInt64) ENGINE = ReplicatedMergeTree('/clickhouse/t', '{i + 1}') ORDER BY tuple()"
)
node2.query("INSERT INTO t SELECT number FROM numbers(10)")