DBScholar

Back to papers

Fugue: Online Elasticity for Distributed Stateful Stream Processing

Summary: Fugue enables self-contained reactive elasticity for stateful stream processing via background state transfer and lightweight barrier-based cutover. Integrated with Flink’s exactly-once protocol, it cuts migration latency by up to 98.6% while retaining >90% throughput without replication overhead. (summarized by gpt-5.6-luna on Aug 28 2026)

Paper ID
h77360085bd993b01
Venue
VLDB
Year
2026
Pagerank
4.9793485e-05
Overall Rank
10,862 | 26.98%
DOI
10.14778/3836663.3836689

Incoming Non-self Citations Over Time

No non-self incoming citations found for this paper in this database.

Authors

BibTeX Citation

@article{zhang_vldb26,
        title = {{Fugue: Online Elasticity for Distributed Stateful Stream Processing}},
        author = {Zhang, Yuqiu and Mao, Yunhao and Jacobsen, Hans-Arno},
        journal = {PVLDB},
        series = {{VLDB} '26},
        volume = {19},
        number = {11},
        pages = {3288--3301},
        doi = {10.14778/3836663.3836689},
        url = {https://doi.org/10.14778/3836663.3836689},
        year = {2026}
}

Incoming Citations (Sorted by Pagerank)

Showing 0 of 0 citing papers.

Rank Citing Paper Year Venue Pagerank
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 14 of 14 cited papers.

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

Rank Cited Paper Year Venue Pagerank
55 Calvin: Fast Distributed Transactions for Partitioned Database Systems 2012 SIGMOD 0.00040471598
123 Schism: a Workload-Driven Approach to Database Replication and Partitioning 2010 VLDB 0.00030762995
218 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024390324
325 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020964941
606 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015635133
685 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014782777
968 Integrating Scale Out and Fault Tolerance in Stream Processing using Operator State Management 2013 SIGMOD 0.00012782051
1,123 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.0001193233
1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010771949
3,033 Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems 2018 VLDB 7.7337998e-05
3,398 Megaphone: Latency-conscious state migration for distributed streaming dataflows 2019 VLDB 7.3353479e-05
4,109 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 6.8008755e-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
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 11,439 How Reliable Are Streams? End-to-End Processing-Guarantee Validation and Performance Benchmarking of Stream Processing Systems 2025 VLDB
2 6,599 AStream: Ad-hoc Shared Stream Processing 2019 SIGMOD
3 10,541 Accelerating Stream Processing Engines via Hardware Offloading 2026 SIGMOD
4 1,228 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD
5 11,972 Klink: Progress-Aware Scheduling for Streaming Data Systems 2021 SIGMOD
6 3,398 Megaphone: Latency-conscious state migration for distributed streaming dataflows 2019 VLDB
7 9,471 Elasticutor: Rapid Elasticity for Realtime Stateful Stream Processing 2019 SIGMOD
8 10,158 Railgun: managing large streaming windows under MAD requirements 2021 VLDB
9 9,648 Disaggregated State Management in Apache Flink 2.0 2025 VLDB
10 1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB