DE Mastery GitHub

Apache Flink · FLK-03

Time & windows

From your world. late-arriving facts and the as-of grain in your SCD2 / event marts

Practice quiz with instant feedback. For a scored run that counts toward your local progress, use uv run de quiz FLK-03.

1What does a watermark of T assert as it flows through the stream?
2forBoundedOutOfOrderness(Duration.ofSeconds(5)) emits a watermark equal to:
3An event arrives after the watermark has already passed the end of its window. No late-data handling is configured. What happens to the event?
4What does sideOutputLateData(tag) do?
5The watermark of a keyed operator is the MINIMUM across its input partitions. One partition goes quiet (no events). Without idleness, what happens to windows on the busy partitions?
6withIdleness(Duration.ofSeconds(10)) does what?
7Which window assigner closes a window only after a configurable gap of inactivity for a key?
8Why is bucketing hourly GMV by processing time (arrival) a problem?