From 33a1df6e38ee7984b2a659320d114ae1bc4c6c2f Mon Sep 17 00:00:00 2001 From: shangeyao Date: Thu, 25 Jun 2026 20:48:36 +0800 Subject: [PATCH] [Console] Fix Maven local repo directory initialization on startup createMvnLocalRepoDir() previously created the directory only when it already existed, leaving a missing Maven local path uninitialized. Closes #4378 Co-authored-by: Cursor --- .../apache/streampark/console/core/runner/EnvInitializer.java | 4 +--- 1 file changed, 1 insertion(+), 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 c9addb4178..af8eaa9010 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 @@ -156,9 +156,7 @@ private void prepareWorkspace( private static void createMvnLocalRepoDir() { String localMavenRepo = Workspace.MAVEN_LOCAL_PATH(); - if (FsOperator.lfs().exists(localMavenRepo)) { - FsOperator.lfs().mkdirs(localMavenRepo); - } + FsOperator.lfs().mkdirsIfNotExists(localMavenRepo); } private void uploadClientJar(Workspace workspace, FsOperator fsOperator) {