diff --git a/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java b/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java index d512d0571f83..ba5b3601f348 100644 --- a/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java +++ b/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java @@ -183,9 +183,9 @@ public Configuration getConfiguration() { * @return DefaultFS */ public String getDefaultFS() { - String defaultFS = getConfiguration().get(Constants.FS_DEFAULT_FS); + String defaultFS = hdfsProperties.getDefaultFS(); if (StringUtils.isBlank(defaultFS)) { - defaultFS = hdfsProperties.getDefaultFS(); + defaultFS = getConfiguration().get(Constants.HDFS_DEFAULT_FS); } return defaultFS; }