flink jobmanager删除前如何删除rocksdb(flink state)文件？

Question

我想删除所有的 rocksdb 文件 before/after flink 作业集群已被删除。我们在 K8s 上部署了 flink 作业。我们将每个作业集群的状态存储在 rocksdb 上。当作业集群停止时，存储状态的 rocksdb 不会被删除。有什么想法吗？

Answer 1

RocksDB 不需要持久存储。您可以简单地使用临时本地存储，而不是 PVC。 Flink 依赖检查点进行恢复，不需要本地 RocksDB 实例存活。

另一方面，如果您想使用本地恢复，则需要使用持久性本地存储。