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;
     }

Reply via email to