From 9808553a8b2c064cdc3aaae1ac335125501eb2d5 Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Tue, 30 Dec 2025 17:23:26 +0800
Subject: [PATCH] improve msg when host invalid

---
 .../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 f6a222178..f9aad4ffd 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 @@ private static List<BackendRowV2> convert(List<String> feNodeList) {
         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;