我在kubernetes中使用flink时遇到如下错误,每个作业的状态后端都是fsstatebackend,比如so-: env.setStateBackend(new FsStateBackend("file:///data/flink/checkpoints"))
我在我的代码中设置它。
错误-: Mkdirs failed to create file:/data/flink/checkpoints/3321ab76ccf319397f5b52be25f6cd8d
有人能建议解决这个问题吗-:
提前谢谢。干杯!!
2条答案
按热度按时间inn6fuwd1#
除了@chuckskull指出的之外,还要确保集群中的每个pod都可以访问这个文件uri。所有的任务管理器和作业管理器都必须能够使用这个uri读写检查点文件。
xzabzqsa2#
以下是一些您可以检查的内容:
确保
/data/flink/checkpoints
存在。确保运行flink作业的用户对此目录具有读/写权限。