Database Paper Browser

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
6211
Venue
SIGMOD
Year
2021
Pagerank
5.2591128e-05
Overall Rank
5,942 | 58.71%
DOI
10.1145/3448016.3457320

Incoming Non-self Citations Over Time

Authors

Incoming Citations (Sorted by Pagerank)

Showing 8 of 8 citing papers.

Rank Citing Paper Year Venue Pagerank
5,292 StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance 2023 VLDB 5.5784769e-05
7,941 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 4.6089395e-05
8,710 Stateful Entities: Object-oriented Cloud Applications as Distributed Dataflows 2023 CIDR 4.4582438e-05
9,497 Scabbard: Single-Node Fault-Tolerant Stream Processing 2022 VLDB 4.3300131e-05
9,731 DARQ Matter Binds Everything: Performant and Composable Cloud Programming via Resilient Steps 2023 SIGMOD 4.2901665e-05
10,292 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 4.1905499e-05
10,348 Transactional Cloud Applications Go with the (Data)Flow 2025 CIDR 4.1905499e-05
10,518 Styx: Transactional Stateful Functions on Streaming Dataflows 2025 SIGMOD 4.1905499e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 19 of 19 cited papers.

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

Rank Cited Paper Year Venue Pagerank
287 Storm @Twitter 2014 SIGMOD 0.00028917909
314 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00028059664
433 Flexible Time Management in Data Stream Systems 2004 PODS 0.00023336894
822 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00016226851
1,226 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00013168869
1,343 Scalable Distributed Stream Processing 2003 CIDR 0.00012478318
1,362 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012380613
1,546 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.00011418993
1,549 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011407374
1,995 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.83817e-05
2,339 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.0029559e-05
3,887 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 6.6601639e-05
4,797 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 5.9101178e-05
5,185 Stateful Functions as a Service in Action 2019 VLDB 5.6358087e-05
5,271 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 5.5924143e-05
5,766 Building a Replicated Logging System with Apache Kafka 2015 VLDB 5.3353079e-05
6,726 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 4.9444528e-05
7,371 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 4.744863e-05
9,306 Shrink – Prescribing Resiliency Solutions for Streaming 2017 VLDB 4.3545376e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
9,806 Railgun: managing large streaming windows under MAD requirements 2021 VLDB 4.2766788e-05
6,769 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 4.9274854e-05
11,245 Fries: Fast and Consistent Runtime Reconfiguration in Dataflow Systems with Transactional Guarantees 2023 VLDB 4.1905499e-05
13,335 Fault-Tolerance for Distributed Iterative Dataflows in Action 2018 VLDB -
1,226 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00013168869
1,995 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.83817e-05
11,812 State Management in Apache Flink 2017 VLDB 4.1905499e-05
10,866 How Reliable Are Streams? End-to-End Processing-Guarantee Validation and Performance Benchmarking of Stream Processing Systems 2025 VLDB 4.1905499e-05
11,827 Toward High-Performance Distributed Stream Processing via Approximate Fault Tolerance 2017 VLDB 4.1905499e-05
1,362 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012380613