From 030fe6e2728cd93f26d912376860222b7f7b7978 Mon Sep 17 00:00:00 2001 From: Amos Bird Date: Mon, 30 May 2022 16:53:55 +0800 Subject: [PATCH] Less flaky jbod rebalancer test --- tests/integration/test_jbod_balancer/test.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/tests/integration/test_jbod_balancer/test.py b/tests/integration/test_jbod_balancer/test.py index 3807d6e1cea..0c6a0709971 100644 --- a/tests/integration/test_jbod_balancer/test.py +++ b/tests/integration/test_jbod_balancer/test.py @@ -161,11 +161,13 @@ def test_replicated_balanced_merge_fetch(start_cluster): p = Pool(20) def task(i): - print("Processing insert {}/{}".format(i, 200)) + print("Processing insert {}/{}".format(i, 80)) # around 1k per block node1.query( "insert into tbl select randConstant() % 2, randomPrintableASCII(16) from numbers(50)" ) + + # Fill jbod disks with garbage data node1.query( "insert into tmp1 select randConstant() % 2, randomPrintableASCII(16) from numbers(50)" ) @@ -179,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(200)) + p.map(task, range(80)) node2.query("SYSTEM SYNC REPLICA tbl", timeout=10)