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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
