# Flink 程序
# 说明
Flink 程序用于执行 Flink 程序。对于 Flink 节点：
当程序类型为 Java、Scala 或 Python 时，worker 使用 Flink 命令提交任务 flink run。
当程序类型为 SQL 时，worker 使用 sql-client.sh 提交任务。
⚠️ 提示：执行Flink程序前，需要在${dolphinscheduler安装目录}/bin/env/dolphinscheduler_env.sh文件中，修改FLINK_HOME指向flink服务在服务器中的路径。如export FLINK_HOME=${FLINK_HOME:-/home/flink/flink-1.15.4}。
# 配置项说明
| 配置项 | 是否必填 | 默认值 | 描述 |
|---|---|---|---|
| 程序类型 | 是 | - | 支持 Java、Scala、Python 和 SQL 四种语言。 |
| Flink 版本 | 否 | - | 根据所需环境选择对应的版本。 |
| 主函数的Class | 是 | - | Flink 程序的入口 Main class 的全路径。 |
| 主程序包 | 否 | - | 执行 Flink 程序的 jar 包（通过项目配置》文件管理上传）。 |
| 初始化脚本 | 否 | - | 用于初始化会话上下文的脚本文件。 |
| 部署方式 | 否 | - | 支持 cluster 和 local 两种模式的部署。 |
| 任务名称 | 否 | - | Flink 程序的名称。 |
| jobManager内存数 | 否 | - | 用于设置 jobManager 内存数，可根据实际生产环境设置对应的内存数。 |
| Slot数量 | 否 | - | 用于设置 Slot 的数量，可根据实际生产环境设置对应的数量。 |
| taskManager内存数 | 否 | - | 用于设置 taskManager 内存数，可根据实际生产环境设置对应的内存数。 |
| 并行度 | 否 | - | 用于设置执行 Flink 任务的并行度。 |
| 主程序参数 | 否 | - | 设置 Flink 程序的输入参数，支持自定义参数变量的替换。 |
| 选项参数 | 否 | - | 支持 --jar、--files、--archives、--conf 格式。 |
| 资源 | 否 | - | 如果其他参数中引用了资源文件，需要在资源中选择指定。 |
# FAQ
无