问题:
flink sql中设置了job挂掉后checkpoint保留

execution.checkpointing.externalized-checkpoint-retention
RETAIN_ON_CANCELLATION

并且配置了checkpoint保存到hdfs上

state.backend rocksdb

#增量checkpoint
#state.backend.incremental true
state.checkpoints.dir hdfs:///tmp/flink/checkpoint

flink实际也做了checkpoint,但是用这个路径去hdfs上查询,并不存在对应的路径的目录,好像并不是每次做checkpoint都会持久化到hdfs上,这个是要做啥配置么?让每次checkpoint都保存到磁盘

<http://apache-flink.147419.n8.nabble.com/file/t572/4C10EE51C7A01D45B9278BE2D2CD6C10.jpg>
 



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复