(seatunnel) branch dev updated: [Fix][Connector-V2] Fix hive krb5 path not work (#8228)

[wuchunfu]

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

wuchunfu 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 e18a4d07b4 [Fix][Connector-V2] Fix hive krb5 path not work (#8228)
e18a4d07b4 is described below

commit e18a4d07b4307087fc225eeb560e69fe52b2b596
Author: Jia Fan <fanjiaemi...@qq.com>
AuthorDate: Tue Dec 17 16:51:41 2024 +0800

    [Fix][Connector-V2] Fix hive krb5 path not work (#8228)
---
 .../org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java  | 1 +
 .../connectors/seatunnel/hive/source/config/HiveSourceConfig.java      | 3 +++
 2 files changed, 4 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
index 13f48823b2..891ef1ae58 100644
--- 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
+++ 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java
@@ -219,6 +219,7 @@ public class HiveSink
                 .getOptional(HiveOptions.HDFS_SITE_PATH)
                 .ifPresent(hadoopConf::setHdfsSitePath);
         
readonlyConfig.getOptional(HiveOptions.REMOTE_USER).ifPresent(hadoopConf::setRemoteUser);
+        
readonlyConfig.getOptional(HiveOptions.KRB5_PATH).ifPresent(hadoopConf::setKrb5Path);
         readonlyConfig
                 .getOptional(HiveOptions.KERBEROS_PRINCIPAL)
                 .ifPresent(hadoopConf::setKerberosPrincipal);
diff --git 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/config/HiveSourceConfig.java
 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/config/HiveSourceConfig.java
index dd3d9478c1..25f95c2c4e 100644
--- 
a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/config/HiveSourceConfig.java
+++ 
b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/config/HiveSourceConfig.java
@@ -182,6 +182,9 @@ public class HiveSourceConfig implements Serializable {
         readonlyConfig
                 .getOptional(HdfsSourceConfigOptions.HDFS_SITE_PATH)
                 .ifPresent(hadoopConf::setHdfsSitePath);
+        readonlyConfig
+                .getOptional(HdfsSourceConfigOptions.KRB5_PATH)
+                .ifPresent(hadoopConf::setKrb5Path);
         readonlyConfig
                 .getOptional(HdfsSourceConfigOptions.KERBEROS_PRINCIPAL)
                 .ifPresent(hadoopConf::setKerberosPrincipal);