This is an automated email from the ASF dual-hosted git repository.

asf-gitbox-commits pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git


The following commit(s) were added to refs/heads/master by this push:
     new db0812667 Reduce replication factor to stablize tests
db0812667 is described below

commit db081266725caa3086f65da385f8a359a779fcb3
Author: Junkai Xue <[email protected]>
AuthorDate: Sat Apr 25 22:25:01 2026 -0700

    Reduce replication factor to stablize tests
---
 .../DelayedAutoRebalancer/TestDelayedAutoRebalance.java           | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/helix-core/src/test/java/org/apache/helix/integration/rebalancer/DelayedAutoRebalancer/TestDelayedAutoRebalance.java
 
b/helix-core/src/test/java/org/apache/helix/integration/rebalancer/DelayedAutoRebalancer/TestDelayedAutoRebalance.java
index d5e823950..d7d3ff644 100644
--- 
a/helix-core/src/test/java/org/apache/helix/integration/rebalancer/DelayedAutoRebalancer/TestDelayedAutoRebalance.java
+++ 
b/helix-core/src/test/java/org/apache/helix/integration/rebalancer/DelayedAutoRebalancer/TestDelayedAutoRebalance.java
@@ -47,9 +47,9 @@ import org.testng.annotations.BeforeMethod;
 import org.testng.annotations.Test;
 
 public class TestDelayedAutoRebalance extends ZkTestBase {
-  static final int NUM_NODE = 5;
+  static final int NUM_NODE = 3;
   protected static final int START_PORT = 12918;
-  protected static final int PARTITIONS = 5;
+  protected static final int PARTITIONS = 3;
   // TODO: remove this wait time once we have a better way to determine if the 
rebalance has been
   // TODO: done as a reaction of the test operations.
   protected static final int DEFAULT_REBALANCE_PROCESSING_WAIT_TIME = 
TestHelper.DEFAULT_REBALANCE_PROCESSING_WAIT_TIME;
@@ -61,7 +61,7 @@ public class TestDelayedAutoRebalance extends ZkTestBase {
   protected ClusterControllerManager _controller;
 
   protected List<MockParticipantManager> _participants = new ArrayList<>();
-  protected int _replica = 3;
+  protected int _replica = 2;
   protected int _minActiveReplica = _replica - 1;
   protected ZkHelixClusterVerifier _clusterVerifier;
   protected List<String> _testDBs = new ArrayList<>();
@@ -135,7 +135,7 @@ public class TestDelayedAutoRebalance extends ZkTestBase {
     validateDelayedMovements(externalViewsBefore);
 
     // bring down another node, the minimal active replica for each partition 
should be maintained.
-    _participants.get(3).syncStop();
+    _participants.get(2).syncStop();
     Assert.assertTrue(_clusterVerifier.verifyByPolling());
     for (String db : _testDBs) {
       ExternalView ev =

Reply via email to