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

Speedup test

Browse Source
This commit is contained in:
alesapin 2021-05-18 14:46:45 +03:00
parent 0ccc31f6ef
commit 70e3ffc895
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tests/integration/test_jbod_balancer/test.py
View File

@ -92,7 +92,10 @@ def test_jbod_balanced_merge(start_cluster):
node1.query("create table tmp1 as tbl") node1.query("create table tmp1 as tbl")
node1.query("create table tmp2 as tbl") node1.query("create table tmp2 as tbl")
for i in range(200): p = Pool(20)
def task(i):
print("Processing insert {}/{}".format(i, 200))
# around 1k per block # around 1k per block
node1.query( node1.query(
"insert into tbl select randConstant() % 2, randomPrintableASCII(16) from numbers(50)" "insert into tbl select randConstant() % 2, randomPrintableASCII(16) from numbers(50)"
@ -104,6 +107,8 @@ def test_jbod_balanced_merge(start_cluster):
"insert into tmp2 select randConstant() % 2, randomPrintableASCII(16) from numbers(50)" "insert into tmp2 select randConstant() % 2, randomPrintableASCII(16) from numbers(50)"
) )
p.map(task, range(200))
time.sleep(1) time.sleep(1)
check_balance(node1, "tbl") check_balance(node1, "tbl")
@ -151,8 +156,10 @@ def test_replicated_balanced_merge_fetch(start_cluster):
node.query("create table tmp2 as tmp1") node.query("create table tmp2 as tmp1")
node2.query("alter table tbl modify setting always_fetch_merged_part = 1") node2.query("alter table tbl modify setting always_fetch_merged_part = 1")
p = Pool(20)
for i in range(200): def task(i):
print("Processing insert {}/{}".format(i, 200))
# around 1k per block # around 1k per block
node1.query( node1.query(
"insert into tbl select randConstant() % 2, randomPrintableASCII(16) from numbers(50)" "insert into tbl select randConstant() % 2, randomPrintableASCII(16) from numbers(50)"
@ -170,6 +177,8 @@ def test_replicated_balanced_merge_fetch(start_cluster):
"insert into tmp2 select randConstant() % 2, randomPrintableASCII(16) from numbers(50)" "insert into tmp2 select randConstant() % 2, randomPrintableASCII(16) from numbers(50)"
) )
p.map(task, range(200))
node2.query("SYSTEM SYNC REPLICA tbl", timeout=10) node2.query("SYSTEM SYNC REPLICA tbl", timeout=10)
check_balance(node1, "tbl") check_balance(node1, "tbl")