diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java index b4a9bba80e..d06829bc7e 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java @@ -612,10 +612,12 @@ public class ResourcesServiceImpl extends BaseServiceImpl implements ResourcesSe try { if (StringUtils.isBlank(fullName)) { - resourcesList = storageOperate.listFilesStatus(defaultPath, defaultPath, tenantCode, type); - } else { - resourcesList = storageOperate.listFilesStatus(fullName, defaultPath, tenantCode, type); + fullName = defaultPath; } + resourcesList = recursive ? storageOperate.listFilesStatusRecursively(fullName, defaultPath, + tenantCode, type) + : storageOperate.listFilesStatus(fullName, defaultPath, + tenantCode, type); } catch (Exception e) { log.error(e.getMessage() + " Resource path: {}", fullName, e); throw new ServiceException(String.format(e.getMessage() +