(helix) branch master updated: Extending timeout

[jxue]

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 4de69db7e Extending timeout
4de69db7e is described below

commit 4de69db7e5d6c34505baeba09811b96fae4e7e22
Author: Junkai Xue <j...@apache.org>
AuthorDate: Sat May 9 02:15:51 2026 -0700

    Extending timeout
---
 .../helix/integration/manager/TestConsecutiveZkSessionExpiry.java  | 7 +++++--
 .../helix/integration/paticipant/TestStateTransitionTimeout.java   | 2 +-
 .../rebalancer/DelayedAutoRebalancer/TestDelayedAutoRebalance.java | 2 +-
 3 files changed, 7 insertions(+), 4 deletions(-)

diff --git 
a/helix-core/src/test/java/org/apache/helix/integration/manager/TestConsecutiveZkSessionExpiry.java
 
b/helix-core/src/test/java/org/apache/helix/integration/manager/TestConsecutiveZkSessionExpiry.java
index 3d36353fd..27e627964 100644
--- 
a/helix-core/src/test/java/org/apache/helix/integration/manager/TestConsecutiveZkSessionExpiry.java
+++ 
b/helix-core/src/test/java/org/apache/helix/integration/manager/TestConsecutiveZkSessionExpiry.java
@@ -210,6 +210,9 @@ public class TestConsecutiveZkSessionExpiry extends 
ZkUnitTestBase {
     LOG.info("Expried distributedController session. oldSessionId: " + 
oldSessionId
         + ", newSessionId: " + newSessionId);
 
+    // Wait for session to stabilize after first expiry before triggering 
second
+    Thread.sleep(500);
+
     // expire zk session again during HelixManager#handleNewSession()
     startCountdown.await();
     LOG.info("2nd Expiring distributedController session...");
@@ -242,8 +245,8 @@ public class TestConsecutiveZkSessionExpiry extends 
ZkUnitTestBase {
     // This is needed because handler cleanup is async and may take time in CI
     List<CallbackHandler> handlers = null;
     int expectedHandlerCount = 1;
-    int maxWaitTime = 20000;
-    int pollInterval = 200;
+    int maxWaitTime = 30000;
+    int pollInterval = 500;
     long startTime = System.currentTimeMillis();
     while (System.currentTimeMillis() - startTime < maxWaitTime) {
       handlers = distributedControllers[0].getHandlers();
diff --git 
a/helix-core/src/test/java/org/apache/helix/integration/paticipant/TestStateTransitionTimeout.java
 
b/helix-core/src/test/java/org/apache/helix/integration/paticipant/TestStateTransitionTimeout.java
index a727ec06b..0b73ebc0a 100644
--- 
a/helix-core/src/test/java/org/apache/helix/integration/paticipant/TestStateTransitionTimeout.java
+++ 
b/helix-core/src/test/java/org/apache/helix/integration/paticipant/TestStateTransitionTimeout.java
@@ -166,7 +166,7 @@ public class TestStateTransitionTimeout extends 
ZkStandAloneCMTestBase {
     Assert.assertTrue(result);
     HelixDataAccessor accessor = _participants[0].getHelixDataAccessor();
 
-    TestHelper.verify(() -> verify(accessor, idealState, factories), 10000);
+    TestHelper.verify(() -> verify(accessor, idealState, factories), 20000);
     Assert.assertTrue(verify(accessor, idealState, factories));
   }
 
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 d7d3ff644..562149d10 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
@@ -450,7 +450,7 @@ public class TestDelayedAutoRebalance extends ZkTestBase {
     InstanceConfig instanceConfig = 
_configAccessor.getInstanceConfig(CLUSTER_NAME, instance);
     Assert.assertEquals(instanceConfig.getInstanceEnabled(), enabled);
     Assert.assertTrue(instanceConfig.getInstanceEnabledTime() >= currentTime);
-    Assert.assertTrue(instanceConfig.getInstanceEnabledTime() <= currentTime + 
100);
+    Assert.assertTrue(instanceConfig.getInstanceEnabledTime() <= currentTime + 
2000);
   }
 
   protected void validateDelayedMovementsOnDisabledNode(Map<String, 
ExternalView> externalViewsBefore)