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
6137
Venue
SIGMOD
Year
2021
Pagerank
5.093636e-05
Overall Rank
11,665 | 19.97%
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,368 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 5.093636e-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.00030738755
220 Storm @Twitter 2014 SIGMOD 0.00024244587
224 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024130894
361 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020138717
424 Flexible Time Management in Data Stream Systems 2004 PODS 0.0001870735
587 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00016106078
612 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.0001573018
710 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014715033
1,027 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00012563656
1,223 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011602265
1,763 Dynamic Pipeline Scheduling for Improving Interactive Query Performance 2001 VLDB 9.8124899e-05
2,393 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.6366772e-05
2,447 Operator Scheduling in a Data Stream Manager 2003 VLDB 8.5728111e-05
3,060 SABER: Window-Based Hybrid Stream Processing for Heterogeneous Architectures 2016 SIGMOD 7.8062155e-05
3,126 S-Store: A Streaming NewSQL System for Big Velocity Applications 2014 VLDB 7.7330792e-05
3,851 Analyzing Efficient Stream Processing on Modern Hardware 2019 VLDB 7.0735328e-05
6,108 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.9730511e-05
6,410 A Holistic View of Stream Partitioning Costs 2017 VLDB 5.884019e-05
7,437 FASTER: An Embedded Concurrent Key-Value Store for State Management 2018 VLDB 5.6191179e-05
7,626 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 5.5800458e-05
8,679 Efficient Scheduling of Heterogeneous Continuous Queries 2006 VLDB 5.3862828e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

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