Flink提交yarn任务报错拒绝连接

Question

./flink run -t yarn-per-job -c
去提交任务
执行到Job has submitted with JobID
之后就开始报错了：拒绝连接
（详见图片）

Answer 1

阿里嘎多学长整理AIGC生成，因移动端显示问题导致当前答案未能完全显示，请使用PC端查看更加详细的解答过程

Flink提交yarn任务报错拒绝连接

Flink提交Yarn任务报错拒绝连接是一个常见的问题，可能是由于Yarn集群的配置问题或Flink的配置问题导致的。下面是一些可能的解决方案：

1. 检查Yarn集群的配置：检查Yarn集群的配置文件（如yarn-site.xml），确保yarn.nodemanager.resource.memory-mb和yarn.nodemanager.resource.cpu-vcores的值合理。
2. 检查Flink的配置：检查Flink的配置文件（如flink-conf.yaml），确保yarn.resourcemanager.address和yarn.nodemanager.address的值正确。
3. 检查网络连接：检查Flink和Yarn集群之间的网络连接是否正常。
4. 检查Yarn的日志：查看Yarn的日志，检查是否有相关的错误信息。

如果以上解决方案都不能解决问题，可以提供更多的日志信息和配置文件内容，以便更好地帮助你解决问题。

样本代码

# flink-conf.yaml
yarn:
  resourcemanager:
    address: yarn-resourcemanager:8088
  nodemanager:
    address: yarn-nodemanager:8041

<!-- yarn-site.xml -->
<property name="yarn.nodemanager.resource.memory-mb" value="4096"/>
<property name="yarn.nodemanager.resource.cpu-vcores" value="4"/>

问题解决

如果你已经检查了以上问题，并且仍然无法解决问题，可以提供更多的日志信息和配置文件内容，以便更好地帮助你解决问题。