You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ch...@apache.org on 2022/11/07 12:36:32 UTC
[dolphinscheduler] branch 3.0.2-prepare updated: Fix flink sql cannot run due to missing main jar (#12705) (#12800)
This is an automated email from the ASF dual-hosted git repository.
chufenggao pushed a commit to branch 3.0.2-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/3.0.2-prepare by this push:
new 206fd003c7 Fix flink sql cannot run due to missing main jar (#12705) (#12800)
206fd003c7 is described below
commit 206fd003c75dd4282551890f5f1eb7fe21b89f3a
Author: Eric Gao <er...@gmail.com>
AuthorDate: Mon Nov 7 20:36:26 2022 +0800
Fix flink sql cannot run due to missing main jar (#12705) (#12800)
Co-authored-by: Wenjun Ruan <we...@apache.org>
---
.../org/apache/dolphinscheduler/plugin/task/flink/FlinkTask.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTask.java
index f70a3d67b7..53e657395c 100644
--- a/dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTask.java
+++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTask.java
@@ -382,10 +382,16 @@ public class FlinkTask extends AbstractYarnTask {
@Override
protected void setMainJarName() {
+ if (flinkParameters.getProgramType() == ProgramType.SQL) {
+ logger.info("The current flink job type is SQL, will no need to set main jar");
+ return;
+ }
+
ResourceInfo mainJar = flinkParameters.getMainJar();
String resourceName = getResourceNameOfMainJar(mainJar);
mainJar.setRes(resourceName);
flinkParameters.setMainJar(mainJar);
+ logger.info("Success set flink jar: {}", resourceName);
}
@Override