Flink 程序

Flink 程序用于执行 Flink 程序。对于 Flink 节点：

当程序类型为 Java、Scala 或 Python 时，worker 使用 Flink 命令提交任务 flink run。

当程序类型为 SQL 时，worker 使用 sql-client.sh 提交任务。

参数说明：

参数	说明
程序名称	设置程序的名称。一个作业流定义中的节点名称是唯一的。
任务优先级	worker 线程数不足时，根据优先级从高到低依次执行，优先级一样时根据先进先出原则执行。
Worker 分组	任务分配给 worker 组的机器执行，选择 Default，会随机选择一台 worker 机器执行。
本地参数	是 SHELL 局部的用户自定义参数，会替换脚本中 ${变量} 的内容。
超时告警	勾选超时告警、超时失败，当任务超过”超时时长”后，会发送告警邮件并且任务执行失败。
备注	描述该 Flink 程序的功能描述。
程序类型	支持 Java、Scala、Python 和 SQL 四种语言。
Flink 版本	根据所需环境选择对应的版本即可。
主函数的 Class	Flink 程序的入口 Main class 的全路径。
主程序包	执行 Flink 程序的 jar 包（通过项目配置》文件管理上传）。
初始化脚本	用于初始化会话上下文的脚本文件。
脚本	用户开发的应该执行的 SQL 脚本文件。
部署方式	支持 cluster 和 local 两种模式的部署。
任务名称	Flink 程序的名称。
jobManager 内存数	用于设置 jobManager 内存数，可根据实际生产环境设置对应的内存数。
Slot 数量	用于设置 Slot 的数量，可根据实际生产环境设置对应的数量。
taskManager 内存数	用于设置 taskManager 内存数，可根据实际生产环境设置对应的内存数。
taskManager 数量	用于设置 taskManager 的数量，可根据实际生产环境设置对应的数量。
并行度	用于设置执行 Flink 任务的并行度。
主程序参数	设置 Flink 程序的输入参数，支持自定义参数变量的替换。
选项参数	支持 --jar、--files、--archives、--conf 格式。
资源	如果其他参数中引用了资源文件，需要在资源中选择指定。