Pinterest用Flink与Iceberg确认数据分区
Pinterest为流式CDC摄取引入分区最终确认水位线，利用Flink跟踪事件时间，并将单调递增的水位线写入Iceberg元数据，帮助下游判断数据何时足够完整、可以安全消费。该机制还支持基于近期检查点统计或事件时间百分位数的策略，在数据完整性与时效性之间权衡。
事件进展（1 篇报道）
-
2026-10-31 21:00
Pinterest为流式CDC摄取引入分区最终确认水位线，利用Flink跟踪事件时间，并将单调递增的水位线写入Iceberg元数据，帮助下游判断数据何时足够完整、可以安全消费。该机制还支持基于近期检查点统计或事件时间百分位数的策略，在数据完整性与时效性之间权衡。