有大佬通过k8s,搭建flink高可用集群吗?我根据官网教程,基于flink 1.17.0-scal

有大佬通过k8s,搭建flink高可用集群吗?我根据官网教程,基于flink 1.17.0-scala_2.12,根据官网上的flink standalone session模式搭建。最终集群中配置的3个job manager会依次crash, 错误是 The base directory of the JobResultStore isn't accessible. No dirty JobResults can be restored.?

展开
收起
真的很搞笑 2023-04-26 13:47:11 427 分享 版权
2 条回答
写回答
取消 提交回答
  • 需要把高可用路径提前创建好,如果高可用路径是本地挂载路径,确保flink有权访问这个路径
    例如high.availability.storageDir:file:///aa/bb/cc
    mkdir -p /aa/bb/cc &&
    chmod 777 /aa/bb/cc

    2024-12-23 17:38:47
    赞同 展开评论
  • 请问解决了吗?同问这个问题

    2023-06-15 17:21:50
    赞同 展开评论

大数据领域前沿技术分享与交流,这里不止有技术干货、学习心得、企业实践、社区活动,还有未来。

还有其他疑问?
咨询AI助理