(incubator-streampark) branch dev-2.1.3 updated: [Improve] project conf path improvement

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 67fc977b6 [Improve] project conf path improvement
67fc977b6 is described below

commit 67fc977b62d2d08fc24e96685d0ec6c435f4b1fd
Author: benjobs <benj...@gmail.com>
AuthorDate: Wed Jan 24 13:38:03 2024 +0800

    [Improve] project conf path improvement
---
 .../streampark/console/core/service/impl/ProjectServiceImpl.java  | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
index 7ce20d25a..931dd712f 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
@@ -269,10 +269,12 @@ public class ProjectServiceImpl extends 
ServiceImpl<ProjectMapper, Project>
   public String getAppConfPath(Long id, String module) {
     Project project = getById(id);
     File appHome = project.getDistHome();
+    File[] files = appHome.listFiles();
+    if (!appHome.exists() || files == null) {
+      return null;
+    }
     Optional<File> fileOptional =
-        Arrays.stream(Objects.requireNonNull(appHome.listFiles()))
-            .filter((x) -> x.getName().equals(module))
-            .findFirst();
+        Arrays.stream(files).filter((x) -> 
x.getName().equals(module)).findFirst();
     return fileOptional.map(File::getAbsolutePath).orElse(null);
   }