This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new b04a075195f [fix](fe ut) make colcoate test wait time longer (#26999)
(#28628)
b04a075195f is described below
commit b04a075195f6861bfd760e1a2193abfe0f0bdda1
Author: yujun <[email protected]>
AuthorDate: Fri Dec 29 10:18:23 2023 +0800
[fix](fe ut) make colcoate test wait time longer (#26999) (#28628)
---
.../doris/clone/ColocateTableCheckerAndBalancerPerfTest.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/clone/ColocateTableCheckerAndBalancerPerfTest.java
b/fe/fe-core/src/test/java/org/apache/doris/clone/ColocateTableCheckerAndBalancerPerfTest.java
index 56ac9b192b8..3c6fe178b13 100644
---
a/fe/fe-core/src/test/java/org/apache/doris/clone/ColocateTableCheckerAndBalancerPerfTest.java
+++
b/fe/fe-core/src/test/java/org/apache/doris/clone/ColocateTableCheckerAndBalancerPerfTest.java
@@ -59,7 +59,7 @@ public class ColocateTableCheckerAndBalancerPerfTest {
FeConstants.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)));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
