回复:Flink 1.6 版本,RocksDBStateBackend ,增量 Checkpoint 目录问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

回复:Flink 1.6 版本,RocksDBStateBackend ,增量 Checkpoint 目录问题

lucas.wu
可能是失败的checkpoint目录,可以看看程序中间是不是有失败的checkpoint


原始邮件
发件人:[hidden email]
收件人:[hidden email]
发送时间:2020年1月16日(周四) 16:47
主题:Flink 1.6 版本,RocksDBStateBackend ,增量 Checkpoint 目录问题


我使用 Flink 1.6 版本,使用的增量 Checkpoint,我看官网说,默认的 Checkpoint 保留目录是1,也就是会保留一个最新完成的 Checkpoint 目录,但是在我的任务 Checkpoint 路径下面,居然有很多个 chk-xxx 目录,比如说 chk-86515,chk-37878,而且在这些目录下面,还有数据,这是什么原因呢。 对这个地方有点困惑,既然默认保留的目录是1了,为什么还有这么多 chk 目录呢。 期待你的回答