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 <[email protected]>
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 <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
