MAPREDUCE服务 MRS-Flink客户端执行命令报错“Could not connect to the leading JobManager”:解决办法

时间:2024-08-27 10:23:52

解决办法

针对 MRS 2.x及之前版本,操作如下:

方法1:

关闭Flink SSL通信加密,修改客户端配置文件“conf/flink-conf.yaml”
security.ssl.internal.enabled: false

方法2:

开启Flink SSL通信加密,security.ssl.internal.enabled保持默认。

正确配置SSL:
  • 配置keystore或truststore文件路径为相对路径时,Flink Client执行命令的目录需要可以直接访问该相对路径。
    security.ssl.internal.keystore: ssl/flink.keystore
    security.ssl.internal.truststore: ssl/flink.truststore

    在Flink的CLI yarn-session.sh命令中增加“-t”选项来传输keystore和truststore文件到各个执行节点。

    yarn-session.sh -t ssl/ 2

  • 配置keystore或truststore文件路径为绝对路径时,需要在Flink Client以及各个节点的该绝对路径上放置keystore或truststore文件。
    security.ssl.internal.keystore: /opt/client/Flink/flink/conf/flink.keystore
    security.ssl.internal.truststore: /opt/client/Flink/flink/conf/flink.truststore

针对MRS3.x及之后版本,操作如下:

方法1:

关闭Flink SSL通信加密,修改客户端配置文件“conf/flink-conf.yaml”
security.ssl.enabled: false

方法2:

开启Flink SSL通信加密,security.ssl.enabled 保持默认。

正确配置SSL:
  • 配置keystore或truststore文件路径为相对路径时,Flink Client执行命令的目录需要可以直接访问该相对路径。
    security.ssl.keystore: ssl/flink.keystore
    security.ssl.truststore: ssl/flink.truststore

    在Flink的CLI yarn-session.sh命令中增加“-t”选项来传输keystore和truststore文件到各个执行节点。

    yarn-session.sh -t ssl/ 2
  • 配置keystore或truststore文件路径为绝对路径时,需要在Flink Client以及各个节点的该绝对路径上放置keystore或truststore文件。
    security.ssl.keystore: /opt/client/Flink/flink/conf/flink.keystore
    security.ssl.truststore: /opt/client/Flink/flink/conf/flink.truststore
support.huaweicloud.com/trouble-mrs/mrs_03_0135.html