CheckMate: Evaluating Checkpointing Protocols for Streaming Dataflows
George Siachamis, Kyriakos Psarakis, Marios Fragkoulis, Arie van Deursen, Paris Carbone, Asterios Katsifodimos
Abstract
Stream processing in the last decade has seen broad adoption in both commercial and research settings. One key element for this success is the ability of modern stream processors to handle failures while ensuring exactly-once processing guarantees. At the moment of writing, virtually all stream processors that guarantee exactly-once processing implement a variant of Apache Flink's coordinated checkpoints -an extension of the original Chandy-Lamport checkpoints from 1985. However, the reasons behind this prevalence of the coordinated approach remain anecdotal, as reported by practitioners of the stream processing community. At the same time, common checkpointing approaches, such as the uncoordinated and the communicationinduced ones, remain largely unexplored.
This paper is the first to address this gap by i) shedding light on why practitioners have favored the coordinated approach and ii) by investigating whether there are viable alternatives. To this end, we implement three checkpointing approaches that we surveyed and adapted for the distinct needs of streaming dataflows. Our analysis shows that the coordinated approach outperforms the uncoordinated and communication-induced protocols under uniformly distributed workloads. To our surprise, however, the uncoordinated approach is not only competitive to the coordinated one in uniformly distributed workloads, but it also outperforms the coordinated approach in skewed workloads. We conclude that rather than blindly employing coordinated checkpointing, research should focus on optimizing the very promising uncoordinated approach, as it can address issues with skew and support prevalent cyclic queries. We believe that our findings can trigger further research into checkpointing mechanisms.
Ask about this paper
Your agent reads all of it.
Lune indexed this paper to the last equation, along with the top-tier papers that cite it. Ask a question and the answer quotes them.
Your agent calls
Luneget_paper_fulltext
Free to start. No credit card required.
Terminal
Install the CLIlune papers fulltext 43cc8e21-0994-44d1-b5a3-e988ce2e5961Cited by top-tier papers2
- Styx: Transactional Stateful Functions on Streaming DataflowsKyriakos Psarakis, George Christodoulou, Georgios Siachamis, Marios Fragkoulis et al.SIGMOD 2025 · 3 citations
- OSTOR: Online Scheduling Framework for Trading Continuous QueriesJin Cheng, Ningning Ding, John C. S. Lui, Jianwei HuangICDE 2025 · 1 citation
Builds on2
Related papers
- Scabbard: Single-Node Fault-Tolerant Stream ProcessingGeorgios Theodorakis, Fotios Kounelis, Peter R. Pietzuch, Holger PirkVLDB 2022 · 21 citations
- Impeller: Stream Processing on Shared LogsZhiting Zhu, Zhipeng Jia, Newton Ni, Dixin Tang et al.EuroSys 2025 · 1 citation
- LPStream: Fine-grained Lazy Provenance for Stream ProcessingMasaya Yamada, Hiroyuki Kitagawa, Salman Ahmed Shaikh, Toshiyuki Amagasa et al.SIGMOD 2026 · 3 citations
- How Reliable Are Streams? End-to-End Processing-Guarantee Validation and Performance Benchmarking of Stream Processing SystemsJawad Tahir, Ruben Mayer, Christoph Doblander, Hans-Arno JacobsenVLDB 2025 · 3 citations
- Meces: Latency-efficient Rescaling via Prioritized State Migration for Stateful Distributed Stream Processing SystemsRong Gu, Han Yin, Weichang Zhong, Chunfeng Yuan et al.USENIX ATC 2022 · 22 citations
