使用 FsStateBackend 在 Kubernetes 中 Flink 检查点失败
Flink checkpointing failing in Kubernetes with FsStateBackend
我在 kubernetes 中使用 flink 和 FsStateBackend 的每个作业状态后端时遇到如下错误 -: env.setStateBackend(new FsStateBackend("file:///data/flink/checkpoints"))
我自己在代码中设置它。
错误-：
Mkdirs failed to create file:/data/flink/checkpoints/3321ab76ccf319397f5b52be25f6cd8d
有人可以为此提出解决方案吗 -:
提前致谢。干杯！！
您可以检查以下几项：
- 确保
/data/flink/checkpoints 存在。
- 确保 flink 作业的用户 运行 具有对该目录的 read/write 访问权限。
除了@chuckskull 指出的内容之外，还要确保群集中的每个 pod 都可以访问此文件 URI。所有任务管理器和作业管理器都必须能够使用此 URI 读取和写入检查点文件。
我在 kubernetes 中使用 flink 和 FsStateBackend 的每个作业状态后端时遇到如下错误 -: env.setStateBackend(new FsStateBackend("file:///data/flink/checkpoints"))
我自己在代码中设置它。
错误-：
Mkdirs failed to create file:/data/flink/checkpoints/3321ab76ccf319397f5b52be25f6cd8d
有人可以为此提出解决方案吗 -:
提前致谢。干杯！！
您可以检查以下几项：
- 确保
/data/flink/checkpoints存在。 - 确保 flink 作业的用户 运行 具有对该目录的 read/write 访问权限。
除了@chuckskull 指出的内容之外，还要确保群集中的每个 pod 都可以访问此文件 URI。所有任务管理器和作业管理器都必须能够使用此 URI 读取和写入检查点文件。