This is an automated email from the ASF dual-hosted git repository.
zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 3305d6d127 [Improvement-13804] Optimal HDFS configuration acquisition
(#13804) (#13811)
3305d6d127 is described below
commit 3305d6d1278f465a22e7ea5c9c4e5abfb1c8de88
Author: zhaifengbing <[email protected]>
AuthorDate: Thu Apr 20 14:24:22 2023 +0800
[Improvement-13804] Optimal HDFS configuration acquisition (#13804) (#13811)
defaultFS key from FS_DEFAULT_FS to HDFS_DEFAULT_FS
---
.../dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 d512d0571f..ba5b3601f3 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 class HdfsStorageOperator implements Closeable,
StorageOperate {
* @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;
}