flink state.savepoints.dir 目录配置问题，需要做哪些调整？
你好， 我在flink jobmanager里的flink-conf.yaml添加了以加三个个关的state配置参数， state.backend: filesystem state.checkpoints.dir: file:///opt/flink/savepoints state.savepoints.dir: file:///opt/flink/savepoints
但在做./flink savepoint 时还是报以下的错，
Caused by: java.io.IOException: Failed to create savepoint directory at file:/opt/flink/savepoints at org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage.initializeLocationForSavepoint(AbstractFsCheckpointStorage.java:167) at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.lambda$initializeCheckpoint$8(CheckpointCoordinator.java:633) ... 8 more
我需要做哪些调整，是只能支持hdfs吗？ 多谢， 急。*来自志愿者整理的flink
写回答
-
Hi 从报错来看是无法在 "/opt/flink/savepoints" 这个路径下创建目录，这个错误下面应该应该一些异常信息，可以看下具体是啥原因。 另外，使用本地路径存储 checkpoint/savepoint 的话，那么恢复的时候，需要确保该文件能被新的 JM/TM 所访问到*来自志愿者整理的flink
2021-12-05 22:25:57赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
