eanble login with kerberos for hive

apache · May 23, 2024 · 166c226 · 166c226
1 parent c3ac953
commit 166c226
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...rc/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java b/...rc/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java
@@ -56,9 +56,11 @@ private HiveMetaStoreProxy(ReadonlyConfig readonlyConfig) {
                 hiveConf.addResource(new File(hiveSitePath).toURI().toURL());
             }
             if (HiveMetaStoreProxyUtils.enableKerberos(readonlyConfig)) {
+                Configuration hadoopConfig = new Configuration();
+                hadoopConfig.set("hadoop.security.authentication", "kerberos");
                 this.hiveMetaStoreClient =
                         HadoopLoginFactory.loginWithKerberos(
-                                new Configuration(),
+                                hadoopConfig,
                                 readonlyConfig.get(BaseSourceConfigOptions.KRB5_PATH),
                                 readonlyConfig.get(BaseSourceConfigOptions.KERBEROS_PRINCIPAL),
                                 readonlyConfig.get(BaseSourceConfigOptions.KERBEROS_KEYTAB_PATH),