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
6210
Venue
SIGMOD
Year
2021
Pagerank
5.2641681e-05
Overall Rank
5,939 | 58.69%
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,286 StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance 2023 VLDB 5.5838392e-05
7,938 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 4.613363e-05
8,713 Stateful Entities: Object-oriented Cloud Applications as Distributed Dataflows 2023 CIDR 4.4625215e-05
9,496 Scabbard: Single-Node Fault-Tolerant Stream Processing 2022 VLDB 4.3341665e-05
9,732 DARQ Matter Binds Everything: Performant and Composable Cloud Programming via Resilient Steps 2023 SIGMOD 4.2942813e-05
10,280 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 4.1945683e-05
10,336 Transactional Cloud Applications Go with the (Data)Flow 2025 CIDR 4.1945683e-05
10,509 Styx: Transactional Stateful Functions on Streaming Dataflows 2025 SIGMOD 4.1945683e-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
288 Storm @Twitter 2014 SIGMOD 0.00028939871
314 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00028084774
432 Flexible Time Management in Data Stream Systems 2004 PODS 0.00023368424
824 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.0001623129
1,226 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00013180799
1,340 Scalable Distributed Stream Processing 2003 CIDR 0.00012489223
1,357 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012392275
1,548 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.00011431383
1,551 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011416058
1,990 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.8472819e-05
2,338 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.00711e-05
3,886 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 6.6661649e-05
4,795 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 5.9158043e-05
5,187 Stateful Functions as a Service in Action 2019 VLDB 5.6400706e-05
5,263 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 5.5976361e-05
5,753 Building a Replicated Logging System with Apache Kafka 2015 VLDB 5.3404371e-05
6,721 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 4.9492015e-05
7,373 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 4.7494183e-05
9,302 Shrink – Prescribing Resiliency Solutions for Streaming 2017 VLDB 4.3587156e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
9,803 Railgun: managing large streaming windows under MAD requirements 2021 VLDB 4.2807806e-05
6,767 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 4.9322174e-05
11,243 Fries: Fast and Consistent Runtime Reconfiguration in Dataflow Systems with Transactional Guarantees 2023 VLDB 4.1945683e-05
13,322 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.00013180799
1,990 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.8472819e-05
11,804 State Management in Apache Flink 2017 VLDB 4.1945683e-05
10,862 How Reliable Are Streams? End-to-End Processing-Guarantee Validation and Performance Benchmarking of Stream Processing Systems 2025 VLDB 4.1945683e-05
11,819 Toward High-Performance Distributed Stream Processing via Approximate Fault Tolerance 2017 VLDB 4.1945683e-05
1,357 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012392275