This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch dev-2.1.5 in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit ea1c13a35438904edacfc01c5ffe7a8f33423f79 Author: benjobs <[email protected]> AuthorDate: Wed Jun 19 14:16:02 2024 +0800 [Improve] hdfs plugins dir bug fixed. --- .../apache/streampark/console/core/runner/EnvInitializer.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java index 0e87a9361..a2777e544 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java @@ -29,7 +29,6 @@ import org.apache.streampark.common.util.Utils; import org.apache.streampark.console.base.util.WebUtils; import org.apache.streampark.console.core.bean.MavenConfig; import org.apache.streampark.console.core.entity.FlinkEnv; -import org.apache.streampark.console.core.service.SettingService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -60,8 +59,6 @@ public class EnvInitializer implements ApplicationRunner { @Autowired private ApplicationContext context; - @Autowired private SettingService settingService; - private final Set<StorageType> initialized = new HashSet<>(2); private final FileFilter fileFilter = p -> !".gitkeep".equals(p.getName()); @@ -171,6 +168,12 @@ public class EnvInitializer implements ApplicationRunner { fsOperator.mkdirs(appJars); } + String appPlugins = workspace.APP_PLUGINS(); + if (!fsOperator.exists(appPlugins)) { + log.info(mkdirLog, appPlugins); + fsOperator.mkdirs(appPlugins); + } + // 2. upload jar. // 2.1) upload client jar File client = WebUtils.getAppClientDir();
