请问一下flink on yarn ha高可用的时候,flink的zookeeper3.5.9支持z

org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink-yarn

展开
收起
雪哥哥 2022-11-23 21:52:45 1236 分享 版权
1 条回答
写回答
取消 提交回答
  • 全栈JAVA领域创作者

    Flink on Yarn是Flink在Yarn上运行的模式,它支持三种模式:Application Mode、Session-Cluster和Per-Job-Cluster模式[8]。在Flink on Yarn的高可用方案中,会使用Zookeeper来进行协调,但是需要注意Zookeeper的版本。根据搜索结果,Apache Flink 1.10和1.11版本需要使用Zookeeper 3.4.x版本,而Apache Flink 1.12版本需要使用Zookeeper 3.5.x版本[6][7]。因此,如果你正在使用Apache Flink 1.12版本,则可以使用Zookeeper 3.5.9来支持高可用。但需要注意,如果在使用Flink on Yarn时出现如下错误:org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink-yarn,则可能是由于使用了不兼容的Zookeeper版本,需要检查是否使用了正确版本的Zookeeper[7]。

    2023-03-30 22:00:44
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理