如何为通过YARN部署的Flink作业设置自定义应用名称?
修改Flink YARN Application Cluster的作业名称
当然可以修改,有两种常用方式:
1. 命令行临时指定(推荐单次自定义)
直接在启动命令中添加-D参数覆盖YARN应用名称,示例命令如下:
flink run-application -t yarn-application -Dyarn.application.name=MyCustomFlinkJob -c com.app.FlinkJob flink-job.jar
这里的MyCustomFlinkJob就是你想要的自定义名称,这个参数优先级最高,会覆盖所有默认配置。
2. 配置文件全局默认设置
如果希望所有YARN Application模式启动的Flink作业都使用统一的自定义名称,可以修改Flink安装目录下的conf/flink-conf.yaml文件,添加或更新以下配置项:
yarn.application.name: MyDefaultFlinkJob
保存配置后,后续启动的作业都会默认使用这个名称,若启动时命令行指定了-Dyarn.application.name,则会优先使用命令行的设置。
内容的提问来源于stack exchange,提问作者on_the_shores_of_linux_sea
相关产品推荐
相关产品推荐

