From acaa87cd759ea2d798bdd9fb8a3041942e50adf2 Mon Sep 17 00:00:00 2001 From: zhaifb Date: Thu, 20 Apr 2023 09:39:52 +0800 Subject: [PATCH] [Improvement-13804] Optimal HDFS configuration acquisition (#13804) 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 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; }