From 5066be6df34415bf538f8b36006f37af94772405 Mon Sep 17 00:00:00 2001 From: Qi Chen Date: Tue, 6 Aug 2024 15:34:32 +0800 Subject: [PATCH] [fix](multicatalog) fix hadoop authenticator not inited for existing hms catalog. (#38930) Backport #38475. Co-authored-by: Yulei-Yang --- .../org/apache/doris/datasource/hive/HMSExternalCatalog.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java index a22eacaf1e..be9bf388ad 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java @@ -138,6 +138,11 @@ public class HMSExternalCatalog extends ExternalCatalog { @Override protected void initLocalObjectsImpl() { + if (authenticator == null) { + AuthenticationConfig config = AuthenticationConfig.getKerberosConfig(getConfiguration()); + authenticator = HadoopAuthenticator.getHadoopAuthenticator(config); + } + HiveConf hiveConf = null; JdbcClientConfig jdbcClientConfig = null; String hiveMetastoreType = catalogProperty.getOrDefault(HMSProperties.HIVE_METASTORE_TYPE, "");