(seatunnel) branch dev updated: [Improve][Connector-V2] Random pick the starrocks fe address which can be connected (#8898)

[wanghailin]

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

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new bef76078f9 [Improve][Connector-V2] Random pick the starrocks fe 
address which can be connected (#8898)
bef76078f9 is described below

commit bef76078f97ad4c7c2cd9eccf485b9b2d0bf250a
Author: xiaochen <598457...@qq.com>
AuthorDate: Fri Mar 7 20:26:52 2025 +0800

    [Improve][Connector-V2] Random pick the starrocks fe address which can be 
connected (#8898)
---
 .../starrocks/client/source/StarRocksQueryPlanReadClient.java          | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksQueryPlanReadClient.java
 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksQueryPlanReadClient.java
index 6f5741897b..4215f29fb6 100644
--- 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksQueryPlanReadClient.java
+++ 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksQueryPlanReadClient.java
@@ -35,6 +35,7 @@ import lombok.extern.slf4j.Slf4j;
 
 import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -140,6 +141,8 @@ public class StarRocksQueryPlanReadClient {
     private QueryPlan getQueryPlan(String querySQL, String table) {
 
         List<String> nodeUrls = sourceConfig.getNodeUrls();
+        // shuffle nodeUrls to ensure support for both random selection and 
high availability
+        Collections.shuffle(nodeUrls);
         Map<String, Object> bodyMap = new HashMap<>();
         bodyMap.put("sql", querySQL);
         String body = JsonUtils.toJsonString(bodyMap);