Apache DolphinScheduler 支持 Flink 吗？

• 当程序类型为 Java、Scala 或 Python 时，worker 使用 Flink 命令提交任务 flink run。
• 当程序类型为 SQL 时，worker 使用sql-client.sh 提交任务。

• 点击项目管理-项目名称-工作流定义，点击“创建工作流”按钮，进入 DAG 编辑页面；
• 拖动工具栏的 任务节点到画板中。

1.在 DolphinScheduler 中配置 Flink 环境

2.任务流程

• 上传主程序包

• 配置 Flink 节点

• 执行 FlinkSQL 程序

• Java 和 Scala 只是用来标识，没有区别，如果是 Python 开发的 Flink 则没有主函数的 class，其余的都一样。
• 使用 SQL 执行 Flink SQL 任务，目前只支持 Flink 1.13及以上版本。