{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,4,10]],"date-time":"2025-04-10T10:14:30Z","timestamp":1744280070619,"version":"3.37.3"},"reference-count":39,"publisher":"Springer Science and Business Media LLC","issue":"11","license":[{"start":{"date-parts":[[2022,3,16]],"date-time":"2022-03-16T00:00:00Z","timestamp":1647388800000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"},{"start":{"date-parts":[[2022,3,16]],"date-time":"2022-03-16T00:00:00Z","timestamp":1647388800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"}],"funder":[{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"publisher","award":["62171155"],"award-info":[{"award-number":["62171155"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Supercomput"],"published-print":{"date-parts":[[2022,7]]},"DOI":"10.1007\/s11227-022-04376-9","type":"journal-article","created":{"date-parts":[[2022,3,16]],"date-time":"2022-03-16T04:43:35Z","timestamp":1647405815000},"page":"13276-13297","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":4,"title":["Toward optimal operator parallelism for stream processing topology with limited buffers"],"prefix":"10.1007","volume":"78","author":[{"given":"Wenhao","family":"Li","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zhan","family":"Zhang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Yanjun","family":"Shu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-9215-7173","authenticated-orcid":false,"given":"Hongwei","family":"Liu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Tianming","family":"Liu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2022,3,16]]},"reference":[{"key":"4376_CR1","doi-asserted-by":"publisher","first-page":"9","DOI":"10.14445\/22312803\/IJCTT-V19P103","volume":"19","author":"MH Iqbal","year":"2015","unstructured":"Iqbal MH, Soomro TR (2015) Big data analysis: apache storm perspective. Int J Comput Trends Technol 19:9\u201314","journal-title":"Int J Comput Trends Technol"},{"issue":"4","key":"4376_CR2","first-page":"28","volume":"36","author":"P Carbone","year":"2015","unstructured":"Carbone P, Katsifodimos A, Ewen S, Markl V, Haridi S, Tzoumas K (2015) Apache Flink: Stream and Batch Processing in a Single Engine. Bull IEEE Comput Soc Tech Committee Data Eng 36(4):28\u201338","journal-title":"Bull IEEE Comput Soc Tech Committee Data Eng"},{"key":"4376_CR3","unstructured":"Liu X (2018) Robust resource management in distributed stream processing systems. Doctoral dissertation"},{"key":"4376_CR4","doi-asserted-by":"crossref","unstructured":"Cervino J, Kalyvianaki E, Salvachua J, Pietzuch P (2012) Adaptive provisioning of stream processing systems in the cloud. In: 2012 IEEE 28th International Conference on Data Engineering Workshops. IEEE, pp 295\u2013301","DOI":"10.1109\/ICDEW.2012.40"},{"key":"4376_CR5","doi-asserted-by":"crossref","unstructured":"Lohrmann B, Warneke D, Kao O (2012) Massively-parallel stream processing under QoS constraints with nephele. In: Proceedings of the 21st international symposium on high-performance parallel and distributed computing, pp 271\u2013282","DOI":"10.1145\/2287076.2287117"},{"key":"4376_CR6","doi-asserted-by":"crossref","unstructured":"Wilmanns PS, Geuns SJ, Hausmans JP, Bekooij MJ (2015) Buffer sizing to reduce interference and increase throughput of real-time stream processing applications. In: 2015 IEEE 18th international symposium on real-time distributed computing. IEEE, pp 9\u201318","DOI":"10.1109\/ISORC.2015.14"},{"issue":"3","key":"4376_CR7","doi-asserted-by":"publisher","first-page":"192","DOI":"10.1089\/big.2018.0093","volume":"7","author":"M Mudassar","year":"2019","unstructured":"Mudassar M, Zhai Y, Liao L (2019) Efficient state management for scaling out stateful operators in stream processing systems. Big data 7(3):192\u2013206","journal-title":"Big data"},{"issue":"12","key":"4376_CR8","doi-asserted-by":"publisher","first-page":"2351","DOI":"10.1109\/TPDS.2012.24","volume":"23","author":"V Gulisano","year":"2012","unstructured":"Gulisano V, Jimenez-Peris R, Patino-Martinez M, Soriente C, Valduriez P (2012) Streamcloud: an elastic and scalable data streaming system. IEEE Trans Parallel Distrib Syst 23(12):2351\u20132365","journal-title":"IEEE Trans Parallel Distrib Syst"},{"issue":"3","key":"4376_CR9","doi-asserted-by":"publisher","first-page":"572","DOI":"10.1109\/TPDS.2017.2762683","volume":"29","author":"F Lombardi","year":"2017","unstructured":"Lombardi F, Aniello L, Bonomi S, Querzoni L (2017) Elastic symbiotic scaling of operators and resources in stream processing systems. IEEE Trans Parallel Distrib Syst 29(3):572\u2013585","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"4376_CR10","doi-asserted-by":"crossref","unstructured":"Kombi RK, Lumineau N, Lamarre P (2017) A preventive auto-parallelization approach for elastic stream processing. In: 2017 IEEE 37th International Conference on Distributed Computing Systems (ICDCS). IEEE, pp 1532\u20131542","DOI":"10.1109\/ICDCS.2017.253"},{"issue":"10","key":"4376_CR11","doi-asserted-by":"publisher","first-page":"2326","DOI":"10.1109\/TPDS.2019.2907950","volume":"30","author":"V Marangozova-Martin","year":"2019","unstructured":"Marangozova-Martin V, De Palma N, El Rheddane A (2019) Multi-level elasticity for data stream processing. IEEE Trans Parallel Distrib Syst 30(10):2326\u20132337","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"4376_CR12","doi-asserted-by":"crossref","unstructured":"Sahni J, Vidyarthi DP (2021) Heterogeneity-aware elastic scaling of streaming applications on cloud platforms. J Supercomput 1\u201328","DOI":"10.1007\/s11227-021-03692-w"},{"key":"4376_CR13","doi-asserted-by":"publisher","first-page":"205","DOI":"10.1016\/j.jpdc.2019.10.012","volume":"137","author":"B Kahveci","year":"2020","unstructured":"Kahveci B, Gedik B (2020) Joker: elastic stream processing with organic adaptation. J Parallel Distrib Comput 137:205\u2013223","journal-title":"J Parallel Distrib Comput"},{"issue":"6","key":"4376_CR14","doi-asserted-by":"publisher","first-page":"1447","DOI":"10.1109\/TPDS.2013.295","volume":"25","author":"B Gedik","year":"2013","unstructured":"Gedik B, Schneider S, Hirzel M, Wu KL (2013) Elastic scaling for data stream processing. IEEE Trans Parallel Distrib Syst 25(6):1447\u20131463","journal-title":"IEEE Trans Parallel Distrib Syst"},{"issue":"12","key":"4376_CR15","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 (2017) Dhalion: self-regulating stream processing in heron. Proc VLDB Endow 10(12):1825\u20131836","journal-title":"Proc VLDB Endow"},{"key":"4376_CR16","doi-asserted-by":"crossref","unstructured":"Xu L, Peng B, Gupta I (2016) Stela: enabling stream processing systems to scale-in and scale-out on-demand. In: 2016 IEEE International Conference on Cloud Engineering (IC2E). IEEE, pp 22\u201331","DOI":"10.1109\/IC2E.2016.38"},{"key":"4376_CR17","doi-asserted-by":"crossref","unstructured":"Zacheilas N, Kalogeraki V, Zygouras N, Panagiotou N, Gunopulos D (2015) Elastic complex event processing exploiting prediction. In: 2015 IEEE International Conference on Big Data (Big Data). IEEE, pp 213\u2013222","DOI":"10.1109\/BigData.2015.7363758"},{"issue":"12","key":"4376_CR18","doi-asserted-by":"publisher","first-page":"2669","DOI":"10.1109\/TKDE.2017.2751606","volume":"29","author":"C Wang","year":"2017","unstructured":"Wang C, Meng X, Guo Q, Weng Z, Yang C (2017) Automating characterization deployment in distributed data stream management systems. IEEE Trans Knowl Data Eng 29(12):2669\u20132681","journal-title":"IEEE Trans Knowl Data Eng"},{"key":"4376_CR19","doi-asserted-by":"crossref","unstructured":"Yang Y, Zhao L, Li Z, Nie L, Chen P, Li K (2019) ElaX: provisioning resource elastically for containerized online cloud services. In: 2019 IEEE 21st International Conference on High Performance Computing and Communications; IEEE 17th International Conference on Smart City; IEEE 5th International Conference on Data Science and Systems (HPCC\/SmartCity\/DSS). IEEE, pp 1987\u20131994","DOI":"10.1109\/HPCC\/SmartCity\/DSS.2019.00274"},{"key":"4376_CR20","doi-asserted-by":"crossref","unstructured":"Foroni D, Axenie C, Bortoli S, Al Hajj Hassan M, Acker R, Tudoran R, Velegrakis Y (2018) Moira: a goal-oriented incremental machine learning approach to dynamic resource cost estimation in distributed stream processing systems. In: Proceedings of the international workshop on real-time business intelligence and analytics, pp 1\u201310","DOI":"10.1145\/3242153.3242160"},{"key":"4376_CR21","doi-asserted-by":"publisher","first-page":"342","DOI":"10.1016\/j.future.2019.03.003","volume":"98","author":"F Lombardi","year":"2019","unstructured":"Lombardi F, Muti A, Aniello L, Baldoni R, Bonomi S, Querzoni L (2019) PASCAL: an architecture for proactive auto-scaling of distributed services. Futur Gener Comput Syst 98:342\u2013361","journal-title":"Futur Gener Comput Syst"},{"key":"4376_CR22","doi-asserted-by":"crossref","unstructured":"Liu N, Li Z, Xu J, Xu Z, Lin S, Qiu Q, Wang Y (2017) A hierarchical framework of cloud resource allocation and power management using deep reinforcement learning. In: 2017 IEEE 37th International Conference on Distributed Computing Systems (ICDCS). IEEE, pp 372\u2013382","DOI":"10.1109\/ICDCS.2017.123"},{"key":"4376_CR23","doi-asserted-by":"crossref","unstructured":"Cardellini V, Presti FL, Nardelli M, Russo GR (2017) Auto-scaling in data stream processing applications: a model-based reinforcement learning approach. In: Workshop on new frontiers in quantitative methods in informatics. Springer, Cham, pp 97\u2013110","DOI":"10.1007\/978-3-319-91632-3_8"},{"key":"4376_CR24","doi-asserted-by":"crossref","unstructured":"Rossi F, Nardelli M, Cardellini V (2019) Horizontal and vertical scaling of container-based applications using reinforcement learning. In: 2019 IEEE 12th International Conference on Cloud Computing (CLOUD). IEEE, pp 329\u2013338","DOI":"10.1109\/CLOUD.2019.00061"},{"issue":"8","key":"4376_CR25","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/3016078.2851148","volume":"51","author":"T De Matteis","year":"2016","unstructured":"De Matteis T, Mencagli G (2016) Keep calm and react with foresight: strategies for low-latency and energy-efficient elastic data stream processing. ACM SIGPLAN Not 51(8):1\u201312","journal-title":"ACM SIGPLAN Not"},{"key":"4376_CR26","doi-asserted-by":"crossref","unstructured":"Farahabady MRH, Zomaya AY, Tari Z (2017) QoS-and contention-aware resource provisioning in a stream processing engine. In 2017 IEEE International Conference on Cluster Computing (CLUSTER). IEEE, pp 137\u2013146","DOI":"10.1109\/CLUSTER.2017.21"},{"issue":"7","key":"4376_CR27","doi-asserted-by":"publisher","first-page":"1628","DOI":"10.1109\/TPDS.2019.2891587","volume":"30","author":"X Wei","year":"2019","unstructured":"Wei X, Li L, Li X, Wang X, Gao S, Li H (2019) Pec: Proactive elastic collaborative resource scheduling in data stream processing. IEEE Trans Parallel Distrib Syst 30(7):1628\u20131642","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"4376_CR28","doi-asserted-by":"crossref","unstructured":"Nasir MAU, Morales GDF, Garcia-Soriano D, Kourtellis N, Serafini M (2015) The power of both choices: practical load balancing for distributed stream processing engines. In: 2015 IEEE 31st International Conference on Data Engineering. IEEE, pp 137\u2013148","DOI":"10.1109\/ICDE.2015.7113279"},{"issue":"3","key":"4376_CR29","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/2856127","volume":"48","author":"MC Calzarossa","year":"2016","unstructured":"Calzarossa MC, Massari L, Tessera D (2016) Workload characterization: a survey revisited. ACM Comput Surv 48(3):1\u201343","journal-title":"ACM Comput Surv"},{"issue":"2","key":"4376_CR30","doi-asserted-by":"publisher","first-page":"157","DOI":"10.1016\/0305-0548(88)90008-1","volume":"15","author":"L Kerbache","year":"1988","unstructured":"Kerbache L, Smith JM (1988) Asymptotic behavior of the expansion method for open finite queueing networks. Comput Oper Res 15(2):157\u2013169","journal-title":"Comput Oper Res"},{"key":"4376_CR31","doi-asserted-by":"publisher","DOI":"10.1007\/978-0-8176-8421-1","volume-title":"An introduction to queueing theory: modeling and analysis in applications","author":"UN Bhat","year":"2015","unstructured":"Bhat UN (2015) An introduction to queueing theory: modeling and analysis in applications. Birkh\u00e4user, Basel"},{"key":"4376_CR32","doi-asserted-by":"publisher","first-page":"373","DOI":"10.1109\/TSE.1980.234493","volume":"4","author":"J Labetoulle","year":"1980","unstructured":"Labetoulle J, Pujolle G (1980) Isolation method in a network of queues. IEEE Trans Softw Eng 4:373\u2013381","journal-title":"IEEE Trans Softw Eng"},{"issue":"1","key":"4376_CR33","doi-asserted-by":"publisher","first-page":"47","DOI":"10.1016\/0305-0548(77)90007-7","volume":"4","author":"WK Grassmann","year":"1977","unstructured":"Grassmann WK (1977) Transient solutions in Markovian queueing systems. Comput Oper Res 4(1):47\u201353","journal-title":"Comput Oper Res"},{"issue":"2","key":"4376_CR34","doi-asserted-by":"publisher","first-page":"163","DOI":"10.1111\/j.1937-5956.1996.tb00392.x","volume":"5","author":"GR Bitran","year":"1996","unstructured":"Bitran GR, Morabito R (1996) State-of-the-art survey: open queueing networks: optimization and performance evaluation models for discrete manufacturing systems. Prod Oper Manag 5(2):163\u2013193","journal-title":"Prod Oper Manag"},{"issue":"4","key":"4376_CR35","doi-asserted-by":"crossref","first-page":"1","DOI":"10.1145\/3132618","volume":"12","author":"X Liu","year":"2017","unstructured":"Liu X, Dastjerdi AV, Calheiros RN, Qu C, Buyya R (2017) A stepwise auto-profiling method for performance optimization of streaming applications. ACM Trans Auton Adapt Syst (TAAS) 12(4):1\u201333","journal-title":"ACM Trans Auton Adapt Syst (TAAS)"},{"issue":"6","key":"4376_CR36","doi-asserted-by":"publisher","first-page":"3338","DOI":"10.1109\/TNET.2017.2741969","volume":"25","author":"TZ Fu","year":"2017","unstructured":"Fu TZ, Ding J, Ma RT, Winslett M, Yang Y, Zhang Z (2017) DRS: auto-scaling for real-time stream analytics. IEEE\/ACM Trans Netw 25(6):3338\u20133352","journal-title":"IEEE\/ACM Trans Netw"},{"key":"4376_CR37","doi-asserted-by":"publisher","first-page":"40977","DOI":"10.1109\/ACCESS.2020.2976738","volume":"8","author":"Z Chu","year":"2020","unstructured":"Chu Z, Yu J, Hamdull A (2020) Maximum sustainable throughput evaluation using an adaptive method for stream processing platforms. IEEE Access 8:40977\u201340988","journal-title":"IEEE Access"},{"issue":"2","key":"4376_CR38","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/3303849","volume":"52","author":"H R\u00f6ger","year":"2019","unstructured":"R\u00f6ger H, Mayer R (2019) A comprehensive survey on parallelization and elasticity in stream processing. ACM Comput Surv (CSUR) 52(2):1\u201337","journal-title":"ACM Comput Surv (CSUR)"},{"key":"4376_CR39","doi-asserted-by":"crossref","unstructured":"Agnihotri P (2021) Autonomous resource management in distributed stream processing systems. In: Proceedings of the 22nd International Middleware Conference: Doctoral Symposium, pp 19\u201322","DOI":"10.1145\/3491087.3493680"}],"container-title":["The Journal of Supercomputing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-022-04376-9.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s11227-022-04376-9\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-022-04376-9.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,1,29]],"date-time":"2023-01-29T07:07:58Z","timestamp":1674976078000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s11227-022-04376-9"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2022,3,16]]},"references-count":39,"journal-issue":{"issue":"11","published-print":{"date-parts":[[2022,7]]}},"alternative-id":["4376"],"URL":"https:\/\/doi.org\/10.1007\/s11227-022-04376-9","relation":{},"ISSN":["0920-8542","1573-0484"],"issn-type":[{"type":"print","value":"0920-8542"},{"type":"electronic","value":"1573-0484"}],"subject":[],"published":{"date-parts":[[2022,3,16]]},"assertion":[{"value":"15 February 2022","order":1,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"16 March 2022","order":2,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}}]}}