feature flinksql support standalone deploy mode (#13495)

apache · Feb 5, 2023 · 8fa90c2 · 8fa90c2
1 parent 0ee82c5
commit 8fa90c2
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/...ask-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkArgsUtils.java b/...ask-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkArgsUtils.java
@@ -129,6 +129,8 @@ public static List<String> buildInitOptionsForSql(FlinkParameters flinkParameter
         if (FlinkDeployMode.LOCAL == deployMode) {
             // execution.target
             initOptions.add(String.format(FlinkConstants.FLINK_FORMAT_EXECUTION_TARGET, FlinkConstants.FLINK_LOCAL));
+        } else if (FlinkDeployMode.STANDALONE == deployMode) {
+            // standalone exec
         } else {
             // execution.target
             initOptions.add(
@@ -209,6 +211,9 @@ private static List<String> buildRunCommandLineForOthers(TaskExecutionContext ta
             case LOCAL:
                 args.add(FlinkConstants.FLINK_RUN); // run
                 break;
+            case STANDALONE:
+                args.add(FlinkConstants.FLINK_RUN); // run
+                break;
         }
 
         String others = flinkParameters.getOthers();
@@ -259,6 +264,8 @@ private static List<String> buildRunCommandLineForOthers(TaskExecutionContext ta
                 break;
             case LOCAL:
                 break;
+            case STANDALONE:
+                break;
         }
 
         int parallelism = flinkParameters.getParallelism();

diff --git a/...sk-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkDeployMode.java b/...sk-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkDeployMode.java
@@ -28,5 +28,7 @@ public enum FlinkDeployMode {
     @JsonProperty("cluster")
     CLUSTER,
     @JsonProperty("application")
-    APPLICATION
+    APPLICATION,
+    @JsonProperty("standalone")
+    STANDALONE
 }
diff --git a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-flink.ts b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-flink.ts
@@ -53,6 +53,10 @@ export function useFlink(model: { [field: string]: any }): IJsonItem[] {
         {
           label: 'local',
           value: 'local'
+        },
+        {
+          label: 'standalone',
+          value: 'standalone'
         }
       ]
     }