Search code examples
apache-flinkhadoop-yarn

Setting YARN application name for Flink Jobs

I'm currently running flink job using below command.

flink run-application -t yarn-application -c com.app.FlinkJob flink-job.jar

This starts a Yarn job with name Flink Application Cluster. is there a way to change yarn job name to something meaningful?

Solution

  • App name can be set via following option

    flink run-application -t yarn-application -D yarn.application.name="AppName" -c com.app.FlinkJob flink-job.jar