开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请问一下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 1053 0
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版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载