DBScholar

Back to papers

Klink: Progress-Aware Scheduling for Streaming Data Systems

Summary: Leveraging watermarks to infer stream progress and window deadlines, Klink schedules pipelines to unblock windows, speed propagation. Runs on Apache Flink; shows gains over schedulers for scale-up/scale-out workloads with memory-aware execution. (summarized by gpt-5-nano on Feb 09 2026)

Paper ID
hdb700328810efa70
Venue
SIGMOD
Year
2021
Pagerank
4.9793485e-05
Overall Rank
11,972 | 19.51%
DOI
10.1145/3448016.3452794

Incoming Non-self Citations Over Time

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

Authors

BibTeX Citation

@inproceedings{farhat_sigmod21,
        title = {{Klink: Progress-Aware Scheduling for Streaming Data Systems}},
        author = {Farhat, Omar and Daudjee, Khuzaima and Querzoni, Leonardo},
        series = {{SIGMOD} '21},
        booktitle = {Proceedings of the {ACM} {SIGMOD} International Conference on Management of Data},
        publisher = {Association for Computing Machinery},
        doi = {10.1145/3448016.3452794},
        url = {https://dl.acm.org/doi/10.1145/3448016.3452794},
        year = {2021}
}

Incoming Citations (Sorted by Pagerank)

Showing 1 of 1 citing papers.

Rank Citing Paper Year Venue Pagerank
10,566 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 4.9793485e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 21 of 21 cited papers.

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

Rank Cited Paper Year Venue Pagerank
127 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00030427614
218 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024390324
231 Storm @Twitter 2014 SIGMOD 0.00023841089
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
429 Flexible Time Management in Data Stream Systems 2004 PODS 0.00018439857
594 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00015823573
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
1,047 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00012308922
1,197 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011566535
1,796 Dynamic Pipeline Scheduling for Improving Interactive Query Performance 2001 VLDB 9.6193021e-05
2,444 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.4583264e-05
2,500 Operator Scheduling in a Data Stream Manager 2003 VLDB 8.3809217e-05
3,106 SABER: Window-Based Hybrid Stream Processing for Heterogeneous Architectures 2016 SIGMOD 7.6428848e-05
3,159 S-Store: A Streaming NewSQL System for Big Velocity Applications 2014 VLDB 7.5808147e-05
3,922 Analyzing Efficient Stream Processing on Modern Hardware 2019 VLDB 6.9229432e-05
6,225 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.8455305e-05
6,541 A Holistic View of Stream Partitioning Costs 2017 VLDB 5.7523608e-05
6,989 FASTER: An Embedded Concurrent Key-Value Store for State Management 2018 VLDB 5.6274028e-05
7,751 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 5.4595244e-05
8,843 Efficient Scheduling of Heterogeneous Continuous Queries 2006 VLDB 5.265429e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 4,590 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB
2 2,444 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD
3 1,047 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD
4 7,751 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD
5 10,267 Darwin: Scale-In Stream Processing 2022 CIDR
6 8,417 Demonstrating PDSP-Bench: A Benchmarking System for Parallel and Distributed Stream Processing 2025 SIGMOD
7 1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB
8 8,014 AJoin: Ad-hoc Stream Joins at Scale 2020 VLDB
9 6,599 AStream: Ad-hoc Shared Stream Processing 2019 SIGMOD
10 6,620 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB