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;