This is an automated email from the ASF dual-hosted git repository.

gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new d9fd8bf820 [INLONG-11453][SDK] notifyHBControl function array out of 
bounds (#11454)
d9fd8bf820 is described below

commit d9fd8bf820a277903d22fad163801b1678373c88
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Tue Nov 5 11:32:27 2024 +0800

    [INLONG-11453][SDK] notifyHBControl function array out of bounds (#11454)
    
    
    
    Co-authored-by: gosonzhang <gosonzh...@tencent.com>
---
 .../main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java
index abb204517b..c891788465 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java
@@ -770,9 +770,7 @@ public class ClientMgr {
                 logger.info("HBClient:" + item.getKey() + ";" + 
item.getValue());
             }
             boolean isLoadSwitch = false;
-
-            // int smallSize = listData.size() < listHB.size() ? 
listData.size() : listHB.size();
-            int smallSize = 1;
+            int smallSize = Math.min(Math.min(listData.size(), listHB.size()), 
1);
             for (int i = 0; i < smallSize; i++) {
                 if ((listData.get(i).getValue() - listHB.get(i).getValue()) >= 
this.loadThreshold) {
                     isLoadSwitch = true;

Reply via email to