This is an automated email from the ASF dual-hosted git repository.
dockerzhang 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 dc5eb894e3 [INLONG-9007][SDK] ClientList out of bounds (#9014)
dc5eb894e3 is described below
commit dc5eb894e31a77e624a910460661c5876fd9d8c3
Author: SCUTking <[email protected]>
AuthorDate: Sat Oct 7 15:52:15 2023 +0800
[INLONG-9007][SDK] ClientList out of bounds (#9014)
---
.../main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 998694de5e..8e1f878591 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
@@ -467,7 +467,7 @@ public class ClientMgr {
int randomId = random.nextInt();
client = clientList.get(randomId % currSize);
if (client != null && client.isActive()) {
- clientId = randomId;
+ clientId = randomId % currSize;
break;
}
maxRetry--;