DE Mastery GitHub

Apache Flink · FLK-01

Philosophy & architecture

  • 4 h

From your world. the Spark driver/executors model, re-cast for always-on streaming

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

1Which process schedules tasks, coordinates checkpoints and reacts to failures, but does NOT process record data?
2A linear pipeline source → map → window → sink runs at parallelism 4 with default slot sharing. How many task slots does the job need?
3What is a 'task slot' in Flink?
4What breaks an operator chain, so that two operators run as separate tasks that a data exchange connects?
5You submit a job with a max operator parallelism of 6. The cluster has 2 TaskManagers with 2 slots each (4 slots in total). What happens?
6In the Flink model, how is a bounded dataset (for example a file) related to a stream?
7Which are valid reasons to NOT choose Flink for a workload? (select all) (select all that apply)
8All sources of a bounded Flink job finish. Which state transition occurs?