[MINOR] support reading cfg file in another s3 bucket (#914)
This commit is contained in:
@@ -92,7 +92,7 @@ public class UtilHelpers {
|
|||||||
*/
|
*/
|
||||||
public static DFSPropertiesConfiguration readConfig(FileSystem fs, Path cfgPath, List<String> overriddenProps) {
|
public static DFSPropertiesConfiguration readConfig(FileSystem fs, Path cfgPath, List<String> overriddenProps) {
|
||||||
try {
|
try {
|
||||||
DFSPropertiesConfiguration conf = new DFSPropertiesConfiguration(fs, cfgPath);
|
DFSPropertiesConfiguration conf = new DFSPropertiesConfiguration(cfgPath.getFileSystem(fs.getConf()), cfgPath);
|
||||||
if (!overriddenProps.isEmpty()) {
|
if (!overriddenProps.isEmpty()) {
|
||||||
logger.info("Adding overridden properties to file properties.");
|
logger.info("Adding overridden properties to file properties.");
|
||||||
conf.addProperties(new BufferedReader(new StringReader(String.join("\n", overriddenProps))));
|
conf.addProperties(new BufferedReader(new StringReader(String.join("\n", overriddenProps))));
|
||||||
|
|||||||
Reference in New Issue
Block a user