flink 基于k8s 的高可用方案
@yiduwangkai 你好,想跟你请教个问题:
你好,我在k8s上搭建flink ha 的时候遇到了,其中一个job manager 日志如下报错:
我目前环境如下,单独搭建的zk集群,创建了两个job manager ,三个task manager
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(2)
我看了一下,可能确实存在这样一个问题,目前还没有解决,虽然他使用的etcd ,但是我是用的是zk,也遇到了这个问题。 但是,我想问,您部署的那种方式,也是可以实现高可用的么?就是standby的jobmanager 日志不会出现这个错误么? https://my.oschina.net/u/1262062/blog/1935750
你参考一下这两篇帖子
https://issues.apache.org/jira/browse/FLINK-12382
https://jira.apache.org/jira/browse/FLINK-7734