This is an automated email from the ASF dual-hosted git repository.
nodece pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new f26e3bac7d4 [fix][test] Relax BrokerRegistryIntegrationTest
broker-close threshold (#25562)
f26e3bac7d4 is described below
commit f26e3bac7d44c9c16bc0eb7f4b2720d763cf7eb1
Author: Matteo Merli <[email protected]>
AuthorDate: Wed Apr 22 03:28:49 2026 -0700
[fix][test] Relax BrokerRegistryIntegrationTest broker-close threshold
(#25562)
---
.../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 683067486f2..80e54278d31 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");
}
}