diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/util/DorisDelimiterParser.java b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/util/DorisDelimiterParser.java index 1c804b7ae4..886c85246f 100644 --- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/util/DorisDelimiterParser.java +++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/util/DorisDelimiterParser.java @@ -24,7 +24,7 @@ public class DorisDelimiterParser { private static final String HEX_STRING = "0123456789ABCDEF"; public static String parse(String sp) throws RuntimeException { - if (sp == null || sp.length() == 0) { + if (sp == null || sp.isBlank()) { throw new RuntimeException("Delimiter can't be empty"); } if (!sp.toUpperCase().startsWith("\\X")) {