VIPFlink
Flink Source 长时间没有数据，为什么会卡住 Watermark
先抓住题目的核心考点，再把答案拆成可复述的面试表达。
1 次浏览2026/9/13
先下定义一句话说清它是什么，面试官先听到结论。
再讲机制拆出关键流程、边界条件和常见坑位。
最后落场景结合生产经验，说出什么时候用、怎么权衡。
题目描述
请回答：Flink Source 长时间没有数据，为什么会卡住 Watermark
这是 Flink Watermark 从概念题变成排障题时很常见的一问。任务没有报错，Kafka 也有部分分区在持续消费，但窗口就是不出结果。很多人会回答“Watermark 取最小值”，却说不清 为什么没数据的分区不能自己推进、withIdleness 如何改变传播规则、超时设太短有什么风险，以及所有 Source 都空闲时窗口会不会自动关闭。
参考答案
刷题导航
评论
加载中...