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.9605343e-05
Overall Rank
12,022 | 19.42%
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,640 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 4.9605343e-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
128 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00030317705
219 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.0002429959
233 Storm @Twitter 2014 SIGMOD 0.00023754096
328 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020889528
433 Flexible Time Management in Data Stream Systems 2004 PODS 0.00018370788
596 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00015766455
607 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015577054
688 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014736145
1,052 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00012262678
1,202 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011523108
1,809 Dynamic Pipeline Scheduling for Improving Interactive Query Performance 2001 VLDB 9.5834851e-05
2,453 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.426611e-05
2,510 Operator Scheduling in a Data Stream Manager 2003 VLDB 8.3492737e-05
3,117 SABER: Window-Based Hybrid Stream Processing for Heterogeneous Architectures 2016 SIGMOD 7.6142606e-05
3,174 S-Store: A Streaming NewSQL System for Big Velocity Applications 2014 VLDB 7.552969e-05
3,939 Analyzing Efficient Stream Processing on Modern Hardware 2019 VLDB 6.8967981e-05
6,240 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.8234435e-05
6,553 A Holistic View of Stream Partitioning Costs 2017 VLDB 5.7306258e-05
7,007 FASTER: An Embedded Concurrent Key-Value Store for State Management 2018 VLDB 5.6071869e-05
7,773 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 5.4388958e-05
8,874 Efficient Scheduling of Heterogeneous Continuous Queries 2006 VLDB 5.2455339e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

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