{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,10]],"date-time":"2026-03-10T15:18:42Z","timestamp":1773155922678,"version":"3.50.1"},"publisher-location":"Cham","reference-count":23,"publisher":"Springer International Publishing","isbn-type":[{"value":"9783030953904","type":"print"},{"value":"9783030953911","type":"electronic"}],"license":[{"start":{"date-parts":[[2022,1,1]],"date-time":"2022-01-01T00:00:00Z","timestamp":1640995200000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"},{"start":{"date-parts":[[2022,1,1]],"date-time":"2022-01-01T00:00:00Z","timestamp":1640995200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":[],"published-print":{"date-parts":[[2022]]},"DOI":"10.1007\/978-3-030-95391-1_9","type":"book-chapter","created":{"date-parts":[[2022,2,22]],"date-time":"2022-02-22T09:04:54Z","timestamp":1645520694000},"page":"133-151","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":6,"title":["AutoFlow: Hotspot-Aware, Dynamic Load Balancing for\u00a0Distributed Stream Processing"],"prefix":"10.1007","author":[{"given":"Pengqi","family":"Lu","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Yue","family":"Yue","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Liang","family":"Yuan","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Yunquan","family":"Zhang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2022,2,23]]},"reference":[{"key":"9_CR1","unstructured":"gRPC. https:\/\/grpc.io\/"},{"key":"9_CR2","unstructured":"NEXMark benchmark. http:\/\/datalab.cs.pdx.edu\/niagara\/NEXMark\/"},{"issue":"11","key":"9_CR3","doi-asserted-by":"publisher","first-page":"1033","DOI":"10.14778\/2536222.2536229","volume":"6","author":"T Akidau","year":"2013","unstructured":"Akidau, T., et al.: MillWheel: fault-tolerant stream processing at internet scale. Proc. VLDB Endow. 6(11), 1033\u20131044 (2013)","journal-title":"Proc. VLDB Endow."},{"key":"9_CR4","doi-asserted-by":"crossref","unstructured":"Akidau, T., et al.: The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing (2015)","DOI":"10.14778\/2824032.2824076"},{"key":"9_CR5","doi-asserted-by":"crossref","unstructured":"Armbrust, M., et al.: Structured streaming: a declarative API for real-time applications in apache spark. In: International Conference on Management of Data, pp. 601\u2013613 (2018)","DOI":"10.1145\/3183713.3190664"},{"key":"9_CR6","unstructured":"Carbone, P., F\u00f3ra, G., Ewen, S., Haridi, S., Tzoumas, K.: Lightweight asynchronous snapshots for distributed dataflows. arXiv preprint arXiv:1506.08603 (2015)"},{"key":"9_CR7","unstructured":"Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., Tzoumas, K.: Apache Flink: stream and batch processing in a single engine. Bull. IEEE Comput. Soc. Tech. Committee Data Eng. 36(4) (2015)"},{"key":"9_CR8","doi-asserted-by":"crossref","unstructured":"Castro Fernandez, R., Migliavacca, M., Kalyvianaki, E., Pietzuch, P.: Integrating scale out and fault tolerance in stream processing using operator state management. In: ACM SIGMOD International Conference on Management of Data, pp. 725\u2013736 (2013)","DOI":"10.1145\/2463676.2465282"},{"key":"9_CR9","unstructured":"Dai, J., Huang, J., Huang, S., Huang, B., Liu, Y.: HiTune: dataflow-based performance analysis for big data cloud. In: ATC, pp. 87\u2013100 (2011)"},{"issue":"1","key":"9_CR10","doi-asserted-by":"publisher","first-page":"107","DOI":"10.1145\/1327452.1327492","volume":"51","author":"J Dean","year":"2008","unstructured":"Dean, J., Ghemawat, S.: MapReduce: simplified data processing on large clusters. Commun. ACM 51(1), 107\u2013113 (2008)","journal-title":"Commun. ACM"},{"issue":"12","key":"9_CR11","doi-asserted-by":"publisher","first-page":"1825","DOI":"10.14778\/3137765.3137786","volume":"10","author":"A Floratou","year":"2017","unstructured":"Floratou, A., Agrawal, A., Graham, B., Rao, S., Ramasamy, K.: Dhalion: self-regulating stream processing in heron. Proc. VLDB Endow. 10(12), 1825\u20131836 (2017)","journal-title":"Proc. VLDB Endow."},{"key":"9_CR12","unstructured":"Garduno, E., Kavulya, S.P., Tan, J., Gandhi, R., Narasimhan, P.: Theia: visual signatures for problem diagnosis in large Hadoop clusters. In: LISA\u201912, pp. 33\u201342 (2012)"},{"key":"9_CR13","unstructured":"Hoffmann, M., et al.: SnailTrail: generalizing critical paths for online analysis of distributed dataflows. In: NSDI\u201918, pp. 95\u2013110 (2018)"},{"issue":"9","key":"9_CR14","doi-asserted-by":"publisher","first-page":"1002","DOI":"10.14778\/3329772.3329777","volume":"12","author":"M Hoffmann","year":"2019","unstructured":"Hoffmann, M., Lattuada, A., McSherry, F.: Megaphone: latency-conscious state migration for distributed streaming dataflows. Proc. VLDB Endow. 12(9), 1002\u20131015 (2019)","journal-title":"Proc. VLDB Endow."},{"key":"9_CR15","unstructured":"Kalavri, V., Liagouris, J., Hoffmann, M., Dimitrova, D., Forshaw, M., Roscoe, T.: Three steps is all you need: fast, accurate, automatic scaling decisions for distributed streaming dataflows. In: OSDI\u201918, pp. 783\u2013798 (2018)"},{"key":"9_CR16","doi-asserted-by":"crossref","unstructured":"Kulkarni, S., et al.: Twitter Heron: stream processing at scale. In: the 2015 ACM SIGMOD International Conference on Management of Data, pp. 239\u2013250 (2015)","DOI":"10.1145\/2723372.2742788"},{"issue":"10","key":"9_CR17","doi-asserted-by":"publisher","first-page":"1303","DOI":"10.14778\/3231751.3231765","volume":"11","author":"L Mai","year":"2018","unstructured":"Mai, L., et al.: Chi: a scalable and programmable control plane for distributed stream processing systems. Proc. VLDB Endow. 11(10), 1303\u20131316 (2018)","journal-title":"Proc. VLDB Endow."},{"key":"9_CR18","unstructured":"Moritz, P., et al.: Ray: a distributed framework for emerging $$\\{$$AI$$\\}$$ applications. In: OSDI\u201918, pp. 561\u2013577 (2018)"},{"key":"9_CR19","doi-asserted-by":"crossref","unstructured":"Toshniwal, A., et al.: Storm@ twitter. In: ACM SIGMOD International Conference on Management of Data, pp. 147\u2013156 (2014)","DOI":"10.1145\/2588555.2595641"},{"key":"9_CR20","doi-asserted-by":"crossref","unstructured":"Wang, S., et al.: Lineage stash: fault tolerance off the critical path. In: SOSP\u201919, pp. 338\u2013352 (2019)","DOI":"10.1145\/3341301.3359653"},{"key":"9_CR21","volume-title":"Hadoop: The Definitive Guide","author":"T White","year":"2012","unstructured":"White, T.: Hadoop: The Definitive Guide. O\u2019Reilly Media, Inc., Newton (2012)"},{"key":"9_CR22","unstructured":"Zaharia, M., et al.: Resilient distributed datasets: a fault-tolerant abstraction for in-memory cluster computing. In: NSDI\u201912, pp. 15\u201328 (2012)"},{"key":"9_CR23","doi-asserted-by":"crossref","unstructured":"Zaharia, M., Das, T., Li, H., Hunter, T., Shenker, S., Stoica, I.: Discretized streams: fault-tolerant streaming computation at scale. In: SOSP\u201913, pp. 423\u2013438 (2013)","DOI":"10.1145\/2517349.2522737"}],"container-title":["Lecture Notes in Computer Science","Algorithms and Architectures for Parallel Processing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/978-3-030-95391-1_9","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2022,2,22]],"date-time":"2022-02-22T09:05:46Z","timestamp":1645520746000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/978-3-030-95391-1_9"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2022]]},"ISBN":["9783030953904","9783030953911"],"references-count":23,"URL":"https:\/\/doi.org\/10.1007\/978-3-030-95391-1_9","relation":{},"ISSN":["0302-9743","1611-3349"],"issn-type":[{"value":"0302-9743","type":"print"},{"value":"1611-3349","type":"electronic"}],"subject":[],"published":{"date-parts":[[2022]]},"assertion":[{"value":"23 February 2022","order":1,"name":"first_online","label":"First Online","group":{"name":"ChapterHistory","label":"Chapter History"}},{"value":"ICA3PP","order":1,"name":"conference_acronym","label":"Conference Acronym","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"International Conference on Algorithms and Architectures for Parallel Processing","order":2,"name":"conference_name","label":"Conference Name","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"2021","order":5,"name":"conference_year","label":"Conference Year","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"3 December 2021","order":7,"name":"conference_start_date","label":"Conference Start Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"5 December 2021","order":8,"name":"conference_end_date","label":"Conference End Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"21","order":9,"name":"conference_number","label":"Conference Number","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"ica3pp2021","order":10,"name":"conference_id","label":"Conference ID","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"http:\/\/nsclab.org\/ica3pp2021\/index.html","order":11,"name":"conference_url","label":"Conference URL","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"Single-blind","order":1,"name":"type","label":"Type","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"EasyChair","order":2,"name":"conference_management_system","label":"Conference Management System","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"403","order":3,"name":"number_of_submissions_sent_for_review","label":"Number of Submissions Sent for Review","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"145","order":4,"name":"number_of_full_papers_accepted","label":"Number of Full Papers Accepted","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"0","order":5,"name":"number_of_short_papers_accepted","label":"Number of Short Papers Accepted","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"36% - The value is computed by the equation \"Number of Full Papers Accepted \/ Number of Submissions Sent for Review * 100\" and then rounded to a whole number.","order":6,"name":"acceptance_rate_of_full_papers","label":"Acceptance Rate of Full Papers","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"3.12","order":7,"name":"average_number_of_reviews_per_paper","label":"Average Number of Reviews per Paper","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"2.27","order":8,"name":"average_number_of_papers_per_reviewer","label":"Average Number of Papers per Reviewer","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"Yes","order":9,"name":"external_reviewers_involved","label":"External Reviewers Involved","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}}]}}