(seatunnel) branch dev updated: [Fix][Connector-V2] Fix iceberg throw java: package sun.security.krb5 does not exist when use jdk 11 (#7734)

[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 116af4febc [Fix][Connector-V2] Fix iceberg throw java: package 
sun.security.krb5 does not exist when use jdk 11 (#7734)
116af4febc is described below

commit 116af4febc0b4804143818042e7cdd96d7948c9f
Author: Xiaojian Sun <sunxiaojian...@163.com>
AuthorDate: Thu Sep 26 14:49:35 2024 +0800

    [Fix][Connector-V2] Fix iceberg throw java: package sun.security.krb5 does 
not exist when use jdk 11 (#7734)
---
 .../seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java
 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java
index bbb590502c..58d6a6ba2d 100644
--- 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java
+++ 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java
@@ -33,7 +33,6 @@ import org.apache.iceberg.common.DynClasses;
 import org.apache.iceberg.common.DynMethods;
 
 import lombok.extern.slf4j.Slf4j;
-import sun.security.krb5.KrbException;
 
 import java.io.IOException;
 import java.io.Serializable;
@@ -170,11 +169,10 @@ public class IcebergCatalogLoader implements Serializable 
{
                         "Start Kerberos authentication using principal {} and 
keytab {}",
                         principal,
                         keytabPath);
-                sun.security.krb5.Config.refresh();
                 UserGroupInformation.loginUserFromKeytab(principal, 
keytabPath);
                 UserGroupInformation loginUser = 
UserGroupInformation.getLoginUser();
                 log.info("Kerberos authentication successful,UGI {}", 
loginUser);
-            } catch (IOException | KrbException e) {
+            } catch (IOException e) {
                 throw new SeaTunnelException("check connectivity failed, " + 
e.getMessage(), e);
             }
         }