fix_flink_jar_submit

DataLinkDC · Dec 7, 2024 · ede0463 · ede0463
1 parent f48c44e
commit ede0463
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/dinky-core/src/main/java/org/dinky/job/JobRunnerFactory.java b/dinky-core/src/main/java/org/dinky/job/JobRunnerFactory.java
@@ -20,6 +20,12 @@
 package org.dinky.job;
 
 import org.dinky.data.job.JobStatementType;
+import org.dinky.job.runner.JobDDLRunner;
+import org.dinky.job.runner.JobJarRunner;
+import org.dinky.job.runner.JobPipelineRunner;
+import org.dinky.job.runner.JobSetRunner;
+import org.dinky.job.runner.JobSqlRunner;
+
 
 public class JobRunnerFactory {
 

diff --git a/dinky-core/src/main/java/org/dinky/job/runner/JobJarRunner.java b/dinky-core/src/main/java/org/dinky/job/runner/JobJarRunner.java
@@ -18,7 +18,7 @@
  */
 
 package org.dinky.job.runner;
-
+import java.util.List;
 import org.dinky.assertion.Asserts;
 import org.dinky.classloader.DinkyClassLoader;
 import org.dinky.data.exception.DinkyException;
@@ -58,6 +58,9 @@
 import java.io.File;
 import java.net.URL;
 import java.time.LocalDateTime;
+import java.util.Collections;
+import java.util.ArrayList;
+import java.util.Set;
 
 import cn.hutool.core.lang.Assert;
 import cn.hutool.core.text.StrFormatter;