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

Question

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

Answer 1

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

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