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) {