This is an automated email from the ASF dual-hosted git repository.
lhotari 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 95dcb583060 [fix][client] fix ArrayIndexOutOfBoundsException in
SameAuthParamsLookupAutoClusterFailover (#24662)
95dcb583060 is described below
commit 95dcb583060539bb62cbb9fb1bf5b16aca6f408b
Author: pmupkin <[email protected]>
AuthorDate: Mon Aug 25 16:53:56 2025 +0800
[fix][client] fix ArrayIndexOutOfBoundsException in
SameAuthParamsLookupAutoClusterFailover (#24662)
---
.../pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java | 2 +-
.../pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java | 2 +-
2 files changed, 2 insertions(+), 2 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 b39f8135e0e..19859d17d50 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
@@ -113,7 +113,7 @@ public class SameAuthParamsLookupAutoClusterFailoverTest
extends OneWayReplicato
});
Assert.assertTrue(checkStatesFuture1.join());
- // Test failover 0 --> 3.
+ // Test failover 0 --> 2.
pulsar1.close();
Awaitility.await().atMost(60, TimeUnit.SECONDS).untilAsserted(() -> {
CompletableFuture<Boolean> checkStatesFuture2 = new
CompletableFuture<>();
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java
index d71ac095a3b..6286bc0322c 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java
@@ -133,7 +133,7 @@ public class SameAuthParamsLookupAutoClusterFailover
implements ServiceUrlProvid
}
private int findFailoverTo() {
- for (int i = currentPulsarServiceIndex + 1; i <=
pulsarServiceUrlArray.length; i++) {
+ for (int i = currentPulsarServiceIndex + 1; i <
pulsarServiceUrlArray.length; i++) {
if (probeAvailable(i)) {
return i;
}