Pinterest 为其数据库摄入框架引入了基于事件时间的分区最终化机制。该机制利用 Apache Flink 跟踪事件时间，并通过 Apache Iceberg 元数据发布非回退水印，帮助下游作业判断持续摄入的 CDC 数据是否已足够完整以供处理。作者：Leela Kumili