DBScholar

Back to papers

Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows

Summary: Clonos enables instant local recovery for streaming dataflows with exactly-once guarantees by switching to passive standby operators. Causal logging tracks nondeterminism to enforce causally consistent recovery with output deduplication; evaluated on Nexmark vs Flink with negligible overhead and no determinism assumptions. (summarized by gpt-5-nano on Feb 09 2026)

Paper ID
h1d6ed55c6752fc58
Venue
SIGMOD
Year
2021
Pagerank
6.3723904e-05
Overall Rank
4,867 | 67.29%
DOI
10.1145/3448016.3457320
PDF
Download (CC BY 4.0)

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@inproceedings{silvestre_sigmod21,
        title = {{Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows}},
        author = {Silvestre, Pedro F. and Fragkoulis, Marios and Spinellis, Diomidis and Katsifodimos, Asterios},
        series = {{SIGMOD} '21},
        booktitle = {Proceedings of the {ACM} {SIGMOD} International Conference on Management of Data},
        publisher = {Association for Computing Machinery},
        doi = {10.1145/3448016.3457320},
        url = {https://dl.acm.org/doi/10.1145/3448016.3457320},
        year = {2021}
}

Incoming Citations (Sorted by Pagerank)

Showing 9 of 9 citing papers.

Rank Citing Paper Year Venue Pagerank
5,939 StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance 2023 VLDB 5.9378976e-05
8,433 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 5.3324907e-05
9,041 Stateful Entities: Object-oriented Cloud Applications as Distributed Dataflows 2023 CIDR 5.2310252e-05
9,817 Scabbard: Single-Node Fault-Tolerant Stream Processing 2022 VLDB 5.1233734e-05
10,087 DARQ Matter Binds Everything: Performant and Composable Cloud Programming via Resilient Steps 2023 SIGMOD 5.0806786e-05
10,784 HarborMaster: Rollback Detection for Trusted Distributed Computing 2026 VLDB 4.9769913e-05
10,855 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 4.9769913e-05
11,087 Transactional Cloud Applications Go with the (Data)Flow 2025 CIDR 4.9769913e-05
11,208 Styx: Transactional Stateful Functions on Streaming Dataflows 2025 SIGMOD 4.9769913e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 20 of 20 cited papers.

Citations counted here include only citations to other VLDB/SIGMOD/CIDR/PODS papers in this database.

Rank Cited Paper Year Venue Pagerank
218 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024379041
231 Storm @Twitter 2014 SIGMOD 0.00023830094
430 Flexible Time Management in Data Stream Systems 2004 PODS 0.00018431194
606 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015627966
970 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00012776109
1,101 Scalable Distributed Stream Processing 2003 CIDR 0.00011999722
1,123 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.00011926683
1,198 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011561138
1,230 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00011419665
1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010766851
1,771 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.6757926e-05
1,829 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.5470848e-05
3,792 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 7.0157179e-05
4,110 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 6.797656e-05
4,310 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 6.6700421e-05
5,029 Building a Replicated Logging System with Apache Kafka 2015 VLDB 6.3058391e-05
5,093 Stateful Functions as a Service in Action 2019 VLDB 6.2767846e-05
6,270 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8275729e-05
6,793 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.6793645e-05
9,641 Shrink - Prescribing Resiliency Solutions for Streaming 2017 VLDB 5.1446858e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 10,162 Railgun: managing large streaming windows under MAD requirements 2021 VLDB
2 6,626 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB
3 11,761 Fries: Fast and Consistent Runtime Reconfiguration in Dataflow Systems with Transactional Guarantees 2023 VLDB
4 13,841 Fault-Tolerance for Distributed Iterative Dataflows in Action 2018 VLDB
5 970 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD
6 1,829 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD
7 1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB
8 11,445 How Reliable Are Streams? End-to-End Processing-Guarantee Validation and Performance Benchmarking of Stream Processing Systems 2025 VLDB
9 12,323 Toward High-Performance Distributed Stream Processing via Approximate Fault Tolerance 2017 VLDB
10 1,230 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD