diff --git a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java index cf9274d69106c..73f25b1615fcb 100644 --- a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java +++ b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java @@ -98,8 +98,9 @@ public HiveSyncConfig(Properties props) { public HiveSyncConfig(Properties props, Configuration hadoopConf) { super(props, hadoopConf); - HiveConf hiveConf = hadoopConf instanceof HiveConf - ? (HiveConf) hadoopConf : new HiveConf(hadoopConf, HiveConf.class); + HiveConf hiveConf = new HiveConf(); + // HiveConf needs to load Hadoop conf to allow instantiation via AWSGlueClientFactory + hiveConf.addResource(hadoopConf); setHadoopConf(hiveConf); validateParameters(); }