{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,1,11]],"date-time":"2026-01-11T05:31:33Z","timestamp":1768109493564,"version":"3.49.0"},"publisher-location":"New York, NY, USA","reference-count":57,"publisher":"ACM","license":[{"start":{"date-parts":[[2021,6,9]],"date-time":"2021-06-09T00:00:00Z","timestamp":1623196800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.acm.org\/publications\/policies\/copyright_policy#Background"}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2021,6,9]]},"DOI":"10.1145\/3448016.3452794","type":"proceedings-article","created":{"date-parts":[[2021,6,18]],"date-time":"2021-06-18T17:22:30Z","timestamp":1624036950000},"page":"485-498","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":7,"title":["Klink: Progress-Aware Scheduling for Streaming Data Systems"],"prefix":"10.1145","author":[{"given":"Omar","family":"Farhat","sequence":"first","affiliation":[{"name":"University of Waterloo, Waterloo, ON, Canada"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Khuzaima","family":"Daudjee","sequence":"additional","affiliation":[{"name":"University of Waterloo, Waterloo, ON, Canada"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Leonardo","family":"Querzoni","sequence":"additional","affiliation":[{"name":"Sapienza University of Rome, Rome, Italy"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2021,6,18]]},"reference":[{"key":"e_1_3_2_2_1_1","unstructured":"2020. Klink Codebase. https:\/\/github.com\/klink-scheduler\/klink.  2020. Klink Codebase. https:\/\/github.com\/klink-scheduler\/klink."},{"key":"e_1_3_2_2_2_1","first-page":"277","article-title":"The design of the borealis stream processing engine","volume":"5","author":"Abadi Daniel J","year":"2005","unstructured":"Daniel J Abadi , Yanif Ahmad , Magdalena Balazinska , Ugur Cetintemel , Mitch Cherniack , Jeong-Hyon Hwang , Wolfgang Lindner , Anurag Maskey , Alex Rasin , Esther Ryvkina , 2005 . The design of the borealis stream processing engine . In Cidr , Vol. 5. 277 -- 289 . Daniel J Abadi, Yanif Ahmad, Magdalena Balazinska, Ugur Cetintemel, Mitch Cherniack, Jeong-Hyon Hwang, Wolfgang Lindner, Anurag Maskey, Alex Rasin, Esther Ryvkina, et al. 2005. The design of the borealis stream processing engine. In Cidr, Vol. 5. 277--289.","journal-title":"Cidr"},{"key":"e_1_3_2_2_3_1","volume-title":"the VLDB Journal 12, 2","author":"Abadi Daniel J","year":"2003","unstructured":"Daniel J Abadi , Don Carney , Ugur \u00c7etintemel , Mitch Cherniack , Christian Convey , Sangdon Lee , Michael Stonebraker , Nesime Tatbul , and Stan Zdonik . 2003. Aurora:a new model and architecture for data stream management. the VLDB Journal 12, 2 ( 2003 ), 120--139. Daniel J Abadi, Don Carney, Ugur \u00c7etintemel, Mitch Cherniack, Christian Convey,Sangdon Lee, Michael Stonebraker, Nesime Tatbul, and Stan Zdonik. 2003. Aurora:a new model and architecture for data stream management. the VLDB Journal 12, 2 (2003), 120--139."},{"key":"e_1_3_2_2_4_1","doi-asserted-by":"publisher","DOI":"10.14778\/2536222.2536229"},{"key":"e_1_3_2_2_5_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_2_6_1","doi-asserted-by":"publisher","DOI":"10.1145\/2488222.2488267"},{"key":"e_1_3_2_2_7_1","volume-title":"Proceedings of the VLDB Endowment,Vol. 30","author":"Arasu Arvind","year":"2004","unstructured":"Arvind Arasu , Mitch Cherniack , Eduardo Galvez , David Maier , Anurag S Maskey , Esther Ryvkina , Michael Stonebraker , and Richard Tibbetts . 2004 . Linear road: a stream data management benchmark . In Proceedings of the VLDB Endowment,Vol. 30 . ACM, 480--491. Arvind Arasu, Mitch Cherniack, Eduardo Galvez, David Maier, Anurag S Maskey, Esther Ryvkina, Michael Stonebraker, and Richard Tibbetts. 2004. Linear road: a stream data management benchmark. In Proceedings of the VLDB Endowment,Vol. 30. ACM, 480--491."},{"key":"e_1_3_2_2_8_1","doi-asserted-by":"publisher","DOI":"10.1145\/872757.872789"},{"key":"e_1_3_2_2_9_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.future.2015.03.023"},{"key":"e_1_3_2_2_10_1","first-page":"270","article-title":"Flow and Stretch Metrics for Scheduling Continuous Job Streams","volume":"98","author":"Bender Michael A","year":"1998","unstructured":"Michael A Bender , Soumen Chakrabarti , and Sambavi Muthukrishnan . 1998 . Flow and Stretch Metrics for Scheduling Continuous Job Streams . In SODA , Vol. 98 . 270 -- 279 . Michael A Bender, Soumen Chakrabarti, and Sambavi Muthukrishnan. 1998. Flow and Stretch Metrics for Scheduling Continuous Job Streams. In SODA, Vol. 98.270--279.","journal-title":"SODA"},{"key":"e_1_3_2_2_11_1","doi-asserted-by":"crossref","unstructured":"Jean-Chrysostome Bolot. 1993. Characterizing end-to-end packet delay and loss in the internet. In Journal of High Speed Networks (JHSN). 305--323.  Jean-Chrysostome Bolot. 1993. Characterizing end-to-end packet delay and loss in the internet. In Journal of High Speed Networks (JHSN). 305--323.","DOI":"10.3233\/JHS-1993-2307"},{"key":"e_1_3_2_2_12_1","volume-title":"Apache flink: Stream and batch processing in a single engine.Bulletin of the IEEE Computer Society Technical Committee on Data Engineering 36, 4","author":"Carbone Paris","year":"2015","unstructured":"Paris Carbone , Asterios Katsifodimos , Stephan Ewen , Volker Markl , Seif Haridi , and Kostas Tzoumas . 2015. Apache flink: Stream and batch processing in a single engine.Bulletin of the IEEE Computer Society Technical Committee on Data Engineering 36, 4 ( 2015 ). Paris Carbone, Asterios Katsifodimos, Stephan Ewen, Volker Markl, Seif Haridi, and Kostas Tzoumas. 2015. Apache flink: Stream and batch processing in a single engine.Bulletin of the IEEE Computer Society Technical Committee on Data Engineering 36, 4 (2015)."},{"key":"e_1_3_2_2_13_1","doi-asserted-by":"publisher","DOI":"10.1016\/B978-012722442-8\/50079-3"},{"key":"e_1_3_2_2_14_1","doi-asserted-by":"publisher","DOI":"10.14778\/2733004.2733048"},{"key":"e_1_3_2_2_15_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2011.5767926"},{"key":"e_1_3_2_2_16_1","doi-asserted-by":"publisher","DOI":"10.14778\/2735496.2735503"},{"key":"e_1_3_2_2_17_1","doi-asserted-by":"publisher","DOI":"10.14778\/3229863.3236227"},{"key":"e_1_3_2_2_18_1","volume-title":"Boyang Jerry Peng, et al","author":"Chintapalli Sanket","year":"2016","unstructured":"Sanket Chintapalli , Derek Dagit , Bobby Evans , Reza Farivar , Thomas Graves , Mark Holderbaugh , Zhuo Liu , Kyle Nusbaum , Kishorkumar Patil , Boyang Jerry Peng, et al . 2016 . Benchmarking streaming computation engines: Storm, flink and spark streaming. In 2016 IEEE international parallel and distributed processing symposium workshops (IPDPSW). IEEE , 1789--1792. Sanket Chintapalli, Derek Dagit, Bobby Evans, Reza Farivar, Thomas Graves, Mark Holderbaugh, Zhuo Liu, Kyle Nusbaum, Kishorkumar Patil, Boyang Jerry Peng, et al. 2016. Benchmarking streaming computation engines: Storm, flink and spark streaming. In 2016 IEEE international parallel and distributed processing symposium workshops (IPDPSW). IEEE, 1789--1792."},{"key":"e_1_3_2_2_19_1","volume-title":"Rodrigo Rodrigues, Marco Serafini, and Luis Veiga.","author":"Esteves Sergio","year":"2020","unstructured":"Sergio Esteves , Gianmarco De Francisci Morales , Rodrigo Rodrigues, Marco Serafini, and Luis Veiga. 2020 . Aion : Better Late than Never in Event-Time Streams . arXiv preprint arXiv: 2003.03604(2020). Sergio Esteves, Gianmarco De Francisci Morales, Rodrigo Rodrigues, Marco Serafini, and Luis Veiga. 2020. Aion: Better Late than Never in Event-Time Streams. arXiv preprint arXiv: 2003.03604(2020)."},{"key":"e_1_3_2_2_20_1","doi-asserted-by":"publisher","DOI":"10.1145\/3401025.3401732"},{"key":"e_1_3_2_2_21_1","doi-asserted-by":"publisher","DOI":"10.1109\/TPDS.2013.295"},{"key":"e_1_3_2_2_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/776985.776986"},{"key":"e_1_3_2_2_23_1","doi-asserted-by":"publisher","DOI":"10.1145\/2933267.2933304"},{"key":"e_1_3_2_2_24_1","volume-title":"A catalog of stream processing optimizations. ACM Computing Surveys(CSUR)46, 4","author":"Hirzel Martin","year":"2014","unstructured":"Martin Hirzel , Robert Soul\u00e9 , Scott Schneider , Bugra Gedik , and Robert Grimm . 2014. A catalog of stream processing optimizations. ACM Computing Surveys(CSUR)46, 4 ( 2014 ), 1--34. Martin Hirzel, Robert Soul\u00e9, Scott Schneider, Bugra Gedik, and Robert Grimm. 2014. A catalog of stream processing optimizations. ACM Computing Surveys(CSUR)46, 4 (2014), 1--34."},{"key":"e_1_3_2_2_25_1","doi-asserted-by":"publisher","DOI":"10.14778\/3229863.3229869"},{"key":"e_1_3_2_2_26_1","volume-title":"Proceedings of the VLDB Endowment. ACM, 431--442","author":"Jain Navendu","year":"2006","unstructured":"Navendu Jain , Lisa Amini , Henrique Andrade , Richard King , Yoonho Park , Philippe Selo , and Chitra Venkatramani . 2006 . Design, implementation, and evaluation of the linear road benchmark on the stream processing core . In Proceedings of the VLDB Endowment. ACM, 431--442 . Navendu Jain, Lisa Amini, Henrique Andrade, Richard King, Yoonho Park, Philippe Selo, and Chitra Venkatramani. 2006. Design, implementation, and evaluation of the linear road benchmark on the stream processing core. In Proceedings of the VLDB Endowment. ACM, 431--442."},{"key":"e_1_3_2_2_27_1","doi-asserted-by":"publisher","DOI":"10.1145\/2675743.2772598"},{"key":"e_1_3_2_2_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/2723372.2735371"},{"key":"e_1_3_2_2_29_1","volume-title":"A holistic view of stream partitioning costs.Proceedings of the VLDB Endowment 10, 11","author":"Katsipoulakis Nikos R","year":"2017","unstructured":"Nikos R Katsipoulakis , Alexandros Labrinidis , and Panos K Chrysanthis . 2017. A holistic view of stream partitioning costs.Proceedings of the VLDB Endowment 10, 11 ( 2017 ), 1286--1297. Nikos R Katsipoulakis, Alexandros Labrinidis, and Panos K Chrysanthis. 2017. A holistic view of stream partitioning costs.Proceedings of the VLDB Endowment 10, 11 (2017), 1286--1297."},{"key":"e_1_3_2_2_30_1","doi-asserted-by":"publisher","DOI":"10.1145\/2882903.2882906"},{"key":"e_1_3_2_2_31_1","doi-asserted-by":"publisher","DOI":"10.1145\/2723372.2742788"},{"key":"e_1_3_2_2_32_1","doi-asserted-by":"publisher","DOI":"10.14778\/1453856.1453890"},{"key":"e_1_3_2_2_33_1","doi-asserted-by":"publisher","DOI":"10.1109\/TBDATA.2016.2616148"},{"key":"e_1_3_2_2_34_1","doi-asserted-by":"publisher","DOI":"10.1109\/TPDS.2017.2762683"},{"key":"e_1_3_2_2_35_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE48307.2020.00141"},{"key":"e_1_3_2_2_36_1","volume-title":"2017 USENIX Annual Technical Conference(USENIX ATC '17)","author":"Miao Hongyu","year":"2017","unstructured":"Hongyu Miao , Heejin Park , Myeongjae Jeon , Gennady Pekhimenko , Kathryn S McKinley , and Felix Xiaozhu Lin . 2017 . Streambox: Modern stream processing on a multicore machine . In 2017 USENIX Annual Technical Conference(USENIX ATC '17) . 617--629. Hongyu Miao, Heejin Park, Myeongjae Jeon, Gennady Pekhimenko, Kathryn S McKinley, and Felix Xiaozhu Lin. 2017. Streambox: Modern stream processing on a multicore machine. In 2017 USENIX Annual Technical Conference(USENIX ATC '17). 617--629."},{"key":"e_1_3_2_2_37_1","doi-asserted-by":"publisher","DOI":"10.1145\/1594187.1594199"},{"key":"e_1_3_2_2_38_1","doi-asserted-by":"publisher","DOI":"10.1109\/SFFCS.1999.814615"},{"key":"e_1_3_2_2_39_1","volume-title":"Flink Forward Conference(2019)","author":"Nagmote Snehal","year":"2019","unstructured":"Snehal Nagmote and Pallavi Phadnis . 2019 . Massive Scale Data Processing at Netflix using Flink . Flink Forward Conference(2019) . Snehal Nagmote and Pallavi Phadnis. 2019. Massive Scale Data Processing at Netflix using Flink. Flink Forward Conference(2019)."},{"key":"e_1_3_2_2_40_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2016.7498273"},{"key":"e_1_3_2_2_41_1","doi-asserted-by":"publisher","DOI":"10.1145\/3328905.3329505"},{"key":"e_1_3_2_2_42_1","doi-asserted-by":"publisher","DOI":"10.1145\/2814576.2814808"},{"key":"e_1_3_2_2_43_1","first-page":"197","article-title":"Avoiding class warfare: managing continuous queries with differentiated classes of service","volume":"25","author":"Pham Thao N","year":"2016","unstructured":"Thao N Pham , Panos K Chrysanthis , and Alexandros Labrinidis . 2016 . Avoiding class warfare: managing continuous queries with differentiated classes of service . Proceedings of the VLDB Endowment 25 , 2 (2016), 197 -- 221 . Thao N Pham, Panos K Chrysanthis, and Alexandros Labrinidis. 2016. Avoiding class warfare: managing continuous queries with differentiated classes of service. Proceedings of the VLDB Endowment 25, 2 (2016), 197--221.","journal-title":"Proceedings of the VLDB Endowment"},{"key":"e_1_3_2_2_44_1","doi-asserted-by":"publisher","DOI":"10.1145\/3210284.3210293"},{"key":"e_1_3_2_2_45_1","doi-asserted-by":"publisher","DOI":"10.1145\/3328905.3329506"},{"key":"e_1_3_2_2_46_1","doi-asserted-by":"publisher","DOI":"10.1109\/ECRTS.2005.24"},{"key":"e_1_3_2_2_47_1","unstructured":"Mohamed A Sharaf Panos K Chrysanthis Alexandros Labrinidis and Kirk Pruhs. 2006. Efficient scheduling of heterogeneous continuous queries. In VLDB. 511--522.  Mohamed A Sharaf Panos K Chrysanthis Alexandros Labrinidis and Kirk Pruhs. 2006. Efficient scheduling of heterogeneous continuous queries. In VLDB. 511--522."},{"key":"e_1_3_2_2_48_1","volume-title":"Algorithms and metrics for processing multiple heterogeneous continuous queries. ACM Transactions on Database Systems (TODS)33, 1","author":"Sharaf Mohamed A","year":"2008","unstructured":"Mohamed A Sharaf , Panos K Chrysanthis , Alexandros Labrinidis , and Kirk Pruhs . 2008. Algorithms and metrics for processing multiple heterogeneous continuous queries. ACM Transactions on Database Systems (TODS)33, 1 ( 2008 ), 5. Mohamed A Sharaf, Panos K Chrysanthis, Alexandros Labrinidis, and Kirk Pruhs. 2008. Algorithms and metrics for processing multiple heterogeneous continuous queries. ACM Transactions on Database Systems (TODS)33, 1 (2008), 5."},{"key":"e_1_3_2_2_49_1","doi-asserted-by":"publisher","DOI":"10.1145\/1055558.1055596"},{"key":"e_1_3_2_2_50_1","doi-asserted-by":"publisher","DOI":"10.1145\/1107499.1107504"},{"key":"e_1_3_2_2_51_1","doi-asserted-by":"publisher","DOI":"10.1145\/2588555.2595641"},{"key":"e_1_3_2_2_52_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2003.1198390"},{"key":"e_1_3_2_2_53_1","volume-title":"PVLDB","volume":"1","author":"Urhan Tolga","year":"2001","unstructured":"Tolga Urhan and Michael J Franklin . 2001 . Dynamic pipeline scheduling for improving interactive query performance . In PVLDB , Vol. 1 . ACM, 501--510. Tolga Urhan and Michael J Franklin. 2001. Dynamic pipeline scheduling for improving interactive query performance. In PVLDB, Vol. 1. ACM, 501--510."},{"key":"e_1_3_2_2_54_1","doi-asserted-by":"publisher","DOI":"10.1145\/3132747.3132750"},{"key":"e_1_3_2_2_55_1","doi-asserted-by":"publisher","DOI":"10.1145\/2934664"},{"key":"e_1_3_2_2_56_1","doi-asserted-by":"publisher","DOI":"10.14778\/3303753.3303758"},{"key":"e_1_3_2_2_57_1","doi-asserted-by":"publisher","DOI":"10.1145\/2789168.2790123"}],"event":{"name":"SIGMOD\/PODS '21: International Conference on Management of Data","location":"Virtual Event China","acronym":"SIGMOD\/PODS '21","sponsor":["SIGMOD ACM Special Interest Group on Management of Data"]},"container-title":["Proceedings of the 2021 International Conference on Management of Data"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3448016.3452794","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3448016.3452794","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,17]],"date-time":"2025-06-17T21:28:05Z","timestamp":1750195685000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3448016.3452794"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,6,9]]},"references-count":57,"alternative-id":["10.1145\/3448016.3452794","10.1145\/3448016"],"URL":"https:\/\/doi.org\/10.1145\/3448016.3452794","relation":{},"subject":[],"published":{"date-parts":[[2021,6,9]]},"assertion":[{"value":"2021-06-18","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}