1 published article
Apache Flink 1.4+ · BLOB 存储内部机制
Flink 的 BLOB 重写加入了校验和验证、引用计数,以及一个在中央服务器与各 TaskManager 缓存之间分层的存储。它通过在清理前保留已失效的 blob,用磁盘空间换取安全性;保留间隔现在为 30 分钟。
2026-09-14