43832这个端口号是被Kill掉的Job Manager
楼主你好,在使用阿里云Flink on YARN per-job模式时,如果启用了HA(高可用)模式,并且使用了Zookeeper进行协调,那么在一个Job Manager节点挂掉后,Zookeeper应该会重新进行选举,选出一个新的Job Manager节点来接管作业。如果您发现在一个Job Manager节点被Kill掉后,Zookeeper没有重新选举新的Job Manager节点,可能是以下几个原因导致的:
Zookeeper集群状态异常:如果Zookeeper集群状态异常,例如某个Zookeeper节点挂掉,可能会导致Zookeeper无法正常进行选举。建议您检查Zookeeper集群状态,并确保Zookeeper集群正常运行。
Flink on YARN per-job模式配置异常:如果Flink on YARN per-job模式的配置存在异常,例如Zookeeper地址配置错误或者HA模式配置错误,可能会导致Zookeeper无法正常进行选举。建议您检查Flink on YARN per-job模式的配置,以确保配置正确无误。
作业状态异常:如果作业状态异常,例如作业未正确关闭,可能会导致Zookeeper无法正常进行选举。建议您检查作业状态,以确保作业正常关闭。
关于43832端口号被Kill掉的Job Manager,这可能是由于某个作业执行失败或者某个Job Manager节点出现故障而导致的。当Flink on YARN per-job模式中的一个Job Manager节点挂掉时,Zookeeper应该会重新选举新的Job Manager节点来接管作业。如果Zookeeper没有进行重新选举,可能是以上所述的原因导致的。
如果您需要进一步排查问题,建议您查看Flink on YARN per-job模式的日志,以便了解更多关于作业状态和Zookeeper选举的信息。您也可以尝试重新启动Flink on YARN per-job模式,并确保Zookeeper集群正常运行,以便解决问题。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。