{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,5]],"date-time":"2025-10-05T16:56:32Z","timestamp":1759683392476,"version":"3.41.0"},"publisher-location":"New York, NY, USA","reference-count":31,"publisher":"ACM","license":[{"start":{"date-parts":[[2022,6,27]],"date-time":"2022-06-27T00:00:00Z","timestamp":1656288000000},"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":[[2022,6,27]]},"DOI":"10.1145\/3524860.3539809","type":"proceedings-article","created":{"date-parts":[[2022,7,15]],"date-time":"2022-07-15T22:16:10Z","timestamp":1657923370000},"page":"55-66","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":1,"title":["Substream management in distributed streaming dataflows"],"prefix":"10.1145","author":[{"given":"Artem","family":"Trofimov","sequence":"first","affiliation":[{"name":"lzy.ai, Tel Aviv, Israel"}]},{"given":"Nikita","family":"Sokolov","sequence":"additional","affiliation":[{"name":"Yandex Cloud, Saint Petersburg, Russia"}]},{"given":"Nikita","family":"Marshalkin","sequence":"additional","affiliation":[{"name":"Limassol, Cyprus"}]},{"given":"Igor","family":"Kuralenok","sequence":"additional","affiliation":[{"name":"Huawei, Saint Petersburg, Russia"}]},{"given":"Boris","family":"Novikov","sequence":"additional","affiliation":[{"name":"HSE University, Saint Petersburg, Russia"}]}],"member":"320","published-online":{"date-parts":[[2022,7,15]]},"reference":[{"key":"e_1_3_2_1_1_1","doi-asserted-by":"publisher","DOI":"10.14778\/2536222.2536229"},{"key":"e_1_3_2_1_2_1","volume-title":"Streaming Systems: The What, Where, When, and how of Large-scale Data Processing","author":"Akidau T.","year":"2018","unstructured":"T. Akidau , S. Chernyak , and R. Lax . 2018 . Streaming Systems: The What, Where, When, and how of Large-scale Data Processing . O'Reilly Media, Inc orporated. https:\/\/books.google.ru\/books?id=48- BAQAACAAJ T. Akidau, S. Chernyak, and R. Lax. 2018. Streaming Systems: The What, Where, When, and how of Large-scale Data Processing. O'Reilly Media, Incorporated. https:\/\/books.google.ru\/books?id=48-BAQAACAAJ"},{"key":"e_1_3_2_1_3_1","volume-title":"Adaptive Watermarks: A Concept Drift-based Approach for Predicting Event-Time Progress in Data Streams. In EDBT. 622--625.","author":"Awad Ahmed","year":"2019","unstructured":"Ahmed Awad , Jonas Traub , and Sherif Sakr . 2019 . Adaptive Watermarks: A Concept Drift-based Approach for Predicting Event-Time Progress in Data Streams. In EDBT. 622--625. Ahmed Awad, Jonas Traub, and Sherif Sakr. 2019. Adaptive Watermarks: A Concept Drift-based Approach for Predicting Event-Time Progress in Data Streams. In EDBT. 622--625."},{"key":"e_1_3_2_1_4_1","doi-asserted-by":"publisher","DOI":"10.14778\/3476311.3476389"},{"key":"e_1_3_2_1_5_1","doi-asserted-by":"publisher","DOI":"10.1145\/3299869.3314040"},{"key":"e_1_3_2_1_7_1","first-page":"12","article-title":"State Management in Apache Flink\u00ae","volume":"10","author":"Carbone Paris","year":"2017","unstructured":"Paris Carbone , Stephan Ewen , Gyula F\u00f3ra , Seif Haridi , Stefan Richter , and Kostas Tzoumas . 2017 . State Management in Apache Flink\u00ae : Consistent Stateful Distributed Stream Processing. Proc. VLDB 10 , 12 (Aug. 2017), 1718--1729. Paris Carbone, Stephan Ewen, Gyula F\u00f3ra, Seif Haridi, Stefan Richter, and Kostas Tzoumas. 2017. State Management in Apache Flink\u00ae: Consistent Stateful Distributed Stream Processing. Proc. VLDB 10, 12 (Aug. 2017), 1718--1729.","journal-title":"Consistent Stateful Distributed Stream Processing. Proc. VLDB"},{"key":"e_1_3_2_1_8_1","unstructured":"P. Carbone G. F\u00f3ra S. Ewen S. Haridi and K. Tzoumas. 2015. Lightweight Asynchronous Snapshots for Distributed Dataflows. ArXiv e-prints (June 2015). arXiv:1506.08603 [cs.DC]  P. Carbone G. F\u00f3ra S. Ewen S. Haridi and K. Tzoumas. 2015. Lightweight Asynchronous Snapshots for Distributed Dataflows. ArXiv e-prints (June 2015). arXiv:1506.08603 [cs.DC]"},{"key":"e_1_3_2_1_9_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_1_10_1","doi-asserted-by":"publisher","DOI":"10.14778\/2735496.2735503"},{"key":"e_1_3_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.1145\/214451.214456"},{"key":"e_1_3_2_1_12_1","volume-title":"Scalejoin: A deterministic, disjoint-parallel and skew-resilient stream join","author":"Gulisano Vincenzo","year":"2016","unstructured":"Vincenzo Gulisano , Yiannis Nikolakopoulos , Marina Papatriantafilou , and Philippas Tsigas . 2016 . Scalejoin: A deterministic, disjoint-parallel and skew-resilient stream join . IEEE Transactions on Big Data ( 2016). Vincenzo Gulisano, Yiannis Nikolakopoulos, Marina Papatriantafilou, and Philippas Tsigas. 2016. Scalejoin: A deterministic, disjoint-parallel and skew-resilient stream join. IEEE Transactions on Big Data (2016)."},{"key":"e_1_3_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.14778\/3007263.3007272"},{"key":"e_1_3_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2018.00169"},{"key":"e_1_3_2_1_15_1","doi-asserted-by":"publisher","DOI":"10.1145\/2723372.2742788"},{"volume-title":"Advances in Databases and Information Systems, Andr\u00e1s Bencz\u00far","author":"Kuralenok Igor E.","key":"e_1_3_2_1_16_1","unstructured":"Igor E. Kuralenok , Artem Trofimov , Nikita Marshalkin , and Boris Novikov . 2018. Deterministic Model for Distributed Speculative Stream Processing . In Advances in Databases and Information Systems, Andr\u00e1s Bencz\u00far , Bernhard Thalheim , and Tom\u00e1\u0161 Horv\u00e1th (Eds.). Springer International Publishing , Cham, 233--246. Igor E. Kuralenok, Artem Trofimov, Nikita Marshalkin, and Boris Novikov. 2018. Deterministic Model for Distributed Speculative Stream Processing. In Advances in Databases and Information Systems, Andr\u00e1s Bencz\u00far, Bernhard Thalheim, and Tom\u00e1\u0161 Horv\u00e1th (Eds.). Springer International Publishing, Cham, 233--246."},{"key":"e_1_3_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.1145\/3206333.3209273"},{"key":"e_1_3_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.14778\/1453856.1453890"},{"key":"e_1_3_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_3_2_1_20_1","doi-asserted-by":"publisher","DOI":"10.1145\/3328905.3329509"},{"key":"e_1_3_2_1_21_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137770"},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.5555\/1287369.1287455"},{"key":"e_1_3_2_1_23_1","unstructured":"storm-site 2018. Apache Storm documentation Guaranteeing Message Processing. https:\/\/storm.apache.org\/releases\/current\/Guaranteeing-message-processing.html  storm-site 2018. Apache Storm documentation Guaranteeing Message Processing. https:\/\/storm.apache.org\/releases\/current\/Guaranteeing-message-processing.html"},{"key":"e_1_3_2_1_24_1","unstructured":"storm-site 2018. Apache Storm documentation Storm State Management. http:\/\/storm.apache.org\/releases\/1.2.1\/State-checkpointing.html  storm-site 2018. Apache Storm documentation Storm State Management. http:\/\/storm.apache.org\/releases\/1.2.1\/State-checkpointing.html"},{"key":"e_1_3_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1145\/2588555.2595641"},{"key":"e_1_3_2_1_27_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2003.1198390"},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2003.1198390"},{"key":"e_1_3_2_1_29_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2016.7498275"},{"key":"e_1_3_2_1_30_1","volume-title":"Proc. of the 4th USENIX Conf. on Hot Topics in Cloud Ccomputing","author":"Zaharia Matei","year":"2012","unstructured":"Matei Zaharia , Tathagata Das , Haoyuan Li , Scott Shenker , and Ion Stoica . 2012 . Discretized Streams: An Efficient and Fault-tolerant Model for Stream Processing on Large Clusters . In Proc. of the 4th USENIX Conf. on Hot Topics in Cloud Ccomputing ( Boston, MA) (HotCloud'12). USENIX Association, Berkeley, CA, USA, 10--10. Matei Zaharia, Tathagata Das, Haoyuan Li, Scott Shenker, and Ion Stoica. 2012. Discretized Streams: An Efficient and Fault-tolerant Model for Stream Processing on Large Clusters. In Proc. of the 4th USENIX Conf. on Hot Topics in Cloud Ccomputing (Boston, MA) (HotCloud'12). USENIX Association, Berkeley, CA, USA, 10--10."},{"key":"e_1_3_2_1_31_1","doi-asserted-by":"publisher","DOI":"10.14778\/3055330.3055335"},{"key":"e_1_3_2_1_32_1","doi-asserted-by":"publisher","DOI":"10.1145\/3132747.3132777"},{"key":"e_1_3_2_1_33_1","volume-title":"Research on Optimal Checkpointing-Interval for Flink Stream Processing Applications. Mobile Networks and Applications","author":"Zhang Zhan","year":"2021","unstructured":"Zhan Zhang , Wenhao Li , Xiao Qing , Xian Liu , and Hongwei Liu . 2021. Research on Optimal Checkpointing-Interval for Flink Stream Processing Applications. Mobile Networks and Applications ( 2021 ), 1--10. Zhan Zhang, Wenhao Li, Xiao Qing, Xian Liu, and Hongwei Liu. 2021. Research on Optimal Checkpointing-Interval for Flink Stream Processing Applications. Mobile Networks and Applications (2021), 1--10."}],"event":{"name":"DEBS '22: The 16th ACM International Conference on Distributed and Event-based Systems","sponsor":["SIGMOD ACM Special Interest Group on Management of Data","SIGSOFT ACM Special Interest Group on Software Engineering"],"location":"Copenhagen Denmark","acronym":"DEBS '22"},"container-title":["Proceedings of the 16th ACM International Conference on Distributed and Event-Based Systems"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3524860.3539809","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3524860.3539809","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,17]],"date-time":"2025-06-17T18:09:19Z","timestamp":1750183759000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3524860.3539809"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2022,6,27]]},"references-count":31,"alternative-id":["10.1145\/3524860.3539809","10.1145\/3524860"],"URL":"https:\/\/doi.org\/10.1145\/3524860.3539809","relation":{},"subject":[],"published":{"date-parts":[[2022,6,27]]},"assertion":[{"value":"2022-07-15","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}