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 <[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");
}
}