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
6272
Venue
SIGMOD
Year
2021
Pagerank
6.097233e-05
Overall Rank
5,756 | 60.51%
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 8 of 8 citing papers.

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
220 Storm @Twitter 2014 SIGMOD 0.00024244587
224 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024130894
424 Flexible Time Management in Data Stream Systems 2004 PODS 0.0001870735
612 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.0001573018
983 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.0001283214
1,090 Scalable Distributed Stream Processing 2003 CIDR 0.0001224178
1,190 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.00011743246
1,209 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00011657178
1,223 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011602265
1,422 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010823039
1,789 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.7502324e-05
1,895 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.5260291e-05
3,776 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 7.1347542e-05
4,278 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 6.7871785e-05
4,279 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 6.7865878e-05
4,974 Stateful Functions as a Service in Action 2019 VLDB 6.4178811e-05
5,419 Building a Replicated Logging System with Apache Kafka 2015 VLDB 6.2255013e-05
6,680 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8049764e-05
7,294 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.6532162e-05
9,531 Shrink - Prescribing Resiliency Solutions for Streaming 2017 VLDB 5.2540895e-05
Previous Page 1 / 1 Next

Semantically Similar Papers