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;
             }

Reply via email to