Flink

Apache Flink 状态后端与 Checkpoint 深度实战:从 Chandy-Lamport 分布式快照到 RocksDB 增量检查点

深入剖析 Flink 有状态流计算的容错内核:StateBackend 与 CheckpointStorage 拆分、Keyed State 与 TTL 语义、Chandy-Lamport barrier 对齐算法、Unaligned Checkpoint 反压降级、RocksDB 增量 checkpoint 的 SST 引用计数,以及 TwoPhaseCommitSink 的端到端精确一次落地与生产调优清单。

Apache Paimon 流式数据湖深度实战:从主键表 LSM 结构、Changelog 生成与 Merge Engine 到 Bucket 分桶与 Lookup Join 的工程全解

深入解析 Apache Paimon 如何把 LSM-Tree 写入模型搬到对象存储:主键表 bucket 分片、deduplicate/partial-update/aggregation 三种 Merge Engine、sequence field 乱序治理、四种 changelog-producer 取舍、minor/full compaction 与 write-only 读写分离、动态分桶与跨分区 Upsert、Lookup Join 维表缓存调优,以及 snapshot 过期与生产避坑清单。