[Bug] [connector-hive] Eanble login with kerberos for hive (apache#6893)

--------- Co-authored-by: 李鹏程 <[email protected]>
chaorongzhi · Aug 21, 2024 · 065d8b5 · 065d8b5
1 parent de10d81
commit 065d8b5
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
@@ -81,9 +81,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),