(pulsar) branch branch-4.1 updated: [fix][test] Extend SameAuthParamsLookupAutoClusterFailoverTest phase timeouts (#25563)

[lhotari]

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

lhotari pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.1 by this push:
     new af41babf75e [fix][test] Extend 
SameAuthParamsLookupAutoClusterFailoverTest phase timeouts (#25563)
af41babf75e is described below

commit af41babf75ee39e0542e8d20ce419193938a45fa
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Wed Apr 22 04:23:53 2026 -0700

    [fix][test] Extend SameAuthParamsLookupAutoClusterFailoverTest phase 
timeouts (#25563)
    
    (cherry picked from commit 43c7ad86ebfc0c7c47f0f6ccc92c5f0aa62177a3)
---
 .../broker/SameAuthParamsLookupAutoClusterFailoverTest.java  | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
index 0a2a74d9a22..755b3edaa3c 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
@@ -63,7 +63,11 @@ public class SameAuthParamsLookupAutoClusterFailoverTest 
extends OneWayReplicato
         };
     }
 
-    @Test(dataProvider = "enabledTls", timeOut = 240 * 1000)
+    // Each state-convergence phase below waits up to 2 minutes. With 3 phases 
plus
+    // cluster startup/teardown, the 240s overall timeout can be tight on slow 
CI agents
+    // (the probe timeout is 3s and recoverThreshold=5, so a single slow probe 
can
+    // stretch a phase to ~30s). Allow 8 minutes overall to match the 
per-phase budget.
+    @Test(dataProvider = "enabledTls", timeOut = 480 * 1000)
     public void testAutoClusterFailover(boolean enabledTls) throws Exception {
         // Start clusters.
         setup();
@@ -116,7 +120,7 @@ public class SameAuthParamsLookupAutoClusterFailoverTest 
extends OneWayReplicato
 
         // Test failover 0 --> 2.
         pulsar1.close();
-        Awaitility.await().atMost(60, TimeUnit.SECONDS).untilAsserted(() -> {
+        Awaitility.await().atMost(120, TimeUnit.SECONDS).untilAsserted(() -> {
             CompletableFuture<Boolean> checkStatesFuture2 = new 
CompletableFuture<>();
             executor.submit(() -> {
                 boolean res = stateArray[0] == PulsarServiceState.Failed;
@@ -133,7 +137,7 @@ public class SameAuthParamsLookupAutoClusterFailoverTest 
extends OneWayReplicato
         executor.execute(() -> {
             urlArray[1] = url2;
         });
-        Awaitility.await().atMost(60, TimeUnit.SECONDS).untilAsserted(() -> {
+        Awaitility.await().atMost(120, TimeUnit.SECONDS).untilAsserted(() -> {
             CompletableFuture<Boolean> checkStatesFuture3 = new 
CompletableFuture<>();
             executor.submit(() -> {
                 boolean res = stateArray[0] == PulsarServiceState.Failed;
@@ -150,7 +154,7 @@ public class SameAuthParamsLookupAutoClusterFailoverTest 
extends OneWayReplicato
         executor.execute(() -> {
             urlArray[0] = url2;
         });
-        Awaitility.await().atMost(60, TimeUnit.SECONDS).untilAsserted(() -> {
+        Awaitility.await().atMost(120, TimeUnit.SECONDS).untilAsserted(() -> {
             CompletableFuture<Boolean> checkStatesFuture4 = new 
CompletableFuture<>();
             executor.submit(() -> {
                 boolean res = stateArray[0] == PulsarServiceState.Healthy;