This is an automated email from the ASF dual-hosted git repository. jxue pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/helix.git
commit 45316d1d8fdec396a4a1adfd3bffbd7a0e5fec08 Author: Junkai Xue <[email protected]> AuthorDate: Thu Apr 9 22:36:20 2026 -0700 Extend wait time --- .../WagedRebalancer/TestWagedClusterExpansion.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedClusterExpansion.java b/helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedClusterExpansion.java index fb8ba7ddc..dc7839e1e 100644 --- a/helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedClusterExpansion.java +++ b/helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedClusterExpansion.java @@ -267,7 +267,8 @@ public class TestWagedClusterExpansion extends ZkTestBase { // Check modified time for external view of the first resource. // if pipeline is run, then external view would be persisted. - waitForPipeline(100, 3000); + // Increased timeout for CI stability + waitForPipeline(100, 6000); LOG.info("After adding the new instance"); validateIdealState(false /* afterWeightChange */); @@ -285,11 +286,12 @@ public class TestWagedClusterExpansion extends ZkTestBase { dataAccessor.setProperty(dataAccessor.keyBuilder().resourceConfig(db), resourceConfig); // Make sure pipeline is run. - waitForPipeline(100, 10000); // 10 sec. max timeout. + // Increased timeout for CI stability + waitForPipeline(100, 20000); LOG.info("After changing resource partition weight"); validateIdealState(true /* afterWeightChange */); - waitForPipeline(100, 3000); // this is for ZK to sync up. + waitForPipeline(100, 6000); // this is for ZK to sync up. } // This test case reduces the capacity of one of the instance. @@ -310,11 +312,12 @@ public class TestWagedClusterExpansion extends ZkTestBase { dataAccessor.setProperty(dataAccessor.keyBuilder().instanceConfig(storageNodeName), config); // Make sure pipeline is run. - waitForPipeline(100, 10000); // 10 sec. max timeout. + // Increased timeout for CI stability + waitForPipeline(100, 20000); LOG.info("After changing instance capacity"); validateIdealState(true); - waitForPipeline(100, 3000); // this is for ZK to sync up. + waitForPipeline(100, 6000); // this is for ZK to sync up. } @AfterClass
