diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java index 36a9bd790..e2c6d6043 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java @@ -92,7 +92,7 @@ public class UtilHelpers { */ public static DFSPropertiesConfiguration readConfig(FileSystem fs, Path cfgPath, List overriddenProps) { try { - DFSPropertiesConfiguration conf = new DFSPropertiesConfiguration(fs, cfgPath); + DFSPropertiesConfiguration conf = new DFSPropertiesConfiguration(cfgPath.getFileSystem(fs.getConf()), cfgPath); if (!overriddenProps.isEmpty()) { logger.info("Adding overridden properties to file properties."); conf.addProperties(new BufferedReader(new StringReader(String.join("\n", overriddenProps))));