From 3305d6d1278f465a22e7ea5c9c4e5abfb1c8de88 Mon Sep 17 00:00:00 2001 From: zhaifengbing Date: Thu, 20 Apr 2023 14:24:22 +0800 Subject: [PATCH] [Improvement-13804] Optimal HDFS configuration acquisition (#13804) (#13811) defaultFS key from FS_DEFAULT_FS to HDFS_DEFAULT_FS --- .../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; }