Two-Phase Commit Sink
A completed checkpoint records progress; a destination commit exposes output. The sink must recover safely when failure separates those two actions.
-
-
Stream Processing Semantics and Correctness
A streaming result describes data received by an agreed boundary. See how windows, lateness, state, and publication rules make revisions understandable.
-
Delivery Semantics
Three promises about how many times a record arrives. The useful question is not which one a product advertises, but where its guarantee stops.
-
Pipeline Correctness: Duplicates and Loss
Every job succeeded and the total is still wrong. Here is where duplicates and missing rows come from, what “exactly once” really promises, and how to verify.
-
Stateful Stream Processing and Checkpoint Recovery
A checkpoint restores a job’s state, not the outside world. Trace restart, sink commits, and crash points to see where exactly-once ends.