如何在删除flink jobmanager之前删除rocksdb(flink state)文件?

kzipqqlq  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(412)

我想在flink作业集群被删除之前/之后删除所有rocksdb文件。我们在K8上部署了flink任务。我们将每个作业集群的状态存储在rocksdb上。当作业集群停止时,存储状态的rocksdb不会被删除。有什么想法吗?

q9rjltbz

q9rjltbz1#

rocksdb不需要耐用的存储空间。您可以简单地使用短暂的本地存储,而不是pvc。flink依赖于检查点进行恢复,不需要本地rocksdb示例来生存。
另一方面,如果要使用本地恢复,则需要使用持久本地存储。

相关问题