This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit de3eb9df883f75ce4057939009f163e588188fe1 Author: Matteo Merli <[email protected]> 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"); } }
