This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 41a9f2fc8895140fbd1d4ce6c1bdee9bcb06c829 Author: pmupkin <399284...@qq.com> AuthorDate: Mon Aug 25 16:53:56 2025 +0800 [fix][client] fix ArrayIndexOutOfBoundsException in SameAuthParamsLookupAutoClusterFailover (#24662) (cherry picked from commit 95dcb583060539bb62cbb9fb1bf5b16aca6f408b) --- .../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 9e96932a696..5e244f70ee0 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 @@ -135,7 +135,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; }