使用FsStateBackend的Kubernetes中Flink checkpoints失败


0

在kubernetes中使用flink时,我得到了如下所述的错误:每个 job状态的FsStateBackend后端如下-:环境设置状态后端(新的FsStateBackend(“file:///data/flink/checkpoints”))

我在我的代码中设置它。

错误-:

提前谢谢。干杯!!

2 答案


0

除了@chuckskull指出的,还要确保集群中的每个pod都可以访问这个文件URI。所有任务管理器和 job管理器都必须能够使用此URI读写 checkpoints文件。


0

以下是一些您可以检查的事项:

    确保/data/flink/checkpoints存在。

我来回答

写文章

提问题

面试题