(seatunnel) branch dev updated: [Bug] [connector-hive] Eanble login with kerberos for hive (#6893)

[fanjia]

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

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 26e433e472 [Bug] [connector-hive] Eanble login with kerberos for hive 
(#6893)
26e433e472 is described below

commit 26e433e4721c40b0a7377757c569a3d8cfe94289
Author: JackeyLee007 <jackeylee...@126.com>
AuthorDate: Fri May 31 17:04:02 2024 +0800

    [Bug] [connector-hive] Eanble login with kerberos for hive (#6893)
    
    
    
    ---------
    
    Co-authored-by: 李鹏程 <li...@topsports.com.cn>
---
 .../seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java
 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java
index b3c463d804..d4d8ca3b7f 100644
--- 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java
+++ 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java
@@ -56,9 +56,11 @@ public class HiveMetaStoreProxy {
                 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),