diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcIdentifierMapping.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcIdentifierMapping.java index 82422518e6..20a74724b3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcIdentifierMapping.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcIdentifierMapping.java @@ -40,6 +40,6 @@ public class JdbcIdentifierMapping extends IdentifierMapping { @Override protected void loadColumnNames(String localDbName, String localTableName) { - jdbcClient.getJdbcColumnsInfo(localDbName, localTableName); + jdbcClient.getColumnsFromJdbc(localDbName, localTableName); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/mapping/IdentifierMapping.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/mapping/IdentifierMapping.java index c42f5fca28..cd121f2b63 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/mapping/IdentifierMapping.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/mapping/IdentifierMapping.java @@ -208,8 +208,7 @@ public abstract class IdentifierMapping { || localColumnToRemoteColumn.get(remoteDbName).isEmpty() || !localColumnToRemoteColumn.get(remoteDbName).containsKey(remoteTableName) || localColumnToRemoteColumn.get(remoteDbName).get(remoteTableName) == null - || localColumnToRemoteColumn.get( - remoteDbName).get(remoteTableName).isEmpty()) { + || localColumnToRemoteColumn.get(remoteDbName).get(remoteTableName).isEmpty()) { loadColumnNamesIfNeeded(localDbName, localTableName); } return localColumnToRemoteColumn.get(remoteDbName).get(remoteTableName);