Skip to content

Commit bef7607

Browse files
[Improve][Connector-V2] Random pick the starrocks fe address which can be connected (#8898)
1 parent 632be34 commit bef7607

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

Diff for: seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksQueryPlanReadClient.java

+3
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535

3636
import java.nio.charset.StandardCharsets;
3737
import java.util.ArrayList;
38+
import java.util.Collections;
3839
import java.util.HashMap;
3940
import java.util.HashSet;
4041
import java.util.List;
@@ -140,6 +141,8 @@ private Map<String, List<Long>> selectBeForTablet(QueryPlan queryPlan) {
140141
private QueryPlan getQueryPlan(String querySQL, String table) {
141142

142143
List<String> nodeUrls = sourceConfig.getNodeUrls();
144+
// shuffle nodeUrls to ensure support for both random selection and high availability
145+
Collections.shuffle(nodeUrls);
143146
Map<String, Object> bodyMap = new HashMap<>();
144147
bodyMap.put("sql", querySQL);
145148
String body = JsonUtils.toJsonString(bodyMap);

0 commit comments

Comments
 (0)