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 b3c463d80428..d4d8ca3b7f73 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 @@ 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),