Database Paper Browser

Back to papers

Highly Available, Fault-Tolerant, Parallel Dataflows

Summary: Flux is a fault-tolerant dataflow operator that provides high availability for long-running, parallel continuous queries. It fuses partitioned parallelism with process-pairs HA to enable piecemeal, on-the-fly recovery while minimizing changes to operator code. (summarized by gpt-5-nano on Feb 09 2026)

Paper ID
3572
Venue
SIGMOD
Year
2004
Pagerank
0.00012380613
Overall Rank
1,362 | 90.54%
DOI
-

Incoming Non-self Citations Over Time

Authors

Incoming Citations (Sorted by Pagerank)

Showing 18 of 18 citing papers.

Rank Citing Paper Year Venue Pagerank
191 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00035714897
1,339 SkewTune: Mitigating Skew in MapReduce Applications 2012 SIGMOD 0.00012492978
1,995 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.83817e-05
2,270 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.149662e-05
2,578 A Latency and Fault-Tolerance Optimizer for Online Parallel Query Plans 2011 SIGMOD 8.5060604e-05
3,216 Frontier: Resilient Edge Processing for the Internet of Things 2018 VLDB 7.3675613e-05
3,887 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 6.6601639e-05
5,075 Load Management and High Availability in the Medusa Distributed Stream Processing System 2004 SIGMOD 5.7104711e-05
5,686 Staying FIT: Efficient Load Shedding Techniques for Distributed Stream Processing 2007 VLDB 5.3714896e-05
5,718 Lineage-driven Fault Injection 2015 SIGMOD 5.3552421e-05
5,942 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 5.2591128e-05
7,941 Correctness in Stream Processing: Challenges and Opportunities 2022 CIDR 4.6089395e-05
8,496 Customizable Parallel Execution of Scientific Stream Queries 2005 VLDB 4.4938165e-05
8,611 Parallel Querying with Non-Dedicated Computers 2005 VLDB 4.4807595e-05
9,306 Shrink – Prescribing Resiliency Solutions for Streaming 2017 VLDB 4.3545376e-05
9,509 Borealis-R: A Replication-Transparent Stream Processing System for Wide-Area Monitoring Applications 2008 SIGMOD 4.3300131e-05
11,827 Toward High-Performance Distributed Stream Processing via Approximate Fault Tolerance 2017 VLDB 4.1905499e-05
12,262 iFlow: An Approach for Fast and Reliable Internet-Scale Stream Processing Utilizing Detouring and Replication 2010 VLDB 4.1905499e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 8 of 8 cited papers.

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

Rank Cited Paper Year Venue Pagerank
41 NiagaraCQ: A Scalable Continuous Query System for Internet Databases 2000 SIGMOD 0.00073944756
113 Encapsulation of Parallelism in the Volcano Query Processing System 1990 SIGMOD 0.0004673401
143 TelegraphCQ: Continuous Dataflow Processing for an Uncertain World 2003 CIDR 0.00041688468
194 Query Processing, Resource Management, and Approximation in a Data Stream Management System 2003 CIDR 0.00035402379
204 Monitoring Streams – A New Class of Data Management Applications 2002 VLDB 0.00034696955
859 Implementing Recoverable Requests Using Queues 1990 SIGMOD 0.00015821352
1,358 Managing Intra-operator Parallelism in Parallel Database Systems 1995 VLDB 0.00012402333
6,393 A Database System for Real-Time Event Aggregation in Telecommunication 1998 VLDB 5.0770934e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
1,791 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.0001052731
2,204 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2986554e-05
3,384 Scalable and Adaptive Online Joins 2014 VLDB 7.153329e-05
2,578 A Latency and Fault-Tolerance Optimizer for Online Parallel Query Plans 2011 SIGMOD 8.5060604e-05
1,226 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00013168869
5,044 Massive Scale-out of Expensive Continuous Queries 2011 VLDB 5.7338982e-05
12,677 Fault-tolerant, Load-balancing Queries in Telegraph 2001 SIGMOD 4.1905499e-05
1,995 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.83817e-05
11,827 Toward High-Performance Distributed Stream Processing via Approximate Fault Tolerance 2017 VLDB 4.1905499e-05
9,451 Cost-based Fault-tolerance for Parallel Data Processing 2015 SIGMOD 4.3364392e-05