thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 09:32:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

minor improvement for test_replicated_fetches_bandwidth

Browse Source
This commit is contained in:
Alexander Tokmakov 2021-11-16 16:02:07 +03:00
parent fe0cbd6036
commit d8a7ffaa65
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -34,7 +34,7 @@ def test_limited_fetch_single_table(start_cluster):
node2.query("SYSTEM STOP FETCHES limited_fetch_table") node2.query("SYSTEM STOP FETCHES limited_fetch_table")
for i in range(5): for i in range(5):
node1.query("INSERT INTO limited_fetch_table SELECT {}, '{}' FROM numbers(300)".format(i, get_random_string(104857))) node1.query("INSERT INTO limited_fetch_table SELECT {}, (select randomPrintableASCII(104857)) FROM numbers(300)".format(i))
n1_net = NetThroughput(node1) n1_net = NetThroughput(node1)
n2_net = NetThroughput(node2) n2_net = NetThroughput(node2)
@ -66,7 +66,7 @@ def test_limited_send_single_table(start_cluster):
node2.query("SYSTEM STOP FETCHES limited_send_table") node2.query("SYSTEM STOP FETCHES limited_send_table")
for i in range(5): for i in range(5):
node1.query("INSERT INTO limited_send_table SELECT {}, '{}' FROM numbers(150)".format(i, get_random_string(104857))) node1.query("INSERT INTO limited_send_table SELECT {}, (select randomPrintableASCII(104857)) FROM numbers(150)".format(i))
n1_net = NetThroughput(node1) n1_net = NetThroughput(node1)
n2_net = NetThroughput(node2) n2_net = NetThroughput(node2)
@ -100,7 +100,7 @@ def test_limited_fetches_for_server(start_cluster):
for j in range(5): for j in range(5):
node3.query(f"SYSTEM STOP FETCHES limited_fetches{j}") node3.query(f"SYSTEM STOP FETCHES limited_fetches{j}")
for i in range(5): for i in range(5):
node1.query("INSERT INTO limited_fetches{} SELECT {}, '{}' FROM numbers(50)".format(j, i, get_random_string(104857))) node1.query("INSERT INTO limited_fetches{} SELECT {}, (select randomPrintableASCII(104857)) FROM numbers(50)".format(j, i))
n1_net = NetThroughput(node1) n1_net = NetThroughput(node1)
n3_net = NetThroughput(node3) n3_net = NetThroughput(node3)
@ -137,7 +137,7 @@ def test_limited_sends_for_server(start_cluster):
for j in range(5): for j in range(5):
node1.query(f"SYSTEM STOP FETCHES limited_sends{j}") node1.query(f"SYSTEM STOP FETCHES limited_sends{j}")
for i in range(5): for i in range(5):
node3.query("INSERT INTO limited_sends{} SELECT {}, '{}' FROM numbers(50)".format(j, i, get_random_string(104857))) node3.query("INSERT INTO limited_sends{} SELECT {}, (select randomPrintableASCII(104857)) FROM numbers(50)".format(j, i))
n1_net = NetThroughput(node1) n1_net = NetThroughput(node1)
n3_net = NetThroughput(node3) n3_net = NetThroughput(node3)
@ -173,7 +173,7 @@ def test_should_execute_fetch(start_cluster):
node2.query("SYSTEM STOP FETCHES should_execute_table") node2.query("SYSTEM STOP FETCHES should_execute_table")
for i in range(3): for i in range(3):
node1.query("INSERT INTO should_execute_table SELECT {}, '{}' FROM numbers(200)".format(i, get_random_string(104857))) node1.query("INSERT INTO should_execute_table SELECT {}, (select randomPrintableASCII(104857)) FROM numbers(200)".format(i))
n1_net = NetThroughput(node1) n1_net = NetThroughput(node1)
n2_net = NetThroughput(node2) n2_net = NetThroughput(node2)
@ -181,7 +181,7 @@ def test_should_execute_fetch(start_cluster):
node2.query("SYSTEM START FETCHES should_execute_table") node2.query("SYSTEM START FETCHES should_execute_table")
for i in range(10): for i in range(10):
node1.query("INSERT INTO should_execute_table SELECT {}, '{}' FROM numbers(3)".format(i, get_random_string(104857))) node1.query("INSERT INTO should_execute_table SELECT {}, (select randomPrintableASCII(104857)) FROM numbers(3)".format(i))
n2_fetch_speed = [] n2_fetch_speed = []
replication_queue_data = [] replication_queue_data = []