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

Mon, 26 Oct 2020 00:32:05 -0700 

你好， 
我在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/

回复