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