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.9769913e-05
Overall Rank
11,978 | 19.50%
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,577 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 4.9769913e-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.00030414379
218 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024379041
231 Storm @Twitter 2014 SIGMOD 0.00023830094
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.0002095522
430 Flexible Time Management in Data Stream Systems 2004 PODS 0.00018431194
594 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00015816384
606 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015627966
685 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014778299
1,047 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00012303144
1,198 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011561138
1,796 Dynamic Pipeline Scheduling for Improving Interactive Query Performance 2001 VLDB 9.6147923e-05
2,446 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.4544371e-05
2,502 Operator Scheduling in a Data Stream Manager 2003 VLDB 8.3769557e-05
3,108 SABER: Window-Based Hybrid Stream Processing for Heterogeneous Architectures 2016 SIGMOD 7.6392673e-05
3,160 S-Store: A Streaming NewSQL System for Big Velocity Applications 2014 VLDB 7.5773134e-05
3,923 Analyzing Efficient Stream Processing on Modern Hardware 2019 VLDB 6.919667e-05
6,228 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.8427633e-05
6,543 A Holistic View of Stream Partitioning Costs 2017 VLDB 5.7496377e-05
6,990 FASTER: An Embedded Concurrent Key-Value Store for State Management 2018 VLDB 5.6256457e-05
7,758 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 5.4569399e-05
8,853 Efficient Scheduling of Heterogeneous Continuous Queries 2006 VLDB 5.2629364e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 4,592 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB
2 2,446 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,758 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD
5 10,273 Darwin: Scale-In Stream Processing 2022 CIDR
6 8,426 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,019 AJoin: Ad-hoc Stream Joins at Scale 2020 VLDB
9 6,601 AStream: Ad-hoc Shared Stream Processing 2019 SIGMOD
10 6,626 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB