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.3754084e-05
Overall Rank
4,866 | 67.29%
DOI
10.1145/3448016.3457320

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.9407099e-05
8,424 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 5.3350162e-05
9,033 Stateful Entities: Object-oriented Cloud Applications as Distributed Dataflows 2023 CIDR 5.2335027e-05
9,810 Scabbard: Single-Node Fault-Tolerant Stream Processing 2022 VLDB 5.1257999e-05
10,082 DARQ Matter Binds Everything: Performant and Composable Cloud Programming via Resilient Steps 2023 SIGMOD 5.0830849e-05
10,774 HarborMaster: Rollback Detection for Trusted Distributed Computing 2026 VLDB 4.9793485e-05
10,846 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 4.9793485e-05
11,078 Transactional Cloud Applications Go with the (Data)Flow 2025 CIDR 4.9793485e-05
11,199 Styx: Transactional Stateful Functions on Streaming Dataflows 2025 SIGMOD 4.9793485e-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.00024390324
231 Storm @Twitter 2014 SIGMOD 0.00023841089
429 Flexible Time Management in Data Stream Systems 2004 PODS 0.00018439857
606 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015635133
968 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00012782051
1,101 Scalable Distributed Stream Processing 2003 CIDR 0.00012005389
1,123 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.0001193233
1,197 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011566535
1,228 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00011425028
1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010771949
1,771 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.6803752e-05
1,828 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.5516021e-05
3,790 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 7.0190297e-05
4,109 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 6.8008755e-05
4,309 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 6.6732011e-05
5,027 Building a Replicated Logging System with Apache Kafka 2015 VLDB 6.3088256e-05
5,090 Stateful Functions as a Service in Action 2019 VLDB 6.2797546e-05
6,266 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8303329e-05
6,787 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.6820544e-05
9,633 Shrink - Prescribing Resiliency Solutions for Streaming 2017 VLDB 5.1471224e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 10,158 Railgun: managing large streaming windows under MAD requirements 2021 VLDB
2 6,620 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB
3 11,755 Fries: Fast and Consistent Runtime Reconfiguration in Dataflow Systems with Transactional Guarantees 2023 VLDB
4 13,836 Fault-Tolerance for Distributed Iterative Dataflows in Action 2018 VLDB
5 968 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD
6 1,828 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,439 How Reliable Are Streams? End-to-End Processing-Guarantee Validation and Performance Benchmarking of Stream Processing Systems 2025 VLDB
9 12,317 Toward High-Performance Distributed Stream Processing via Approximate Fault Tolerance 2017 VLDB
10 1,228 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD