This is an automated email from the ASF dual-hosted git repository. diwu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push: new 9d1fb6bc (Fix)[source] Fix the problem of multiple fenodes when flink reads Doris (#416) 9d1fb6bc is described below commit 9d1fb6bcf381a2c58f046914c67a1fa9efa5d967 Author: wudi <676366...@qq.com> AuthorDate: Wed Jul 3 14:34:53 2024 +0800 (Fix)[source] Fix the problem of multiple fenodes when flink reads Doris (#416) --- .../src/main/java/org/apache/doris/flink/rest/RestService.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java index c7304f9d..1dbb1fde 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java @@ -277,8 +277,9 @@ public class RestService implements Serializable { List<String> nodes = Arrays.asList(feNodes.split(",")); Collections.shuffle(nodes); for (String feNode : nodes) { - if (BackendUtil.tryHttpConnection(feNode)) { - return feNode; + String host = feNode.trim(); + if (BackendUtil.tryHttpConnection(host)) { + return host; } } throw new DorisRuntimeException( @@ -548,7 +549,7 @@ public class RestService implements Serializable { String queryPlanUri = String.format( QUERY_PLAN_API, - options.getFenodes(), + randomEndpoint(options.getFenodes(), logger), tableIdentifier[0], tableIdentifier[1]); HttpPost httpPost = new HttpPost(queryPlanUri); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org