diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java index 0cb77d3e2..99ca0a4f5 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java @@ -246,7 +246,7 @@ protected String queryFenodes() { ResultSetMetaData metaData = resultSet.getMetaData(); for (int i = 1; i <= metaData.getColumnCount(); i++) { String columnName = metaData.getColumnName(i); - if(columnName.equalsIgnoreCase("IP") || columnName.equalsIgnoreCase("Host")){ + if (columnName.equalsIgnoreCase("IP") || columnName.equalsIgnoreCase("Host")) { field = columnName; break; }