(incubator-streampark) branch dev-2.1.4 updated: [Improve] plugins dir remove

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.4 by this push:
     new 91732845e [Improve] plugins dir remove
91732845e is described below

commit 91732845e24ec39949de5403d13b1f53aa2a3f81
Author: benjobs <benj...@gmail.com>
AuthorDate: Sat Apr 13 00:25:08 2024 +0800

    [Improve] plugins dir remove
---
 .../src/main/assembly/plugins/.gitkeep                    |  0
 .../streampark/console/core/runner/EnvInitializer.java    | 15 ++-------------
 2 files changed, 2 insertions(+), 13 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/assembly/plugins/.gitkeep
 
b/streampark-console/streampark-console-service/src/main/assembly/plugins/.gitkeep
deleted file mode 100644
index e69de29bb..000000000
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 e702018b4..841f954fa 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
@@ -186,17 +186,7 @@ public class EnvInitializer implements ApplicationRunner {
       fsOperator.upload(file.getAbsolutePath(), appClient);
     }
 
-    // 2.2) upload plugin jar.
-    String appPlugins = workspace.APP_PLUGINS();
-    fsOperator.mkCleanDirs(appPlugins);
-
-    File plugins = WebUtils.getAppPluginsDir();
-    for (File file : plugins.listFiles(fileFilter)) {
-      log.info("load plugin:{} to {}", file.getName(), appPlugins);
-      fsOperator.upload(file.getAbsolutePath(), appPlugins);
-    }
-
-    // 2.3) upload shims jar
+    // 2.2) upload shims jar
     File[] shims =
         WebUtils.getAppLibDir()
             .listFiles(pathname -> 
pathname.getName().matches(PATTERN_FLINK_SHIMS_JAR.pattern()));
@@ -217,8 +207,7 @@ public class EnvInitializer implements ApplicationRunner {
       }
     }
 
-    // 2.4) create maven local repository dir
-
+    // 2.3) create maven local repository dir
     String localMavenRepo = Workspace.MAVEN_LOCAL_PATH();
     if (FsOperator.lfs().exists(localMavenRepo)) {
       FsOperator.lfs().mkdirs(localMavenRepo);