{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,6,2]],"date-time":"2026-06-02T05:05:27Z","timestamp":1780376727088,"version":"3.54.1"},"publisher-location":"New York, NY, USA","reference-count":52,"publisher":"ACM","license":[{"start":{"date-parts":[[2025,3,30]],"date-time":"2025-03-30T00:00:00Z","timestamp":1743292800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2025,3,30]]},"DOI":"10.1145\/3689031.3696085","type":"proceedings-article","created":{"date-parts":[[2025,3,26]],"date-time":"2025-03-26T06:25:20Z","timestamp":1742970320000},"page":"654-670","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":5,"title":["CAPSys: Contention-aware task placement for data stream processing"],"prefix":"10.1145","author":[{"ORCID":"https:\/\/orcid.org\/0009-0007-2668-0138","authenticated-orcid":false,"given":"Yuanli","family":"Wang","sequence":"first","affiliation":[{"name":"Boston University, Boston, Massachusetts, USA"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0009-0009-1774-7999","authenticated-orcid":false,"given":"Lei","family":"Huang","sequence":"additional","affiliation":[{"name":"Boston University, Boston, Massachusetts, USA"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0009-0000-8207-502X","authenticated-orcid":false,"given":"Zikun","family":"Wang","sequence":"additional","affiliation":[{"name":"Boston University, Boston, Massachusetts, USA"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0001-8219-4862","authenticated-orcid":false,"given":"Vasiliki","family":"Kalavri","sequence":"additional","affiliation":[{"name":"Boston University, Boston, Massachusetts, USA"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-4528-0344","authenticated-orcid":false,"given":"Ibrahim","family":"Matta","sequence":"additional","affiliation":[{"name":"Boston University, Boston, Massachusetts, USA"}],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"320","published-online":{"date-parts":[[2025,3,30]]},"reference":[{"key":"e_1_3_2_1_1_1","volume-title":"https:\/\/flink.apache.org\/. Last access","author":"Flink Apache","year":"2024","unstructured":"Apache Flink. https:\/\/flink.apache.org\/. Last access: January 2024."},{"key":"e_1_3_2_1_2_1","volume-title":"Evenly spread out slots. https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.16\/docs\/deployment\/config\/#cluster-evenly-spread-out-slots. Last access","author":"Apache Flink","year":"2024","unstructured":"Apache Flink configuration: Evenly spread out slots. https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.16\/docs\/deployment\/config\/#cluster-evenly-spread-out-slots. Last access: January 2024."},{"key":"e_1_3_2_1_3_1","volume-title":"https:\/\/storm.apache.org\/. Last access","author":"Storm Apache","year":"2024","unstructured":"Apache Storm. https:\/\/storm.apache.org\/. Last access: January 2024."},{"key":"e_1_3_2_1_4_1","volume-title":"https:\/\/nightlies.apache.org\/flink\/flink-docs-stable\/docs\/deployment\/finegrained_resource\/. Last access","author":"Resource Fine-Grained","year":"2024","unstructured":"Fine-Grained Resource Management in Apache Flink. https:\/\/nightlies.apache.org\/flink\/flink-docs-stable\/docs\/deployment\/finegrained_resource\/. Last access: January 2024."},{"key":"e_1_3_2_1_5_1","volume-title":"Task Slots and Resources. https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.16\/docs\/concepts\/flink-architecture\/#task-slots-and-resources. Last access","author":"Architecture Flink","year":"2024","unstructured":"Flink Architecture: Task Slots and Resources. https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.16\/docs\/concepts\/flink-architecture\/#task-slots-and-resources. Last access: September 2024."},{"key":"e_1_3_2_1_6_1","volume-title":"Tasks and Operator Chains. https:\/\/nightlies.apache.org\/flink\/flink-docs-master\/docs\/concepts\/flink-architecture\/#tasks-and-operator-chains. Last access","author":"Architecture Flink","year":"2024","unstructured":"Flink Architecture: Tasks and Operator Chains. https:\/\/nightlies.apache.org\/flink\/flink-docs-master\/docs\/concepts\/flink-architecture\/#tasks-and-operator-chains. Last access: September 2024."},{"key":"e_1_3_2_1_7_1","volume-title":"Last access","author":"Optimal","year":"2023","unstructured":"Optimal dsp placement and replication, 2023. Last access: Oct 2023."},{"key":"e_1_3_2_1_8_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_1_9_1","doi-asserted-by":"publisher","DOI":"10.1145\/3492321.3519592"},{"key":"e_1_3_2_1_10_1","volume-title":"Nexmark Benchmark Suite","author":"Beam Apache","year":"2022","unstructured":"Apache Beam. Nexmark Benchmark Suite, 2022. Last access: March 2022."},{"key":"e_1_3_2_1_11_1","first-page":"623","volume-title":"17th USENIX Symposium on Operating Systems Design and Implementation (OSDI 23)","author":"Bhardwaj Romil","year":"2023","unstructured":"Romil Bhardwaj, Kirthevasan Kandasamy, Asim Biswal, Wenshuo Guo, Benjamin Hindman, Joseph Gonzalez, Michael Jordan, and Ion Stoica. Cilantro: Performance-Aware resource allocation for general objectives via online feedback. In 17th USENIX Symposium on Operating Systems Design and Implementation (OSDI 23), pages 623--643, Boston, MA, July 2023. USENIX Association."},{"key":"e_1_3_2_1_12_1","doi-asserted-by":"publisher","DOI":"10.1145\/3127479.3127492"},{"key":"e_1_3_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.1145\/2933267.2933312"},{"key":"e_1_3_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.1145\/3092819.3092823"},{"key":"e_1_3_2_1_15_1","doi-asserted-by":"publisher","DOI":"10.14778\/3648160.3648186"},{"key":"e_1_3_2_1_16_1","doi-asserted-by":"publisher","DOI":"10.1145\/2670979.2670995"},{"key":"e_1_3_2_1_17_1","first-page":"1","volume-title":"Proceedings of the USENIX Annual Technical Conference (ATC)","author":"Duplyakin Dmitry","year":"2019","unstructured":"Dmitry Duplyakin, Robert Ricci, Aleksander Maricq, Gary Wong, Jonathon Duerig, Eric Eide, Leigh Stoller, Mike Hibler, David Johnson, Kirk Webb, Aditya Akella, Kuangching Wang, Glenn Ricart, Larry Landweber, Chip Elliott, Michael Zink, Emmanuel Cecchet, Snigdhaswin Kar, and Prabodh Mishra. The design and operation of CloudLab. In Proceedings of the USENIX Annual Technical Conference (ATC), pages 1--14, July 2019."},{"key":"e_1_3_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.1109\/CLOUD.2018.00008"},{"key":"e_1_3_2_1_19_1","volume-title":"Network memory tuning guide. https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.16\/docs\/deployment\/memory\/network_mem_tuning\/","author":"Flink Apache","year":"2023","unstructured":"Apache Flink. Network memory tuning guide. https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.16\/docs\/deployment\/memory\/network_mem_tuning\/, 2023."},{"issue":"12","key":"e_1_3_2_1_20_1","first-page":"1825","article-title":"Self-regulating stream processing in heron","volume":"10","author":"Floratou Avrilia","year":"2017","unstructured":"Avrilia Floratou, Ashvin Agrawal, Bill Graham, Sriram Rao, and Karthik Ramasamy. Dhalion: Self-regulating stream processing in heron. PVLDB, 10(12):1825--1836, August 2017.","journal-title":"PVLDB"},{"key":"e_1_3_2_1_21_1","first-page":"1","volume-title":"The VLDB Journal","author":"Fragkoulis Marios","year":"2023","unstructured":"Marios Fragkoulis, Paris Carbone, Vasiliki Kalavri, and Asterios Katsifodimos. A survey on the evolution of stream processing systems. The VLDB Journal, pages 1--35, 2023."},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1109\/TNET.2017.2741969"},{"key":"e_1_3_2_1_23_1","doi-asserted-by":"publisher","DOI":"10.1145\/3190508.3190549"},{"key":"e_1_3_2_1_24_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-013-0335-9"},{"key":"e_1_3_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE53745.2022.00296"},{"key":"e_1_3_2_1_26_1","volume-title":"8th USENIX Symposium on Networked Systems Design and Implementation (NSDI 11)","author":"Hindman Benjamin","year":"2011","unstructured":"Benjamin Hindman, Andy Konwinski, Matei Zaharia, Ali Ghodsi, Anthony D Joseph, Randy Katz, Scott Shenker, and Ion Stoica. Mesos: A platform for {Fine-Grained} resource sharing in the data center. In 8th USENIX Symposium on Networked Systems Design and Implementation (NSDI 11), 2011."},{"key":"e_1_3_2_1_27_1","first-page":"676","volume-title":"27th International Conference on Extending Database Technology, EDBT 2024","author":"Horchidan Sonia","year":"2024","unstructured":"Sonia Horchidan, Po Hao Chen, Emmanouil Kritharakis, Paris Carbone, and Vasiliki Kalavri. Crayfish: Navigating the labyrinth of machine learning inference in stream processing systems. In 27th International Conference on Extending Database Technology, EDBT 2024, Paestum, Italy, Mar 25 2024-Mar 28 2024, pages 676--689, 2024."},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/1272996.1273005"},{"key":"e_1_3_2_1_29_1","first-page":"221","volume-title":"Proceedings of the 21st International Middleware Conference, Middleware '20","author":"Jonathan Albert","year":"2020","unstructured":"Albert Jonathan, Abhishek Chandra, and Jon Weissman. Wasp: Wide-area adaptive stream processing. In Proceedings of the 21st International Middleware Conference, Middleware '20, page 221--235, New York, NY, USA, 2020. Association for Computing Machinery."},{"key":"e_1_3_2_1_30_1","volume-title":"Proceedings of the 13th USENIX Conference on Operating Systems Design and Implementation","author":"Kalavri Vasiliki","year":"2018","unstructured":"Vasiliki Kalavri, John Liagouris, Moritz Hoffmann, Desislava Dimitrova, Matthew Forshaw, and Timothy Roscoe. Three steps is all you need: Fast, accurate, automatic scaling decisions for distributed streaming dataflows. In Proceedings of the 13th USENIX Conference on Operating Systems Design and Implementation, 2018."},{"key":"e_1_3_2_1_31_1","volume-title":"October","author":"Kalavri Vasiliki","year":"2018","unstructured":"Vasiliki Kalavri, John Liagouris, Moritz Hofmann, Desislava Dimitrova, Matthew Forshaw, and Timothy Roscoe. Three steps is all you need: fast, accurate, automatic scaling decisions for distributed streaming dataflows. https:\/\/github.com\/strymon-system\/ds2\/blob\/master\/flink-examples\/src\/main\/java\/ch\/ethz\/systems\/strymon\/ds2\/flink\/nexmark\/queries\/Query1.java#L49, October 2018. Last access: May 2024."},{"key":"e_1_3_2_1_32_1","doi-asserted-by":"publisher","DOI":"10.1145\/3267809.3267832"},{"key":"e_1_3_2_1_33_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2018.00169"},{"key":"e_1_3_2_1_34_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137628.3137639"},{"key":"e_1_3_2_1_35_1","volume-title":"USENIX Annual Technical Conference","author":"Liu Pinchao","year":"2021","unstructured":"Pinchao Liu, Dilma Da Silva, and Liting Hu. Dart: A scalable and adaptive edge stream processing engine. In USENIX Annual Technical Conference, 2021."},{"key":"e_1_3_2_1_36_1","doi-asserted-by":"publisher","DOI":"10.1002\/cpe.3661"},{"key":"e_1_3_2_1_37_1","doi-asserted-by":"publisher","DOI":"10.14778\/3231751.3231765"},{"key":"e_1_3_2_1_38_1","first-page":"589","volume-title":"2016 IEEE 32nd International Conference on Data Engineering (ICDE)","author":"Uddin Nasir Muhammad Anis","year":"2015","unstructured":"Muhammad Anis Uddin Nasir, Gianmarco De Francisci Morales, Nicolas Kourtellis, and Marco Serafini. When two choices are not enough: Balancing at scale in distributed stream processing. 2016 IEEE 32nd International Conference on Data Engineering (ICDE), pages 589--600, 2015."},{"key":"e_1_3_2_1_39_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522716"},{"key":"e_1_3_2_1_40_1","doi-asserted-by":"publisher","DOI":"10.1145\/2814576.2814808"},{"key":"e_1_3_2_1_41_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2006.105"},{"key":"e_1_3_2_1_42_1","doi-asserted-by":"publisher","DOI":"10.1145\/2675743.2771827"},{"key":"e_1_3_2_1_43_1","volume-title":"Streambed: capacity planning for stream processing. arXiv preprint arXiv:2309.03377","author":"Rosinosky Guillaume","year":"2023","unstructured":"Guillaume Rosinosky, Donatien Schmitz, and Etienne Rivi\u00e8re. Streambed: capacity planning for stream processing. arXiv preprint arXiv:2309.03377, 2023."},{"key":"e_1_3_2_1_44_1","doi-asserted-by":"publisher","DOI":"10.1145\/3546591.3547524"},{"key":"e_1_3_2_1_45_1","volume-title":"OGI School of Science & Engineering at OHSU","author":"Tucker Pete","year":"2002","unstructured":"Pete Tucker, Kristin Tufte, Vassilis Papadimos, and David Maier. Nexmark---a benchmark for queries over data streams. Technical report, OGI School of Science & Engineering at OHSU, 2002."},{"key":"e_1_3_2_1_46_1","doi-asserted-by":"publisher","DOI":"10.1145\/2523616.2523633"},{"key":"e_1_3_2_1_47_1","volume-title":"BUCS-2024-001, Computer Science Department","author":"Wang Yuanli","year":"2024","unstructured":"Yuanli Wang, Lei Huang, Zikun Wang, Vasiliki Kalavri, and Ibrahim Matta. Capsys: Contention-aware task placement for data stream processing. Technical report, BUCS-2024-001, Computer Science Department, Boston University, https:\/\/hdl.handle.net\/2144\/49285, 2024."},{"key":"e_1_3_2_1_48_1","first-page":"595","volume-title":"Proceedings of the 13th USENIX Conference on Operating Systems Design and Implementation, OSDI'18","author":"Xiao Wencong","year":"2018","unstructured":"Wencong Xiao, Romil Bhardwaj, Ramachandran Ramjee, Muthian Sivathanu, Nipun Kwatra, Zhenhua Han, Pratyush Patel, Xuan Peng, Hanyu Zhao, Quanlu Zhang, Fan Yang, and Lidong Zhou. Gandiva: Introspective cluster scheduling for deep learning. In Proceedings of the 13th USENIX Conference on Operating Systems Design and Implementation, OSDI'18, page 595--610, USA, 2018. USENIX Association."},{"key":"e_1_3_2_1_49_1","doi-asserted-by":"publisher","DOI":"10.1109\/IC2E.2016.38"},{"key":"e_1_3_2_1_50_1","first-page":"389","volume-title":"18th USENIX Symposium on Networked Systems Design and Implementation (NSDI 21)","author":"Xu Le","year":"2021","unstructured":"Le Xu, Shivaram Venkataraman, Indranil Gupta, Luo Mai, and Rahul Potharaju. Move fast and meet deadlines: Fine-grained real-time stream processing with cameo. In 18th USENIX Symposium on Networked Systems Design and Implementation (NSDI 21), pages 389--405, 2021."},{"key":"e_1_3_2_1_51_1","doi-asserted-by":"publisher","DOI":"10.1145\/3230543.3230554"},{"key":"e_1_3_2_1_52_1","first-page":"559","volume-title":"16th USENIX Symposium on Operating Systems Design and Implementation (OSDI 22)","author":"Zheng Lianmin","year":"2022","unstructured":"Lianmin Zheng, Zhuohan Li, Hao Zhang, Yonghao Zhuang, Zhifeng Chen, Yanping Huang, Yida Wang, Yuanzhong Xu, Danyang Zhuo, Eric P Xing, et al. Alpa: Automating inter-and {Intra-Operator} parallelism for distributed deep learning. In 16th USENIX Symposium on Operating Systems Design and Implementation (OSDI 22), pages 559--578, 2022."}],"event":{"name":"EuroSys '25: Twentieth European Conference on Computer Systems","location":"Rotterdam Netherlands","acronym":"EuroSys '25","sponsor":["SIGOPS ACM Special Interest Group on Operating Systems"]},"container-title":["Proceedings of the Twentieth European Conference on Computer Systems"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3689031.3696085","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3689031.3696085","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,8,21]],"date-time":"2025-08-21T11:21:02Z","timestamp":1755775262000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3689031.3696085"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2025,3,30]]},"references-count":52,"alternative-id":["10.1145\/3689031.3696085","10.1145\/3689031"],"URL":"https:\/\/doi.org\/10.1145\/3689031.3696085","relation":{},"subject":[],"published":{"date-parts":[[2025,3,30]]},"assertion":[{"value":"2025-03-30","order":3,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}