diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java index 1a8cde4d03..e9b17497cf 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java @@ -309,6 +309,7 @@ public class JdbcExternalCatalog extends ExternalCatalog { jdbcTable.setJdbcPasswd(this.getJdbcPasswd()); jdbcTable.setDriverClass(this.getDriverClass()); jdbcTable.setDriverUrl(this.getDriverUrl()); + jdbcTable.setCheckSum(this.getCheckSum()); jdbcTable.setResourceName(this.getResource()); jdbcTable.setConnectionPoolMinSize(this.getConnectionPoolMinSize()); jdbcTable.setConnectionPoolMaxSize(this.getConnectionPoolMaxSize()); diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java index 3865d0b25c..cb0f510022 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java +++ b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java @@ -44,12 +44,6 @@ public abstract class QueryTableValueFunction extends TableValuedFunctionIf { protected final String query; public QueryTableValueFunction(Map params) throws AnalysisException { - if (params.size() != 2) { - throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'"); - } - if (!params.containsKey(CATALOG) || !params.containsKey(QUERY)) { - throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'"); - } String catalogName = params.get(CATALOG); this.query = params.get(QUERY); this.catalogIf = Env.getCurrentEnv().getCatalogMgr().getCatalog(catalogName); @@ -57,6 +51,12 @@ public abstract class QueryTableValueFunction extends TableValuedFunctionIf { public static QueryTableValueFunction createQueryTableValueFunction(Map params) throws AnalysisException { + if (params.size() != 2) { + throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'"); + } + if (!params.containsKey(CATALOG) || !params.containsKey(QUERY)) { + throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'"); + } String catalogName = params.get(CATALOG); // check priv