You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by di...@apache.org on 2026/01/05 11:12:12 UTC
(doris-flink-connector) branch master updated: [Chore] improve error msg when host invalid (#629)
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 11080a6a [Chore] improve error msg when host invalid (#629)
11080a6a is described below
commit 11080a6a085b292f16c56f25f86beccd3dba7f86
Author: wudi <67...@qq.com>
AuthorDate: Mon Jan 5 19:12:07 2026 +0800
[Chore] improve error msg when host invalid (#629)
---
.../src/main/java/org/apache/doris/flink/rest/RestService.java | 2 ++
1 file changed, 2 insertions(+)
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 f6a22217..f9aad4ff 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
@@ -362,6 +362,8 @@ public class RestService implements Serializable {
List<BackendRowV2> nodeList = new ArrayList<>();
for (String node : feNodeList) {
String[] split = node.split(":");
+ Preconditions.checkArgument(
+ split.length == 2, "Invalid format: %s, Expected [host:port]", node);
nodeList.add(BackendRowV2.of(split[0], Integer.valueOf(split[1]), true));
}
return nodeList;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org