{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,8]],"date-time":"2025-10-08T15:35:30Z","timestamp":1759937730240,"version":"3.41.0"},"publisher-location":"New York, NY, USA","reference-count":47,"publisher":"ACM","license":[{"start":{"date-parts":[[2021,11,1]],"date-time":"2021-11-01T00:00:00Z","timestamp":1635724800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"funder":[{"name":"Ministry of Education, Singapore","award":["R-252-000-A67-114 and R-252-000-B18-114"],"award-info":[{"award-number":["R-252-000-A67-114 and R-252-000-B18-114"]}]}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2021,11]]},"DOI":"10.1145\/3472883.3487010","type":"proceedings-article","created":{"date-parts":[[2021,10,27]],"date-time":"2021-10-27T10:48:16Z","timestamp":1635331696000},"page":"214-228","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":8,"title":["Trisk"],"prefix":"10.1145","author":[{"given":"Yancan","family":"Mao","sequence":"first","affiliation":[{"name":"National University of Singapore"}]},{"given":"Yuan","family":"Huang","sequence":"additional","affiliation":[{"name":"National University of Singapore"}]},{"given":"Runxin","family":"Tian","sequence":"additional","affiliation":[{"name":"National University of Singapore"}]},{"given":"Xin","family":"Wang","sequence":"additional","affiliation":[{"name":"National University of Singapore"}]},{"given":"Richard T. B.","family":"Ma","sequence":"additional","affiliation":[{"name":"National University of Singapore"}]}],"member":"320","published-online":{"date-parts":[[2021,11]]},"reference":[{"unstructured":"Daniel J Abadi Yanif Ahmad Magdalena Balazinska Ugur Cetintemel Mitch Cherniack Jeong-Hyon Hwang Wolfgang Lindner Anurag Maskey Alex Rasin Esther Ryvkina etal 2005. The design of the Borealis stream processing engine.. In CIDR. 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. 277--289.","key":"e_1_3_2_2_1_1"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_2_1","DOI":"10.1007\/s00778-003-0095-z"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_3_1","DOI":"10.14778\/2536222.2536229"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_4_1","DOI":"10.14778\/2824032.2824076"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_5_1","DOI":"10.1007\/s00778-014-0357-y"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_6_1","DOI":"10.1145\/3183713.3190664"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_7_1","DOI":"10.1145\/3183713.3190664"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_8_1","DOI":"10.14778\/3137765.3137777"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_9_1","DOI":"10.14778\/3137765.3137777"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_10_1","DOI":"10.1145\/3318464.3383131"},{"key":"e_1_3_2_2_11_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)."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_12_1","DOI":"10.1145\/2463676.2465282"},{"unstructured":"Apache Flink. 2020. Flink Unaligned Checkpoints. https:\/\/flink.apache.org\/2020\/10\/15\/from-aligned-to-unaligned-checkpoints-part-1.html.  Apache Flink. 2020. Flink Unaligned Checkpoints. https:\/\/flink.apache.org\/2020\/10\/15\/from-aligned-to-unaligned-checkpoints-part-1.html.","key":"e_1_3_2_2_13_1"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_14_1","DOI":"10.14778\/3137765.3137786"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_15_1","DOI":"10.1109\/ICDCS.2015.49"},{"key":"e_1_3_2_2_16_1","volume-title":"13th USENIX Symposium on Operating Systems Design and Implementation (OSDI). 213--231","author":"Gjengset Jon","year":"2018","unstructured":"Jon Gjengset , Malte Schwarzkopf , Jonathan Behrens , Lara Timb\u00f3 Ara\u00fajo , Martin Ek , Eddie Kohler , M. Frans Kaashoek , and Robert Morris . 2018 . Noria: dynamic, partially-stateful data-flow for high-performance web applications . In 13th USENIX Symposium on Operating Systems Design and Implementation (OSDI). 213--231 . Jon Gjengset, Malte Schwarzkopf, Jonathan Behrens, Lara Timb\u00f3 Ara\u00fajo, Martin Ek, Eddie Kohler, M. Frans Kaashoek, and Robert Morris. 2018. Noria: dynamic, partially-stateful data-flow for high-performance web applications. In 13th USENIX Symposium on Operating Systems Design and Implementation (OSDI). 213--231."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_17_1","DOI":"10.1007\/978-3-540-31865-1_25"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_18_1","DOI":"10.1109\/TKDE.2013.184"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_19_1","DOI":"10.14778\/3329772.3329777"},{"doi-asserted-by":"crossref","unstructured":"Michael Isard Mihai Budiu Yuan Yu Andrew Birrell and Dennis Fetterly. 2007. Dryad: distributed data-parallel programs from sequential building blocks. In ACM SIGOPS operating systems review. ACM 59--72.  Michael Isard Mihai Budiu Yuan Yu Andrew Birrell and Dennis Fetterly. 2007. Dryad: distributed data-parallel programs from sequential building blocks. In ACM SIGOPS operating systems review. ACM 59--72.","key":"e_1_3_2_2_20_1","DOI":"10.1145\/1272998.1273005"},{"unstructured":"Kaggle. 2020. Credit Card Transactions Fraud Detection. https:\/\/www.kaggle.com\/kartik2112\/fraud-detection.  Kaggle. 2020. Credit Card Transactions Fraud Detection. https:\/\/www.kaggle.com\/kartik2112\/fraud-detection.","key":"e_1_3_2_2_21_1"},{"key":"e_1_3_2_2_22_1","volume-title":"13th USENIX Symposium on Operating Systems Design and Implementation (OSDI). 783--798","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). 783--798 . 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). 783--798."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_23_1","DOI":"10.1145\/3267809.3267832"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_24_1","DOI":"10.1145\/2723372.2742788"},{"key":"e_1_3_2_2_25_1","volume-title":"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) . 439--453. 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). 439--453."},{"key":"e_1_3_2_2_26_1","volume-title":"Elastic Stream Processing with Latency Guarantees. In IEEE 35th International Conference on Distributed Computing Systems. 399--410","author":"Lohrmann B.","year":"2015","unstructured":"B. Lohrmann , P. Janacik , and O. Kao . 2015 . Elastic Stream Processing with Latency Guarantees. In IEEE 35th International Conference on Distributed Computing Systems. 399--410 . https:\/\/doi.org\/10.1109\/ICDCS. 2015 .48 10.1109\/ICDCS.2015.48 B. Lohrmann, P. Janacik, and O. Kao. 2015. Elastic Stream Processing with Latency Guarantees. In IEEE 35th International Conference on Distributed Computing Systems. 399--410. https:\/\/doi.org\/10.1109\/ICDCS.2015.48"},{"key":"e_1_3_2_2_27_1","volume-title":"Kungfu: Making training in distributed machine learning adaptive. In 14th { USENIX} Symposium on Operating Systems Design and Implementation ({OSDI} 20). 937--954.","author":"Mai Luo","year":"2020","unstructured":"Luo Mai , Guo Li , Marcel Wagenl\u00e4nder , Konstantinos Fertakis , Andrei-Octavian Brabete , and Peter Pietzuch . 2020 . Kungfu: Making training in distributed machine learning adaptive. In 14th { USENIX} Symposium on Operating Systems Design and Implementation ({OSDI} 20). 937--954. Luo Mai, Guo Li, Marcel Wagenl\u00e4nder, Konstantinos Fertakis, Andrei-Octavian Brabete, and Peter Pietzuch. 2020. Kungfu: Making training in distributed machine learning adaptive. In 14th { USENIX} Symposium on Operating Systems Design and Implementation ({OSDI} 20). 937--954."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_28_1","DOI":"10.14778\/3231751.3231765"},{"key":"e_1_3_2_2_29_1","volume-title":"Proceedings of the ACM SIGMOD International Conference on Management of Data. ACM.","author":"Monte Bonaventura Del","year":"2020","unstructured":"Bonaventura Del Monte , Steffen Zeuch , Tilmann Rabl , and Volker Markl . 2020 . Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines . In Proceedings of the ACM SIGMOD International Conference on Management of Data. ACM. Bonaventura Del Monte, Steffen Zeuch, Tilmann Rabl, and Volker Markl. 2020. Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines. In Proceedings of the ACM SIGMOD International Conference on Management of Data. ACM."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_30_1","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_3_2_2_31_1","volume-title":"Proc. 8th ACM\/USENIX Symposium on Networked Systems Design and Implementation. 113--126","author":"Murray Derek G","year":"2011","unstructured":"Derek G Murray , Malte Schwarzkopf , Christopher Smowton , Steven Smith , Anil Madhavapeddy , and Steven Hand . 2011 . CIEL: a universal execution engine for distributed data-flow computing . In Proc. 8th ACM\/USENIX Symposium on Networked Systems Design and Implementation. 113--126 . Derek G Murray, Malte Schwarzkopf, Christopher Smowton, Steven Smith, Anil Madhavapeddy, and Steven Hand. 2011. CIEL: a universal execution engine for distributed data-flow computing. In Proc. 8th ACM\/USENIX Symposium on Networked Systems Design and Implementation. 113--126."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_32_1","DOI":"10.14778\/3137765.3137770"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_33_1","DOI":"10.1109\/TPDS.2019.2935727"},{"unstructured":"The pandas development team. 2020. pandas-dev\/pandas: Pandas. https:\/\/doi.org\/10.5281\/zenodo.3509134 10.5281\/zenodo.3509134","key":"#cr-split#-e_1_3_2_2_34_1.1"},{"unstructured":"The pandas development team. 2020. pandas-dev\/pandas: Pandas. https:\/\/doi.org\/10.5281\/zenodo.3509134","key":"#cr-split#-e_1_3_2_2_34_1.2"},{"key":"e_1_3_2_2_35_1","first-page":"1","article-title":"Self-Driving Database Management Systems","volume":"4","author":"Pavlo Andrew","year":"2017","unstructured":"Andrew Pavlo , Gustavo Angulo , Joy Arulraj , Haibin Lin , Jiexi Lin , Lin Ma , Prashanth Menon , Todd C Mowry , Matthew Perron , Ian Quah , 2017 . Self-Driving Database Management Systems .. In CIDR , Vol. 4. 1 . Andrew Pavlo, Gustavo Angulo, Joy Arulraj, Haibin Lin, Jiexi Lin, Lin Ma, Prashanth Menon, Todd C Mowry, Matthew Perron, Ian Quah, et al. 2017. Self-Driving Database Management Systems.. In CIDR, Vol. 4. 1.","journal-title":"CIDR"},{"key":"e_1_3_2_2_36_1","volume-title":"Scikit-learn: Machine learning in Python. the Journal of machine Learning research 12","author":"Pedregosa Fabian","year":"2011","unstructured":"Fabian Pedregosa , Ga\u00ebl Varoquaux , Alexandre Gramfort , Vincent Michel , Bertrand Thirion , Olivier Grisel , Mathieu Blondel , Peter Prettenhofer , Ron Weiss , Vincent Dubourg , 2011 . Scikit-learn: Machine learning in Python. the Journal of machine Learning research 12 (2011), 2825--2830. Fabian Pedregosa, Ga\u00ebl Varoquaux, Alexandre Gramfort, Vincent Michel, Bertrand Thirion, Olivier Grisel, Mathieu Blondel, Peter Prettenhofer, Ron Weiss, Vincent Dubourg, et al. 2011. Scikit-learn: Machine learning in Python. the Journal of machine Learning research 12 (2011), 2825--2830."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_37_1","DOI":"10.1007\/s00778-015-0411-4"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_38_1","DOI":"10.1145\/2465351.2465353"},{"unstructured":"Stefan Ricther and Chris Ward. 2018. Managing Large State in Apache Flink: An Intro to Incremental Checkpointing. https:\/\/flink.apache.org\/features\/2018\/01\/30\/incremental-checkpointing.html.  Stefan Ricther and Chris Ward. 2018. Managing Large State in Apache Flink: An Intro to Incremental Checkpointing. https:\/\/flink.apache.org\/features\/2018\/01\/30\/incremental-checkpointing.html.","key":"e_1_3_2_2_39_1"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_40_1","DOI":"10.1145\/2675743.2771827"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_41_1","DOI":"10.1145\/2588555.2595641"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_42_1","DOI":"10.1145\/79173.79181"},{"key":"e_1_3_2_2_43_1","volume-title":"Proceedings of the 9th USENIX conference on Networked Systems Design and Implementation. USENIX Association, 2--2.","author":"Zaharia Matei","year":"2012","unstructured":"Matei Zaharia , Mosharaf Chowdhury , Tathagata Das , Ankur Dave , Justin Ma , Murphy McCauley , Michael J Franklin , Scott Shenker , and Ion Stoica . 2012 . Resilient distributed datasets: A fault-tolerant abstraction for in-memory cluster computing . In Proceedings of the 9th USENIX conference on Networked Systems Design and Implementation. USENIX Association, 2--2. Matei Zaharia, Mosharaf Chowdhury, Tathagata Das, Ankur Dave, Justin Ma, Murphy McCauley, Michael J Franklin, Scott Shenker, and Ion Stoica. 2012. Resilient distributed datasets: A fault-tolerant abstraction for in-memory cluster computing. In Proceedings of the 9th USENIX conference on Networked Systems Design and Implementation. USENIX Association, 2--2."},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_44_1","DOI":"10.1145\/2517349.2522737"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_45_1","DOI":"10.14778\/2536274.2536319"},{"doi-asserted-by":"publisher","key":"e_1_3_2_2_46_1","DOI":"10.1145\/3132747.3132777"}],"event":{"sponsor":["SIGMOD ACM Special Interest Group on Management of Data","SIGOPS ACM Special Interest Group on Operating Systems"],"acronym":"SoCC '21","name":"SoCC '21: ACM Symposium on Cloud Computing","location":"Seattle WA USA"},"container-title":["Proceedings of the ACM Symposium on Cloud Computing"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3472883.3487010","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3472883.3487010","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,17]],"date-time":"2025-06-17T20:11:57Z","timestamp":1750191117000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3472883.3487010"}},"subtitle":["Task-Centric Data Stream Reconfiguration"],"short-title":[],"issued":{"date-parts":[[2021,11]]},"references-count":47,"alternative-id":["10.1145\/3472883.3487010","10.1145\/3472883"],"URL":"https:\/\/doi.org\/10.1145\/3472883.3487010","relation":{},"subject":[],"published":{"date-parts":[[2021,11]]},"assertion":[{"value":"2021-11-01","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}