MAPREDUCE服务 MRS-Flink客户端执行命令报错“Could not connect to the leading JobManager”:解决办法
解决办法
针对 MRS 2.x及之前版本,操作如下:
方法1:
security.ssl.internal.enabled: false
方法2:
开启Flink SSL通信加密,security.ssl.internal.enabled保持默认。
- 配置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:
security.ssl.enabled: false
方法2:
开启Flink SSL通信加密,security.ssl.enabled 保持默认。
- 配置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