跳到主要内容
版本: 0.6

作业基础配置

Dinky 使用 Flink 社区开源版本,也完全兼容企业二次开发的 Flink 版本。本文介绍如何配置 Flink 的作业。

作业配置

FlinkSQL 作业配置,您可以根据具体需求配置参数,参数设置如下

类型配置项备注
作业配置执行模式指定 FlinkSQL 的执行模式,默认为local
作业配置Flink集群此参数依据执行模式选择需要的集群实例或者集群配置
作业配置作业名称默认作业名,作业名称在当前项目中必须保持 唯一
作业配置FlinkSQL 环境选择当前 FlinkSQL 执行环境,会提前执行环境语句,默认无
作业配置任务并行度设置Flink任务的并行度,默认为 1
作业配置Insert 语句集默认禁用,开启语句集机制,将多个 Insert 语句合并成一个JobGraph
进行提交,select 语句无效
作业配置全局变量默认禁用,开启 FlinkSQL 全局变量,以“${}”进行调用
作业配置批模式默认禁用,开启后启用 Batch Mode
作业配置SavePoint 策略默认禁用,策略包括:
最近一次
最早一次
指定一次
作业配置报警组报警组配置详见报警管理
作业配置其他配置其他的 Flink 作业配置,具体可选参数,详见Flink 官网
说明

FlinkSQL 执行模式除 local 外,还包括Standalone、Yarn Session、Yarn Per-Job、Yarn Application、Kubernetes Session、Kubernetes Application

执行配置

另外 Dinky 提供了针对 FlinkSQL 查询预览的配置,,参数设置如下

类型配置项备注
执行配置预览结果默认开启,开启预览结果将同步运行并返回数据结果
执行配置打印流默认禁用,开启打印流将同步运行并返回含有op字段信息的 ChangeLog
默认不开启则返回最终结果
执行配置最大行数预览数据的最大行数,默认100
执行配置自动停止默认禁用,开启自动停止将在捕获最大行记录数后自动停止

保存点

Dinky 提供 FlinkSQL 在通过 cancel 作业停止时,自动保存savepoint。并生成一个保存 savepoint 的创建时间。

说明

​ 此保存点必须通过 Flink Cancel 完成