Why it matters
Watermarks essential for event-time streaming.
Advertisement
The architecture
Watermark = max event time - allowed lateness.
Data before watermark: dropped.
Advertisement
How it works end to end
Allowed lateness: how late data can be.
State cleanup: past watermark can be dropped.
Late data: sink-specific handling (drop, alert).