{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,2,22]],"date-time":"2026-02-22T07:34:10Z","timestamp":1771745650350,"version":"3.50.1"},"reference-count":37,"publisher":"Springer Science and Business Media LLC","issue":"5","license":[{"start":{"date-parts":[[2025,4,10]],"date-time":"2025-04-10T00:00:00Z","timestamp":1744243200000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2025,4,10]],"date-time":"2025-04-10T00:00:00Z","timestamp":1744243200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"}],"funder":[{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"publisher","award":["62372419"],"award-info":[{"award-number":["62372419"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"publisher","award":["62372419"],"award-info":[{"award-number":["62372419"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100012226","name":"Fundamental Research Funds for the Central Universities","doi-asserted-by":"publisher","award":["265QZ2021001"],"award-info":[{"award-number":["265QZ2021001"]}],"id":[{"id":"10.13039\/501100012226","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Supercomput"],"DOI":"10.1007\/s11227-025-07216-8","type":"journal-article","created":{"date-parts":[[2025,4,10]],"date-time":"2025-04-10T09:40:25Z","timestamp":1744278025000},"update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":2,"title":["An elastic reconfiguration strategy for operators in distributed stream computing systems"],"prefix":"10.1007","volume":"81","author":[{"given":"Dawei","family":"Sun","sequence":"first","affiliation":[]},{"given":"Yinuo","family":"Fan","sequence":"additional","affiliation":[]},{"given":"Chengjun","family":"Guan","sequence":"additional","affiliation":[]},{"given":"Jia","family":"Rong","sequence":"additional","affiliation":[]},{"given":"Shang","family":"Gao","sequence":"additional","affiliation":[]},{"given":"Rajkumar","family":"Buyya","sequence":"additional","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2025,4,10]]},"reference":[{"key":"7216_CR1","doi-asserted-by":"crossref","unstructured":"Gonzalez-Guerrero P, Stan MR (2019) Asynchronous stream computing for low power IoT. In: 2019 IEEE 62nd international midwest symposium on circuits and systems (MWSCAS), pp 1135\u20131138 (2019). IEEE","DOI":"10.1109\/MWSCAS.2019.8885388"},{"key":"7216_CR2","doi-asserted-by":"crossref","unstructured":"Juneja A, Das NN (2019) Big data quality framework: pre-processing data in weather monitoring application. In: 2019 International conference on machine learning, big data, cloud and parallel computing (COMITCon), pp 559\u2013563. IEEE","DOI":"10.1109\/COMITCon.2019.8862267"},{"key":"7216_CR3","doi-asserted-by":"crossref","unstructured":"Imai S, Patterson S, Varela CA (2017) Maximum sustainable throughput prediction for data stream processing over public clouds. In: 2017 17th IEEE\/ACM International Symposium on Cluster, Cloud and Grid Computing (CCGRID), pp 504\u2013513. IEEE","DOI":"10.1109\/CCGRID.2017.105"},{"key":"7216_CR4","unstructured":"Apache Storm, http:\/\/storm.apache\/org\/, last accessed 03 Dec 2023"},{"key":"7216_CR5","unstructured":"Apache Samza, http:\/\/samza.apache.org\/, last accessed 03 Dec 2023"},{"key":"7216_CR6","unstructured":"Apache Flink, http:\/\/flink.apache.org\/, last accessed 2023\/12\/03"},{"key":"7216_CR7","unstructured":"Twitter Heron, https:\/\/github.com\/apache\/incubator-heron, last accessed 03 Dec 2023"},{"key":"7216_CR8","unstructured":"Spark streaming. https:\/\/spark.apache.org\/, last accessed 03 Dec 2023"},{"key":"7216_CR9","doi-asserted-by":"publisher","first-page":"109","DOI":"10.1016\/j.jnca.2017.01.039","volume":"84","author":"MI Alghamdi","year":"2017","unstructured":"Alghamdi MI, Jiang X, Zhang J, Zhang J, Jiang M, Qin X (2017) Towards two-phase scheduling of real-time applications in distributed systems. J Netw Comput Appl 84:109\u2013117","journal-title":"J Netw Comput Appl"},{"key":"7216_CR10","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1016\/j.jnca.2017.12.001","volume":"103","author":"MD Assuncao","year":"2018","unstructured":"Assuncao MD, Silva Veith A, Buyya R (2018) Distributed data stream processing and edge computing: a survey on resource elasticity and future directions. J Netw Comput Appl 103:1\u201317","journal-title":"J Netw Comput Appl"},{"issue":"6","key":"7216_CR11","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 K-L (2013) Elastic scaling for data stream processing. IEEE Trans Parallel Distrib Syst 25(6):1447\u20131463","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"7216_CR12","doi-asserted-by":"publisher","first-page":"617","DOI":"10.1016\/j.future.2018.07.011","volume":"89","author":"L Eskandari","year":"2018","unstructured":"Eskandari L, Mair J, Huang Z, Eyers D (2018) T3-scheduler: a topology and traffic aware two-level scheduler for stream processing systems in a heterogeneous cluster. Futur Gener Comput Syst 89:617\u2013632","journal-title":"Futur Gener Comput Syst"},{"issue":"9","key":"7216_CR13","doi-asserted-by":"publisher","first-page":"4334","DOI":"10.1002\/cpe.4334","volume":"30","author":"V Cardellini","year":"2018","unstructured":"Cardellini V, Lo Presti F, Nardelli M, Russo Russo G (2018) Optimal operator deployment and replication for elastic distributed data stream processing. Concurr Comput: Pract Exp 30(9):4334","journal-title":"Concurr Comput: Pract Exp"},{"issue":"10","key":"7216_CR14","doi-asserted-by":"publisher","first-page":"2223","DOI":"10.1109\/TPDS.2018.2827380","volume":"29","author":"J Fang","year":"2018","unstructured":"Fang J, Zhang R, Fu TZ, Zhang Z, Zhou A, Zhou X (2018) Distributed stream rebalance for stateful operator under workload variance. IEEE Trans Parallel Distrib Syst 29(10):2223\u20132240","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"7216_CR15","doi-asserted-by":"crossref","unstructured":"Hesse G, Matthies C, Glass K, Huegle J, Uflacker M (2019) Quantitative impact evaluation of an abstraction layer for data stream processing systems. In: 2019 IEEE 39th International Conference on Distributed Computing Systems (ICDCS), pp 1381\u20131392. IEEE","DOI":"10.1109\/ICDCS.2019.00138"},{"issue":"6","key":"7216_CR16","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"},{"issue":"8","key":"7216_CR17","doi-asserted-by":"publisher","first-page":"1753","DOI":"10.1109\/TPDS.2019.2896115","volume":"30","author":"M Nardelli","year":"2019","unstructured":"Nardelli M, Cardellini V, Grassi V, Presti FL (2019) Efficient operator placement for distributed data stream processing applications. IEEE Trans Parallel Distrib Syst 30(8):1753\u20131767","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"7216_CR18","doi-asserted-by":"crossref","unstructured":"Zhang Z, Jin P, Wang X, Liu R, Wan S (2019) N-storm: efficient thread-level task migration in Apache Storm. 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), pp 1595\u20131602. IEEE","DOI":"10.1109\/HPCC\/SmartCity\/DSS.2019.00219"},{"issue":"12","key":"7216_CR19","doi-asserted-by":"publisher","first-page":"3553","DOI":"10.1109\/TPDS.2017.2723403","volume":"28","author":"T Buddhika","year":"2017","unstructured":"Buddhika T, Stern R, Lindburg K, Ericson K, Pallickara S (2017) Online scheduling and interference alleviation for low-latency, high-throughput processing of data streams. IEEE Trans Parallel Distrib Syst 28(12):3553\u20133569","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"7216_CR20","doi-asserted-by":"crossref","unstructured":"Aniello L, Baldoni R, Querzoni L (2013) Adaptive online scheduling in storm. In: Proceedings of the 7th ACM International Conference on Distributed Event-based Systems, pp 207\u2013218 (2013)","DOI":"10.1145\/2488222.2488267"},{"key":"7216_CR21","doi-asserted-by":"crossref","unstructured":"Madsen KGS, Zhou Y, Cao J (2017) Integrative dynamic reconfiguration in a parallel stream processing engine. In: 2017 IEEE 33rd International Conference on Data Engineering (ICDE), pp 227\u2013230. IEEE","DOI":"10.1109\/ICDE.2017.81"},{"key":"7216_CR22","doi-asserted-by":"crossref","unstructured":"Tang K, Hao Z, Cai R, Fu TZ, Yang Y, Wang L, Winslett M, Zhang Z (2020) Drs+: load shedding meets resource auto-scaling in distributed stream processing. In: 2020 IEEE 22nd International Conference on High Performance Computing and Communications; IEEE 18th International Conference on Smart City; IEEE 6th International Conference on Data Science and Systems (HPCC\/SmartCity\/DSS), pp 292\u2013301","DOI":"10.1109\/HPCC-SmartCity-DSS50907.2020.00036"},{"key":"7216_CR23","doi-asserted-by":"crossref","unstructured":"Cardellini V, Nardelli M, Luzi D (2016) Elastic stateful stream processing in storm. In: 2016 International Conference on High Performance Computing & Simulation (HPCS), pp 583\u2013590. IEEE","DOI":"10.1109\/HPCSim.2016.7568388"},{"issue":"11","key":"7216_CR24","doi-asserted-by":"publisher","first-page":"13276","DOI":"10.1007\/s11227-022-04376-9","volume":"78","author":"W Li","year":"2022","unstructured":"Li W, Zhang Z, Shu Y, Liu H, Liu T (2022) Toward optimal operator parallelism for stream processing topology with limited buffers. J Supercomput 78(11):13276\u201313297","journal-title":"J Supercomput"},{"issue":"1","key":"7216_CR25","doi-asserted-by":"publisher","first-page":"181201","DOI":"10.1007\/s11704-022-1706-4","volume":"18","author":"S Liu","year":"2024","unstructured":"Liu S, Li Y, Yang H, Dun M, Chen C, Zhang H, Li W (2024) QAAS: quick accurate auto-scaling for streaming processing. Front Comput Sci 18(1):181201","journal-title":"Front Comput Sci"},{"issue":"3","key":"7216_CR26","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":"7216_CR27","doi-asserted-by":"crossref","unstructured":"Mao Y, Huang Y, Tian R, Wang X, Ma RT (2021) Trisk: task-centric data stream reconfiguration. In: Proceedings of the ACM Symposium on Cloud Computing, pp. 214\u2013228","DOI":"10.1145\/3472883.3487010"},{"key":"7216_CR28","doi-asserted-by":"publisher","first-page":"116322","DOI":"10.1016\/j.eswa.2021.116322","volume":"191","author":"M Farrokh","year":"2022","unstructured":"Farrokh M, Hadian H, Sharifi M, Jafari A (2022) Sp-ant: An ant colony optimization based operator scheduler for high performance distributed stream processing on heterogeneous clusters. Expert Syst Appl 191:116322","journal-title":"Expert Syst Appl"},{"key":"7216_CR29","doi-asserted-by":"crossref","unstructured":"Li H, Xia J, Luo W, Fang H (2022) Cost-efficient scheduling of streaming applications in Apache Flink on cloud. IEEE Trans Big Data","DOI":"10.1109\/TBDATA.2022.3233031"},{"issue":"4","key":"7216_CR30","doi-asserted-by":"publisher","first-page":"2863","DOI":"10.1109\/TCC.2020.3032577","volume":"10","author":"X Huang","year":"2020","unstructured":"Huang X, Shao Z, Yang Y (2020) Potus: Predictive online tuple scheduling for data stream processing systems. IEEE Trans Cloud Comput 10(4):2863\u20132875","journal-title":"IEEE Trans Cloud Comput"},{"key":"7216_CR31","doi-asserted-by":"crossref","unstructured":"Li W, Liu D, Chen K, Li K, Qi H (2021) Hone: Mitigating stragglers in distributed stream processing with tuple scheduling. IEEE Trans Parallel Distri Syst 32(8)","DOI":"10.1109\/TPDS.2021.3051059"},{"key":"7216_CR32","doi-asserted-by":"crossref","unstructured":"Li H, Wu J, Jiang Z, Li X, Wei X (2017) Task allocation for stream processing with recovery latency guarantee. In: 2017 IEEE international conference on cluster computing (CLUSTER), pp 379\u2013383. IEEE","DOI":"10.1109\/CLUSTER.2017.10"},{"issue":"12","key":"7216_CR33","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":"7216_CR34","unstructured":"Kalavri V, Liagouris J, Hoffmann M, Dimitrova D, Forshaw M, Roscoe T (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), pp 783\u2013798"},{"key":"7216_CR35","doi-asserted-by":"crossref","unstructured":"Sun D, Guan C, Fan Y, Rong J, Gao S (2023) A latency guaranteed scheduling strategy under performance constraints in big data stream computing environments. In: 2023 International Conference on Parallel and Distributed Systems (ICPADS)","DOI":"10.1109\/ICPADS60453.2023.00363"},{"key":"7216_CR36","doi-asserted-by":"crossref","unstructured":"Karimov J, et al (2018) Benchmarking distributed stream data processing systems. In: 2018 IEEE 34th International Conference on Data Engineering (ICDE)","DOI":"10.1109\/ICDE.2018.00169"},{"key":"7216_CR37","unstructured":"Aliyun (2025) User behavior data from taobao for recommendation. [Online] Available at: https:\/\/tianchi.aliyun.com\/dataset\/649?t=1679727494514. Accessed 22 Feb 2025"}],"container-title":["The Journal of Supercomputing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-025-07216-8.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s11227-025-07216-8\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-025-07216-8.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,4,10]],"date-time":"2025-04-10T09:40:48Z","timestamp":1744278048000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s11227-025-07216-8"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2025,4,10]]},"references-count":37,"journal-issue":{"issue":"5","published-online":{"date-parts":[[2025,4]]}},"alternative-id":["7216"],"URL":"https:\/\/doi.org\/10.1007\/s11227-025-07216-8","relation":{},"ISSN":["1573-0484"],"issn-type":[{"value":"1573-0484","type":"electronic"}],"subject":[],"published":{"date-parts":[[2025,4,10]]},"assertion":[{"value":"17 March 2025","order":1,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"10 April 2025","order":2,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}},{"order":1,"name":"Ethics","group":{"name":"EthicsHeading","label":"Declarations"}},{"value":"The authors declare no competing interests.","order":2,"name":"Ethics","group":{"name":"EthicsHeading","label":"Competing Interests"}}],"article-number":"722"}}