使用fsstatebend的kubernetes中的flink检查点失败

wkyowqbh  于 2021-06-26  发布在  Flink
关注(0)|答案(2)|浏览(398)

我在kubernetes中使用flink时遇到如下错误,每个作业的状态后端都是fsstatebackend,比如so-: env.setStateBackend(new FsStateBackend("file:///data/flink/checkpoints")) 我在我的代码中设置它。
错误-: Mkdirs failed to create file:/data/flink/checkpoints/3321ab76ccf319397f5b52be25f6cd8d 有人能建议解决这个问题吗-:
提前谢谢。干杯!!

inn6fuwd

inn6fuwd1#

除了@chuckskull指出的之外,还要确保集群中的每个pod都可以访问这个文件uri。所有的任务管理器和作业管理器都必须能够使用这个uri读写检查点文件。

xzabzqsa

xzabzqsa2#

以下是一些您可以检查的内容:
确保 /data/flink/checkpoints 存在。
确保运行flink作业的用户对此目录具有读/写权限。

相关问题