(pulsar) branch branch-4.1 updated: [fix][test] Relax BrokerRegistryIntegrationTest broker-close threshold (#25562)

[lh...@apache.org]

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 56bc4a5487c [fix][test] Relax BrokerRegistryIntegrationTest broker-close threshold (#25562)
56bc4a5487c is described below

commit 56bc4a5487c29358022b39230254148852c12fa7
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Wed Apr 22 03:28:49 2026 -0700

    [fix][test] Relax BrokerRegistryIntegrationTest broker-close threshold (#25562)
    
    (cherry picked from commit f26e3bac7d44c9c16bc0eb7f4b2720d763cf7eb1)
---
 .../loadbalance/extensions/BrokerRegistryIntegrationTest.java       | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
index 588b1c7730e..1c9d9a99804 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
@@ -70,7 +70,11 @@ public class BrokerRegistryIntegrationTest {
         if (bk != null) {
             bk.stop();
         }
-        if (elapsedMs > 5000) {
+        // Guard against regressions where the broker hangs on shutdown (e.g. blocked health
+        // checks or stuck registrations). Keep the threshold generous enough to tolerate CI
+        // variability in BrokerRegistryMetadataStoreIntegrationTest, while still catching the
+        // multi-minute hangs this assertion was originally added to detect.
+        if (elapsedMs > 15000) {
             throw new RuntimeException("Broker took " + elapsedMs + "ms to close");
         }
     }