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 index 2628a69254..c46fff071a 100644 --- 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 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 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 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); }