database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](fe ut) make colcoate test wait time longer (#26999)

Browse Source
This commit is contained in:
yujun
2023-11-15 08:18:48 +08:00
committed by GitHub
parent add160b768
commit 82a88366f1
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
fe/fe-core/src/test/java/org/apache/doris/clone/ColocateTableCheckerAndBalancerPerfTest.java
View File

@ -59,7 +59,7 @@ public class ColocateTableCheckerAndBalancerPerfTest {
Config.tablet_schedule_interval_ms = 100;
Config.enable_round_robin_create_tablet = false;
Config.disable_balance = true;
Config.schedule_batch_size = 400;
Config.schedule_batch_size = 500;
Config.schedule_slot_num_per_hdd_path = 1000;
Config.disable_colocate_balance = true;
Config.disable_tablet_scheduler = true;
@ -127,7 +127,7 @@ public class ColocateTableCheckerAndBalancerPerfTest {
ColocateTableIndex colocateIndex = env.getColocateTableIndex();
Set<GroupId> groupIds = colocateIndex.getAllGroupIds();
RebalancerTestUtil.updateReplicaDataSize(100L << 10, 10, 10);
RebalancerTestUtil.updateReplicaDataSize(1L << 10, 10, 10);
RebalancerTestUtil.updateReplicaPathHash();
BalanceStatistic beforeBalanceStatistic = BalanceStatistic.getCurrentBalanceStatistic();
@ -146,7 +146,12 @@ public class ColocateTableCheckerAndBalancerPerfTest {
backends.get(i).setTagMap(tagMap);
}
Config.disable_colocate_balance = false;
Thread.sleep(1000);
for (int i = 0; i < 10; i++) {
Thread.sleep(1000);
if (groupIds.stream().allMatch(groupId -> colocateIndex.isGroupUnstable(groupId))) {
break;
}
}
Assert.assertTrue("some groups are stable",
groupIds.stream().allMatch(groupId -> colocateIndex.isGroupUnstable(groupId)));