From ede0463aa1faa6ddbb41a456053654693cc7c92e Mon Sep 17 00:00:00 2001 From: ZackYoung Date: Sat, 7 Dec 2024 22:03:02 +0800 Subject: [PATCH] fix_flink_jar_submit --- .../src/main/java/org/dinky/job/JobRunnerFactory.java | 6 ++++++ .../src/main/java/org/dinky/job/runner/JobJarRunner.java | 5 ++++- 2 files changed, 10 insertions(+), 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 index 50167f1ba9..bd102141be 100644 --- 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 index 18d6a4d88e..ae956cd75e 100644 --- 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;