From f269ccbd4a494ef63fb82d7160bfebb4dfacbdf2 Mon Sep 17 00:00:00 2001 From: liyou <103415610+ly109974@users.noreply.github.com> Date: Sat, 6 May 2023 16:59:29 +0800 Subject: [PATCH] [Fix-13989] Fix resource center path validation (#14021) --- .../plugin/storage/hdfs/HdfsStorageOperator.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 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 ba5b3601f3..79b925fd56 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 @@ -473,7 +473,11 @@ public class HdfsStorageOperator implements Closeable, StorageOperate { // TODO: add hdfs prefix getFile List storageEntityList = new ArrayList<>(); try { - FileStatus[] fileStatuses = fs.listStatus(new Path(path)); + Path filePath = new Path(path); + if (!fs.exists(filePath)) { + return storageEntityList; + } + FileStatus[] fileStatuses = fs.listStatus(filePath); // transform FileStatusArray into the StorageEntity List for (FileStatus fileStatus : fileStatuses) { @@ -756,9 +760,10 @@ public class HdfsStorageOperator implements Closeable, StorageOperate { private static final class YarnHAAdminUtils { /** - * get active resourcemanager node + * get active resourcemanager node + * * @param protocol http protocol - * @param rmIds yarn ha ids + * @param rmIds yarn ha ids * @return yarn active node */ public static String getActiveRMName(String protocol, String rmIds) {