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

Less parallelism instead

Browse Source
This commit is contained in:
Amos Bird 2022-06-01 23:02:31 +08:00
parent 030fe6e272
commit 139264d881
No known key found for this signature in database
GPG Key ID: 80D430DCBECFEDB4
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -158,10 +158,10 @@ def test_replicated_balanced_merge_fetch(start_cluster):
node.query("create table tmp2 as tmp1")
node2.query("alter table tbl modify setting always_fetch_merged_part = 1")
p = Pool(20)
p = Pool(5)
def task(i):
print("Processing insert {}/{}".format(i, 80))
print("Processing insert {}/{}".format(i, 200))
# around 1k per block
node1.query(
"insert into tbl select randConstant() % 2, randomPrintableASCII(16) from numbers(50)"
@ -181,7 +181,7 @@ def test_replicated_balanced_merge_fetch(start_cluster):
"insert into tmp2 select randConstant() % 2, randomPrintableASCII(16) from numbers(50)"
)
p.map(task, range(80))
p.map(task, range(200))
node2.query("SYSTEM SYNC REPLICA tbl", timeout=10)