{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,8,21]],"date-time":"2025-08-21T11:40:01Z","timestamp":1755776401878,"version":"3.44.0"},"publisher-location":"New York, NY, USA","reference-count":50,"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.3717485","type":"proceedings-article","created":{"date-parts":[[2025,3,26]],"date-time":"2025-03-26T06:25:20Z","timestamp":1742970320000},"page":"637-653","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":0,"title":["Impeller: Stream Processing on Shared Logs"],"prefix":"10.1145","author":[{"ORCID":"https:\/\/orcid.org\/0009-0005-9598-3875","authenticated-orcid":false,"given":"Zhiting","family":"Zhu","sequence":"first","affiliation":[{"name":"Lepton AI Inc., Cupertino, California, United States and University of Texas at Austin"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-4471-3793","authenticated-orcid":false,"given":"Zhipeng","family":"Jia","sequence":"additional","affiliation":[{"name":"Google LLC, Seattle, Washington, United States"}]},{"ORCID":"https:\/\/orcid.org\/0009-0002-2491-1880","authenticated-orcid":false,"given":"Newton","family":"Ni","sequence":"additional","affiliation":[{"name":"The University of Texas at Austin, Austin, Texas, United States"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-3316-6651","authenticated-orcid":false,"given":"Dixin","family":"Tang","sequence":"additional","affiliation":[{"name":"The University of Texas at Austin, Austin, Texas, United States"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-1391-2880","authenticated-orcid":false,"given":"Emmett","family":"Witchel","sequence":"additional","affiliation":[{"name":"The University of Texas at Austin, Austin, Texas, United States"}]}],"member":"320","published-online":{"date-parts":[[2025,3,30]]},"reference":[{"key":"e_1_3_2_1_1_1","volume-title":"https:\/\/storm.apache.org\/releases\/current\/Trident-tutorial.html (Accessed","author":"Tutorial Trident","year":"2024","unstructured":"[n.d.]. Trident Tutorial. https:\/\/storm.apache.org\/releases\/current\/Trident-tutorial.html (Accessed: May 2024)."},{"key":"e_1_3_2_1_2_1","doi-asserted-by":"publisher","DOI":"10.14778\/2536222.2536229"},{"key":"e_1_3_2_1_3_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_1_4_1","doi-asserted-by":"publisher","DOI":"10.1145\/2463676.2465272"},{"key":"e_1_3_2_1_5_1","volume-title":"Apache Flink --- Stateful Computations over Data Streams. https:\/\/flink.apache.org (Accessed","author":"Foundation Apache Software","year":"2024","unstructured":"Apache Software Foundation. 2024. Apache Flink --- Stateful Computations over Data Streams. https:\/\/flink.apache.org (Accessed: May 2024)."},{"key":"e_1_3_2_1_6_1","volume-title":"Trident State. https:\/\/storm.apache.org\/releases\/current\/Trident-state.html (Accessed","author":"Foundation Apache Software","year":"2024","unstructured":"Apache Software Foundation. 2024. Trident State. https:\/\/storm.apache.org\/releases\/current\/Trident-state.html (Accessed: May 2024)."},{"key":"e_1_3_2_1_7_1","doi-asserted-by":"publisher","DOI":"10.1145\/3183713.3190664"},{"key":"e_1_3_2_1_8_1","volume-title":"Virtual Consensus in Delos. In 14th USENIX Symposium on Operating Systems Design and Implementation (OSDI 20)","author":"Balakrishnan Mahesh","year":"2020","unstructured":"Mahesh Balakrishnan, Jason Flinn, Chen Shen, Mihir Dharamshi, Ahmed Jafri, Xiao Shi, Santosh Ghosh, Hazem Hassan, Aaryaman Sagar, Rhed Shi, Jingming Liu, Filip Gruszczynski, Xianan Zhang, Huy Hoang, Ahmed Yossef, Francois Richard, and Yee Jiun Song. 2020. Virtual Consensus in Delos. In 14th USENIX Symposium on Operating Systems Design and Implementation (OSDI 20). USENIX Association, 617--632. https:\/\/www.usenix.org\/conference\/osdi20\/presentation\/balakrishnan"},{"volume-title":"CORFU: A Shared Log Design for Flash Clusters. In 9th USENIX Symposium on Networked Systems Design and Implementation (NSDI 12)","author":"Balakrishnan Mahesh","key":"e_1_3_2_1_9_1","unstructured":"Mahesh Balakrishnan, Dahlia Malkhi, Vijayan Prabhakaran, Ted Wobbler, Michael Wei, and John D. Davis. 2012. CORFU: A Shared Log Design for Flash Clusters. In 9th USENIX Symposium on Networked Systems Design and Implementation (NSDI 12). USENIX Association, San Jose, CA, 1--14. https:\/\/www.usenix.org\/conference\/nsdi12\/technical-sessions\/presentation\/balakrishnan"},{"key":"e_1_3_2_1_10_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522732"},{"key":"e_1_3_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.14778\/3529337.3529344"},{"key":"e_1_3_2_1_12_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137777"},{"key":"e_1_3_2_1_13_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)."},{"key":"e_1_3_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.14778\/2733004.2733048"},{"key":"e_1_3_2_1_15_1","doi-asserted-by":"publisher","DOI":"10.1145\/2882903.2904441"},{"key":"e_1_3_2_1_16_1","volume-title":"17th USENIX Symposium on Networked Systems Design and Implementation (NSDI 20)","author":"Ding Cong","year":"2020","unstructured":"Cong Ding, David Chu, Evan Zhao, Xiang Li, Lorenzo Alvisi, and Robbert Van Renesse. 2020. Scalog: Seamless Reconfiguration and Total Order in a Scalable Shared Log. In 17th USENIX Symposium on Networked Systems Design and Implementation (NSDI 20). USENIX Association, Santa Clara, CA, 325--338. https:\/\/www.usenix.org\/conference\/nsdi20\/presentation\/ding"},{"volume-title":"Foundations of Computation Theory","author":"Fischer Michael J.","key":"e_1_3_2_1_17_1","unstructured":"Michael J. Fischer. 1983. The consensus problem in unreliable distributed systems (a brief survey). In Foundations of Computation Theory, Marek Karpinski (Ed.). Springer Berlin Heidelberg, Berlin, Heidelberg, 127--140."},{"key":"e_1_3_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.1145\/3472883.3487011"},{"key":"e_1_3_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.14778\/3377369.3377370"},{"key":"e_1_3_2_1_20_1","doi-asserted-by":"publisher","DOI":"10.1145\/3318464.3389739"},{"key":"e_1_3_2_1_21_1","volume-title":"2022 USENIX Annual Technical Conference (USENIX ATC 22)","author":"Gu Rong","year":"2022","unstructured":"Rong Gu, Han Yin, Weichang Zhong, Chunfeng Yuan, and Yihua Huang. 2022. Meces: Latency-efficient Rescaling via Prioritized State Migration for Stateful Distributed Stream Processing Systems. In 2022 USENIX Annual Technical Conference (USENIX ATC 22). USENIX Association, Carlsbad, CA, 539--556. https:\/\/www.usenix.org\/conference\/atc22\/presentation\/gu-rong"},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/3477132.3483541"},{"key":"e_1_3_2_1_23_1","volume-title":"d.]. Kafka Streams. https:\/\/kafka.apache.org\/documentation\/streams\/ (Accessed","author":"Authors Kafka Streams","year":"2024","unstructured":"Kafka Streams Authors. [n. d.]. Kafka Streams. https:\/\/kafka.apache.org\/documentation\/streams\/ (Accessed: March 2024)."},{"key":"e_1_3_2_1_24_1","volume-title":"13th USENIX Symposium on Operating Systems Design and Implementation (OSDI 18)","author":"Kalavri Vasiliki","year":"2018","unstructured":"Vasiliki Kalavri, John Liagouris, Moritz Hoffmann, Desislava Dimitrova, Matthew Forshaw, and Timothy Roscoe. 2018. Three steps is all you need: fast, accurate, automatic scaling decisions for distributed streaming dataflows. In 13th USENIX Symposium on Operating Systems Design and Implementation (OSDI 18). USENIX Association, Carlsbad, CA, 783--798. https:\/\/www.usenix.org\/conference\/osdi18\/presentation\/kalavri"},{"key":"e_1_3_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2018.00169"},{"key":"e_1_3_2_1_26_1","doi-asserted-by":"publisher","DOI":"10.1145\/3299869.3319884"},{"key":"e_1_3_2_1_27_1","doi-asserted-by":"publisher","DOI":"10.1145\/3589262"},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/3448016.3458454"},{"key":"e_1_3_2_1_29_1","volume-title":"StreamScope: Continuous Reliable Distributed Processing of Big Data Streams. In 13th USENIX Symposium on Networked Systems Design and Implementation (NSDI 16)","author":"Lin Wei","year":"2016","unstructured":"Wei Lin, Zhengping Qian, Junwei Xu, Sen Yang, Jingren Zhou, and Lidong Zhou. 2016. StreamScope: Continuous Reliable Distributed Processing of Big Data Streams. In 13th USENIX Symposium on Networked Systems Design and Implementation (NSDI 16). USENIX Association, Santa Clara, CA, 439--453. https:\/\/www.usenix.org\/conference\/nsdi16\/technical-sessions\/presentation\/lin"},{"key":"e_1_3_2_1_30_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_3_2_1_31_1","volume-title":"Exactly-Once Semantics Are Possible: Here's How Kafka Does It. https:\/\/www.confluent.io\/blog\/exactly-once-semantics-are-possible-heres-how-apache-kafka-does-it\/ (Accessed","author":"Narkhede Neha","year":"2024","unstructured":"Neha Narkhede. 2017. Exactly-Once Semantics Are Possible: Here's How Kafka Does It. https:\/\/www.confluent.io\/blog\/exactly-once-semantics-are-possible-heres-how-apache-kafka-does-it\/ (Accessed: May 2024)."},{"key":"e_1_3_2_1_32_1","volume-title":"https:\/\/github.com\/nexmark\/nexmark (Accessed","author":"Authors Nexmark Benchmark","year":"2024","unstructured":"Nexmark Benchmark Authors. 2024. Nexmark Benchmark. https:\/\/github.com\/nexmark\/nexmark (Accessed: May 2024)."},{"key":"e_1_3_2_1_33_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137770"},{"key":"e_1_3_2_1_34_1","volume-title":"Vassilis Papadimos and David Maier","author":"Tucker Pete","year":"2010","unstructured":"Pete Tucker, Kristin Tufte, Vassilis Papadimos and David Maier. 2010. NEXMark - A benchmark for queries over data streams. https:\/\/web.archive.org\/web\/20100620010601\/http:\/\/datalab.cs.pdx.edu\/niagaraST\/NEXMark\/ (Accessed: May 2024)."},{"key":"e_1_3_2_1_35_1","volume-title":"An Overview of End-to-End Exactly-Once Processing in Apache Flink. https:\/\/flink.apache.org\/features\/2018\/03\/01\/end-to-end-exactly-once-apache-flink.html (Accessed","author":"Nowojski Piotr","year":"2024","unstructured":"Piotr Nowojski and Mike Winters. 2018. An Overview of End-to-End Exactly-Once Processing in Apache Flink. https:\/\/flink.apache.org\/features\/2018\/03\/01\/end-to-end-exactly-once-apache-flink.html (Accessed: May 2024)."},{"key":"e_1_3_2_1_36_1","doi-asserted-by":"publisher","DOI":"10.1145\/3190508.3190516"},{"key":"e_1_3_2_1_37_1","unstructured":"Yuan Mei Roman Khachatryan. 2022. Improving speed and stability of checkpointing with generic log-based incremental checkpoints. https:\/\/flink.apache.org\/2022\/05\/30\/improving-speed-and-stability-of-checkpointing-with-generic-log- based-incremental-checkpoints\/ (Accessed: May 2024)."},{"key":"e_1_3_2_1_38_1","doi-asserted-by":"publisher","DOI":"10.1145\/3563835.3567664"},{"key":"e_1_3_2_1_39_1","volume-title":"https:\/\/temporal.io (Accessed","author":"Technologies Temporal","year":"2024","unstructured":"Temporal Technologies. 2024. Temporal. https:\/\/temporal.io (Accessed: Jul 2024)."},{"key":"e_1_3_2_1_40_1","doi-asserted-by":"publisher","DOI":"10.14778\/3489496.3489515"},{"key":"e_1_3_2_1_41_1","doi-asserted-by":"publisher","DOI":"10.5441\/002\/EDBT.2019.10"},{"key":"e_1_3_2_1_42_1","doi-asserted-by":"publisher","DOI":"10.1145\/3132747.3132750"},{"key":"e_1_3_2_1_43_1","doi-asserted-by":"publisher","DOI":"10.1145\/3448016.3457556"},{"key":"e_1_3_2_1_44_1","volume-title":"14th USENIX Symposium on Networked Systems Design and Implementation (NSDI 17)","author":"Wei Michael","year":"2017","unstructured":"Michael Wei, Amy Tai, Christopher J. Rossbach, Ittai Abraham, Maithem Munshed, Medhavi Dhawan, Jim Stabile, Udi Wieder, Scott Fritchie, Steven Swanson, Michael J. Freedman, and Dahlia Malkhi. 2017. vCorfu: A Cloud-Scale Object Store on a Shared Log. In 14th USENIX Symposium on Networked Systems Design and Implementation (NSDI 17). USENIX Association, Boston, MA, 35--49. https:\/\/www.usenix.org\/conference\/nsdi17\/technical-sessions\/presentation\/wei-michael"},{"key":"e_1_3_2_1_45_1","volume-title":"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)","author":"Xu Le","year":"2021","unstructured":"Le Xu, Shivaram Venkataraman, Indranil Gupta, Luo Mai, and Rahul Potharaju. 2021. 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). USENIX Association, 389--405. https:\/\/www.usenix.org\/conference\/nsdi21\/presentation\/xu"},{"key":"e_1_3_2_1_46_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522737"},{"key":"e_1_3_2_1_47_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE55515.2023.00078"},{"key":"e_1_3_2_1_48_1","volume-title":"Haralampos Gavriilidis, Dimitrios Giouroukis, Philipp M. Grulich, Sebastian Bre\u00df, Jonas Traub, and Volker Markl.","author":"Zeuch Steffen","year":"2020","unstructured":"Steffen Zeuch, Ankit Chaudhary, Bonaventura Del Monte, Haralampos Gavriilidis, Dimitrios Giouroukis, Philipp M. Grulich, Sebastian Bre\u00df, Jonas Traub, and Volker Markl. 2020. The NebulaStream Platform for Data and Application Management in the Internet of Things. In 10th Conference on Innovative Data Systems Research, CIDR 2020, Amsterdam, The Netherlands, January 12-15, 2020, Online Proceedings. www.cidrdb.org.http:\/\/cidrdb.org\/cidr2020\/papers\/p7-zeuch-cidr20.pdf"},{"key":"e_1_3_2_1_49_1","doi-asserted-by":"publisher","DOI":"10.1145\/3299869.3300067"},{"key":"e_1_3_2_1_50_1","volume-title":"ExoFlow: A Universal Workflow System for Exactly-Once DAGs. In 17th USENIX Symposium on Operating Systems Design and Implementation (OSDI 23)","author":"Zhuang Siyuan","year":"2023","unstructured":"Siyuan Zhuang, Stephanie Wang, Eric Liang, Yi Cheng, and Ion Stoica. 2023. ExoFlow: A Universal Workflow System for Exactly-Once DAGs. In 17th USENIX Symposium on Operating Systems Design and Implementation (OSDI 23). USENIX Association, Boston, MA, 269--286. https:\/\/www.usenix.org\/conference\/osdi23\/presentation\/zhuang"}],"event":{"name":"EuroSys '25: Twentieth European Conference on Computer Systems","sponsor":["SIGOPS ACM Special Interest Group on Operating Systems"],"location":"Rotterdam Netherlands","acronym":"EuroSys '25"},"container-title":["Proceedings of the Twentieth European Conference on Computer Systems"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3689031.3717485","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3689031.3717485","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,8,21]],"date-time":"2025-08-21T11:23:55Z","timestamp":1755775435000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3689031.3717485"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2025,3,30]]},"references-count":50,"alternative-id":["10.1145\/3689031.3717485","10.1145\/3689031"],"URL":"https:\/\/doi.org\/10.1145\/3689031.3717485","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"}}]}}