fix_session_cannot_use_add_customjar

DataLinkDC · Nov 27, 2024 · 47f3988 · 47f3988
1 parent f969c84
commit 47f3988
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/dinky-core/src/main/java/org/dinky/job/runner/JobDDLRunner.java b/dinky-core/src/main/java/org/dinky/job/runner/JobDDLRunner.java
@@ -144,26 +144,24 @@ public SqlExplainResult explain(JobStatement jobStatement) {
 
     private void executeAdd(String statement) {
         Set<File> allFilePath = AddJarSqlParseStrategy.getAllFilePath(statement);
-        allFilePath
-                .forEach(t -> jobManager.getUdfPathContextHolder().addOtherPlugins(t));
+        allFilePath.forEach(t -> jobManager.getUdfPathContextHolder().addOtherPlugins(t));
         (jobManager.getExecutor().getDinkyClassLoader())
                 .addURLs(URLUtils.getURLs(jobManager.getUdfPathContextHolder().getOtherPluginsFiles()));
     }
 
     private void executeAddFile(String statement) {
         Set<File> allFilePath = AddFileSqlParseStrategy.getAllFilePath(statement);
-        allFilePath
-                .forEach(t -> jobManager.getUdfPathContextHolder().addFile(t));
+        allFilePath.forEach(t -> jobManager.getUdfPathContextHolder().addFile(t));
         (jobManager.getExecutor().getDinkyClassLoader())
                 .addURLs(URLUtils.getURLs(jobManager.getUdfPathContextHolder().getFiles()));
-        jobManager.getExecutor().addJar(ArrayUtil.toArray(allFilePath,File.class));
+        jobManager.getExecutor().addJar(ArrayUtil.toArray(allFilePath, File.class));
     }
 
     private void executeAddJar(String statement) {
         Set<File> allFilePath = AddFileSqlParseStrategy.getAllFilePath(statement);
         Configuration combinationConfig = getCombinationConfig();
         FileSystem.initialize(combinationConfig, null);
-        jobManager.getExecutor().addJar(ArrayUtil.toArray(allFilePath,File.class));
+        jobManager.getExecutor().addJar(ArrayUtil.toArray(allFilePath, File.class));
         jobManager.getExecutor().executeSql(statement);
     }