Watermark 面试题10 道

和Watermark相关的题都在这里,涉及Flink、Spark、Kafka、数仓建模。

  1. 4 Flink Watermark 和迟到数据怎么处理? Flink
  2. 32 Flink 空闲分区为什么会卡住 Watermark?withIdleness 怎么用? Flink
  3. 35 Flink Watermark 已经推进,窗口为什么还没有输出? Flink
  4. 39 Flink Watermark Alignment 是什么?为什么要主动暂停较快的数据源? Flink
  5. 43 时间语义与 Watermark:实时计算最核心的概念 Flink
  6. 58 迟到数据处理:Watermark 之后来的数据怎么办 Flink
  7. 63 数据延迟了 5 分钟才到Watermark 和 Event Time 怎么处理乱序数据? Flink
  8. 111 Spark Structured Streaming 如何处理迟到数据和状态清理? Spark
  9. 180 Kafka 扩分区为什么可能乱序?同一个 Key 还能保证顺序吗? Kafka
  10. 490 数仓中的迟到数据怎么处理? 数仓建模