我想在flink作业集群被删除之前/之后删除所有rocksdb文件。我们在K8上部署了flink任务。我们将每个作业集群的状态存储在rocksdb上。当作业集群停止时,存储状态的rocksdb不会被删除。有什么想法吗?
q9rjltbz1#
rocksdb不需要耐用的存储空间。您可以简单地使用短暂的本地存储,而不是pvc。flink依赖于检查点进行恢复,不需要本地rocksdb示例来生存。另一方面,如果要使用本地恢复,则需要使用持久本地存储。
1条答案
按热度按时间q9rjltbz1#
rocksdb不需要耐用的存储空间。您可以简单地使用短暂的本地存储,而不是pvc。flink依赖于检查点进行恢复,不需要本地rocksdb示例来生存。
另一方面,如果要使用本地恢复,则需要使用持久本地存储。