Re: flink state.savepoints.dir 目录配置问题

Mon, 26 Oct 2020 00:43:03 -0700 

Hi
    从报错来看是无法在 "/opt/flink/savepoints" 这个路径下创建目录，这个错误下面应该应该一些异常信息，可以看下具体是啥原因。
    另外，使用本地路径存储 checkpoint/savepoint 的话，那么恢复的时候，需要确保该文件能被新的 JM/TM 所访问到

Best,
Congxian


marble.zh...@coinflex.com.INVALID <marble.zh...@coinflex.com.invalid>
于2020年10月26日周一 下午3:32写道：

> 你好，
> 我在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 <jobid>时还是报以下的错，
>
> 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吗？  多谢， 急。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

回复