文档首页/ MapReduce服务 MRS/ 组件操作指南（LTS版）/ 使用Flink/ Flink运维管理/ Flink支持指定作业运行的JDK版本
更新时间：2026-04-23 GMT+08:00
查看PDF
分享

Flink支持指定作业运行的JDK版本

操作场景

MRS 3.6.0-LTS及之后版本，Flink支持指定在Yarn上运行作业的JDK版本，默认为JDK 8，还支持指定为JDK 17或JDK 21。

FlinkServer提交的作业，JDK版本切换操作步骤

  1. 登录Manager界面，选择“集群 > 服务 > Flink”，在“Flink WebUI”右侧，单击链接，访问Flink的WebUI。
  2. 单击“作业管理”进入作业管理页面。
  3. 在FlinkServer作业管理界面，可参考创建FlinkServer作业选择已有作业或新建作业，进入作业开发界面。
  4. 在作业开发界面修改运行作业的JDK版本。

    以切换为JDK 21为例，配置Flink作业时，在“自定义参数”配置：

    “containerized.master.env.JAVA_HOME”的值为“$JAVA_HOME_21”

    “containerized.taskmanager.env.JAVA_HOME”的值为“$JAVA_HOME_21”

  5. 保存作业并提交，作业状态为“运行中”时，单击“操作”列的“作业详情”进入Flink UI，选择“Job Manager > Configuration > JVM”，可以查看JDK的详细信息。

Flink客户端提交的作业，JDK版本切换操作步骤

  1. 使用客户端安装用户登录客户端所在节点，例如安装目录为“/opt/hadoopclient”。
  1. 执行以下命令，进入客户端配置文件所在目录： 

    cd /opt/hadoopclient/Flink/flink/conf

  2. 以切换为JDK 21为例，执行vi flink-conf.yaml命令修改配置文件，添加如下参数： 

    containerized.master.env.JAVA_HOME: $JAVA_HOME_21
containerized.taskmanager.env.JAVA_HOME: $JAVA_HOME_21
env.java.home: /opt/hadoopclient/JDK21/jdk-21.0.8

  3. 使用客户端命令提交作业。
  4. 作业提交运行后，进入Flink UI，选择“Job Manager > Configuration > JVM”，可以查看JDK的详细信息。

父主题： Flink运维管理

相关文档