This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 5066be6df34 [fix](multicatalog) fix hadoop authenticator not inited 
for existing hms catalog. (#38930)
5066be6df34 is described below

commit 5066be6df34415bf538f8b36006f37af94772405
Author: Qi Chen <kaka11.c...@gmail.com>
AuthorDate: Tue Aug 6 15:34:32 2024 +0800

    [fix](multicatalog) fix hadoop authenticator not inited for existing hms 
catalog. (#38930)
    
    Backport #38475.
    
    Co-authored-by: Yulei-Yang <yulei.yang0...@gmail.com>
---
 .../java/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 a22eacaf1e4..be9bf388adb 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, "");


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to