Pinterest用事件时间判定数据分区完成

Pinterest 为下一代数据库摄取框架引入事件时间分区终结机制，让下游作业判断流式数据是否已足够完整、可安全消费。该机制通过 Apache Flink 统计事件时间进度，并利用 Apache Iceberg 元数据发布不会倒退的终结水位。 默认策略会参考近期若干次提交，以其中最小事件时间为准，并向下取整到相关小时；水位存于 Iceberg 表属性中，下游无需额外协调服务即可读取。下游也可选择牺牲部分完整性，以获取更新鲜的数据。

AI 根据报道生成 · 3 小时前更新

还没有足够的连续观测数据，暂不绘制趋势。