1 个回答
Flink 增量checkpoint是以 RocksDB checkpoints 为基础实现的,RocksDB 底层则基于"LMS"树形结构实现.每一次checkpoint仅生成增量文件,接着 Flink 将新生成的sstables拷贝到持久化的存储中（如 HDFS、S3）,新checkpoint将为它们创建引用。Flink 并不是将现有所有的sstables全部拷贝到持久化存储，而是让新checkpoint再次引用它们.
发布于：3个月前 (02-06) IP属地：四川省
我来回答
您需要 登录 后回答此问题！