{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,1,29]],"date-time":"2026-01-29T13:23:09Z","timestamp":1769692989556,"version":"3.49.0"},"reference-count":42,"publisher":"Springer Science and Business Media LLC","issue":"18","license":[{"start":{"date-parts":[[2023,6,18]],"date-time":"2023-06-18T00:00:00Z","timestamp":1687046400000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2023,6,18]],"date-time":"2023-06-18T00:00:00Z","timestamp":1687046400000},"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":["61972364"],"award-info":[{"award-number":["61972364"]}],"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":"crossref","award":["265QZ2021001"],"award-info":[{"award-number":["265QZ2021001"]}],"id":[{"id":"10.13039\/501100012226","id-type":"DOI","asserted-by":"crossref"}]},{"name":"Melbourne-Chindia Cloud Computing (MC3) Research Network, Australia"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Supercomput"],"published-print":{"date-parts":[[2023,12]]},"DOI":"10.1007\/s11227-023-05473-z","type":"journal-article","created":{"date-parts":[[2023,6,18]],"date-time":"2023-06-18T14:01:32Z","timestamp":1687096892000},"page":"21028-21056","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":5,"title":["A two-tier coordinated load balancing strategy over skewed data streams"],"prefix":"10.1007","volume":"79","author":[{"given":"Dawei","family":"Sun","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Minghui","family":"Wu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zhihong","family":"Yang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Atul","family":"Sajjanhar","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Rajkumar","family":"Buyya","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2023,6,18]]},"reference":[{"key":"5473_CR1","doi-asserted-by":"crossref","unstructured":"Liu S, Weng J, Wang J, An C, Zhou Y, Wang J (2019) An adaptive online scheme for scheduling and resource enforcement in storm. IEEE\/ACM Trans Netw (TON)","DOI":"10.1109\/TNET.2019.2918341"},{"key":"5473_CR2","doi-asserted-by":"crossref","unstructured":"Baig F, Teng D, Kong J, Wang (2021) Spear: dynamic spatio-temporal query processing over high velocity data streams. 2021 IEEE 37th International Conference on Data Engineering (ICDE), 2279\u20132284","DOI":"10.1109\/ICDE51399.2021.00237"},{"key":"5473_CR3","doi-asserted-by":"publisher","first-page":"6936","DOI":"10.1007\/s11227-020-03508-3","volume":"77","author":"V Kumar","year":"2021","unstructured":"Kumar V, Sharma DK, Mishra VK (2021) Mille cheval: a gpu-based in-memory high-performance computing framework for accelerated processing of big-data streams. J Supercomput 77:6936\u20136960","journal-title":"J Supercomput"},{"key":"5473_CR4","unstructured":"Aleem M, Islam A (2020) Top-storm: a topology-based resource-aware scheduler for stream processing engine. Cluster Comput J Netw Softw Tools Appl, 123\u2013124"},{"key":"5473_CR5","doi-asserted-by":"publisher","first-page":"461","DOI":"10.1007\/s11227-022-04669-z","volume":"79","author":"H Hadian","year":"2023","unstructured":"Hadian H, Farrokh M, Sharifi M, Jafari A (2023) An elastic and traffic-aware scheduler for distributed data stream processing in heterogeneous clusters. J Supercomput 79:461\u2013498","journal-title":"J Supercomput"},{"key":"5473_CR6","doi-asserted-by":"publisher","first-page":"1373","DOI":"10.1109\/TNET.2019.2918341","volume":"27","author":"C Liu","year":"2019","unstructured":"Liu C, Weng J, Wang J, An C, Zhou Y, Wang J (2019) An adaptive online scheme for scheduling and resource enforcement in storm. IEEE\/ACM Trans Netw 27:1373\u20131386","journal-title":"IEEE\/ACM Trans Netw"},{"key":"5473_CR7","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:13276\u201313297","journal-title":"J Supercomput"},{"key":"5473_CR8","doi-asserted-by":"crossref","unstructured":"Zhang Z, Jin PQ, Wang XL.(2019) N-storm: efficient thread-level task migration in apache storm. 2019 IEEE 21st International Conference on High Performance Computing and Communication, IEEE 14th International Conference on Smart City, IEEE 2nd International Conference on Data Science and Systems, 1595\u20131602","DOI":"10.1109\/HPCC\/SmartCity\/DSS.2019.00219"},{"key":"5473_CR9","doi-asserted-by":"crossref","unstructured":"Qian W, Shen Q, Qin J, Yang D, Yang Y, Wu Z (2016) A slot-aware scheduling strategy for even scheduler in storm. 18th International Conference on High Performance Computing and Communications, 623\u2013630","DOI":"10.1109\/HPCC-SmartCity-DSS.2016.0093"},{"key":"5473_CR10","doi-asserted-by":"crossref","unstructured":"Houatra D, Tseng Y (2018) Monitoring 5g radio access networks with cloud-based stream processing platforms. 2018 21st Conference on Innovation in Clouds, Internet and Networks and Workshops (ICIN), 1\u20135","DOI":"10.1109\/ICIN.2018.8401581"},{"key":"5473_CR11","doi-asserted-by":"publisher","first-page":"1395","DOI":"10.1109\/TII.2019.2946045","volume":"16","author":"Y Bi","year":"2020","unstructured":"Bi Y, Han G, Lin C (2020) Intelligent quality of service aware traffic forwarding for software-defined networking\/open shortest path first hybrid industrial internet. IEEE Trans Industr Inf 16:1395\u20131405","journal-title":"IEEE Trans Industr Inf"},{"key":"5473_CR12","doi-asserted-by":"publisher","first-page":"2672","DOI":"10.1109\/TPDS.2018.2846234","volume":"29","author":"D Cheng","year":"2018","unstructured":"Cheng D, Zhou X, Wang Y, Jiang C (2018) Adaptive scheduling parallel jobs with dynamic batching in spark streaming. IEEE Trans Parallel Distrib Syst 29:2672\u20132685","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"5473_CR13","doi-asserted-by":"crossref","unstructured":"Fischer L, Bernstein A (2015) Workload scheduling in distributed stream proces-sors using graph partitioning. Proceedings of IEEE International Conference on Big Data, Big Data, 124\u2013133","DOI":"10.1109\/BigData.2015.7363749"},{"key":"5473_CR14","doi-asserted-by":"crossref","unstructured":"Zhao J, Guo J (2018) Design of distance learning streaming media system based on cloud platform. 2018 IEEE 3rd International Conference on Cloud Computing and Big Data Analysis (ICCCBDA), 131\u2013134","DOI":"10.1109\/ICCCBDA.2018.8386500"},{"key":"5473_CR15","doi-asserted-by":"crossref","unstructured":"Shangguan B, Yue P, Wu Z (2017) A stream computing based approach for updating waterlogging information on remote sensing images. 2017 IEEE International Geoscience and Remote Sensing Symposium (IGARSS), 373\u2013375","DOI":"10.1109\/IGARSS.2017.8126973"},{"key":"5473_CR16","doi-asserted-by":"publisher","first-page":"5944","DOI":"10.1007\/s11227-018-2508-1","volume":"74","author":"K Shojaei","year":"2018","unstructured":"Shojaei K, Safi-Esfahani Ayat S (2018) Vmdfs: virtual machine dynamic frequency scaling strategy in cloud computing. J Supercomput 74:5944\u20135979","journal-title":"J Supercomput"},{"key":"5473_CR17","unstructured":"Fan JHC, Hu F (2015) Adaptive task scheduling in storm. 2015 4th International Conference on Computer Science and Ne The Power of Both Choices Technology (ICCSNT), 309\u2013314"},{"key":"5473_CR18","doi-asserted-by":"publisher","first-page":"2165","DOI":"10.1109\/TPDS.2019.2911495","volume":"30","author":"X Liao","year":"2019","unstructured":"Liao X, Huang Y, Zheng L, Jin H (2019) Efficient time-evolving stream processing at scale. IEEE Trans Parallel Distrib Syst 30:2165\u20132178","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"5473_CR19","doi-asserted-by":"crossref","unstructured":"Jayashri C, Abitha P, Subburaj S, Devi SY, S S, S J (2017) Big data transfers through dynamic and load balanced flow on cloud networks. 2017 Third International Conference on Advances in Electrical, Electronics, In-formation, Communication and Bio-Informatics (AEEICB), 342\u2013346","DOI":"10.1109\/AEEICB.2017.7972328"},{"key":"5473_CR20","doi-asserted-by":"publisher","first-page":"6103","DOI":"10.1109\/TII.2020.2974875","volume":"16","author":"S Deng","year":"2020","unstructured":"Deng S et al (2020) Dynamical resource allocation in edge for trustable internet-of-things systems: a reinforcement learning method. IEEE Trans Industr Inf 16:6103\u20136113","journal-title":"IEEE Trans Industr Inf"},{"key":"5473_CR21","unstructured":"Grandl R, Chowdhury M, Akella A (2016) Altruistic scheduling in multi-resource clusters. Proceedings of OSDI\u201916: 12th USENIX Symposium on Operating Systems Design and Implementation, 65\u201380"},{"key":"5473_CR22","doi-asserted-by":"crossref","unstructured":"Son SHI, Moon YS (2021) Stochastic distributed data stream partitioning using task locality: design, implementation, and optimization. J Supercomput 10","DOI":"10.1007\/s11227-021-03725-4"},{"key":"5473_CR23","doi-asserted-by":"crossref","unstructured":"Aslam, Adeel HC, H J (2021) Pre-filtering based summarization for data partitioning in distributed stream processing. Concurr Comput Pract Exp","DOI":"10.1002\/cpe.6338"},{"key":"5473_CR24","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 Parall Distrib Syst, 99","DOI":"10.1109\/TPDS.2021.3051059"},{"key":"5473_CR25","doi-asserted-by":"crossref","unstructured":"FeiChen SongWu HaiJin (2018) Network-aware grouping in distributed stream processing systems. In: International Conference on Algorithms and Architectures for Parallel Processing","DOI":"10.1007\/978-3-030-05051-1_1"},{"key":"5473_CR26","doi-asserted-by":"crossref","unstructured":"Qian W, Shen Q, Qin J, Yang D, Yang Y, Wu Z (2016) S-storm: a slot-aware scheduling strategy for even scheduler in storm. 2016 IEEE 2nd Interna-tional Conference on Data Science and Systems, HPCC, Sydney, NSW, Australia, 623\u2013630","DOI":"10.1109\/HPCC-SmartCity-DSS.2016.0093"},{"key":"5473_CR27","doi-asserted-by":"crossref","unstructured":"Nasir MAU, Morales G, Garc\u00eda-Soriano D, Kourtellis N, Serafini M (2015) The power of both choices: Practical load balancing for distributed tream processing engines. 2015 IEEE 31st International Conference on Data Engineering, 137\u2013148","DOI":"10.1109\/ICDE.2015.7113279"},{"key":"5473_CR28","doi-asserted-by":"publisher","first-page":"615","DOI":"10.1007\/s11227-017-2151-2","volume":"74","author":"D Sun","year":"2018","unstructured":"Sun D, Yan H, Gao S, Liu X, Buyya R (2018) Rethinking elastic online scheduling of big data streaming applications over high-velocity continuous data streams. J Supercomput 74:615\u2013636","journal-title":"J Supercomput"},{"key":"5473_CR29","doi-asserted-by":"crossref","unstructured":"Lang K, Chai X (2022) Implementation of load balancing algorithm based on flink cluster, pp 264\u2013268","DOI":"10.1109\/CBASE57816.2022.00058"},{"key":"5473_CR30","doi-asserted-by":"publisher","first-page":"2703","DOI":"10.3233\/JIFS-222524","volume":"44","author":"Q Dai","year":"2023","unstructured":"Dai Q, Qin G, Li J, Zhao J, Cai J (2023) A resource occupancy ratio-oriented load balancing task scheduling mechanism for flink. J Intell Fuzzy Syst 44:2703\u20132713","journal-title":"J Intell Fuzzy Syst"},{"key":"5473_CR31","first-page":"92","volume":"41","author":"Z Li","year":"2020","unstructured":"Li Z, Yu J, Wang Y, Bian C, Pu Y, Zhang Y, Liu Y (2020) Load prediction based elastic resource scheduling strategy in flink. J Commun 41:92\u2013108","journal-title":"J Commun"},{"key":"5473_CR32","doi-asserted-by":"crossref","unstructured":"Anis Uddin\u00a0Nasir M, G, DFM, Kourtellis N, Serafini M (2016) When two choices are not enough: balancing at scale in distributed stream processing. 2016 IEEE 32nd International Conference on Data Engineering, ICDE, Helsinki, Finland, 589\u2013600","DOI":"10.1109\/ICDE.2016.7498273"},{"key":"5473_CR33","doi-asserted-by":"publisher","first-page":"1582","DOI":"10.1109\/TC.2020.3019689","volume":"70","author":"H Chen","year":"2021","unstructured":"Chen H, Zhang F, Jin H (2021) Pstream: a popularity-aware differentiated distributed stream processing system. IEEE Trans Comput 70:1582\u20131597","journal-title":"IEEE Trans Comput"},{"key":"5473_CR34","doi-asserted-by":"crossref","unstructured":"Aslam A, Chen H, Jin H (2021) Pre-filtering based summarization for data partitioning in distributed stream processing. Concurr Comput Pract Exp 33","DOI":"10.1002\/cpe.6338"},{"key":"5473_CR35","doi-asserted-by":"crossref","unstructured":"Fu TZJ, Ding J, Ma RTB, Winslett M, Yang Y, Zhang Z (2015) Drs: dynamic resource scheduling for real-time analytics over fast streams. 2015 IEEE 35th International Conference on Distributed Computing Systems, Colum-bus, OH, USA, 411\u2013420","DOI":"10.1109\/ICDCS.2015.49"},{"key":"5473_CR36","doi-asserted-by":"publisher","first-page":"2166","DOI":"10.1109\/TII.2016.2560802","volume":"12","author":"W Zhang","year":"2016","unstructured":"Zhang W, Duan P, Gong W, Lu Q, Yang S (2016) A load-aware pluggable cloud strategy for real-time video processing. IEEE Trans Industr Inf 12:2166\u20132176","journal-title":"IEEE Trans Industr Inf"},{"key":"5473_CR37","doi-asserted-by":"crossref","unstructured":"Cardellini V, Grassi V, Presti FL, Nardelli M (2015) Poster: distributed qos-aware scheduling in storm\". Acm International Conference on Distributed Event-based Systems, 344\u2013347","DOI":"10.1145\/2675743.2776766"},{"key":"5473_CR38","doi-asserted-by":"crossref","unstructured":"Zhou Y, Liu Y, Zhang C, Peng X (2020) Toss: a topology-based scheduler for storm c1usters. IEEE International Symposium on Parallel and Distributed Processing Workshops and PhD Forum, IPDPSW, 587\u2013588","DOI":"10.1109\/IPDPSW50202.2020.00101"},{"key":"5473_CR39","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1016\/j.jnca.2022.103462","volume":"206","author":"M Wu","year":"2022","unstructured":"Wu M, Sun D, Cui Y, Gao S, Liu X, Buyya R (2022) A state lossless scheduling strategy in distributed stream computing systems. J Netw Comput Appl 206:1\u201316","journal-title":"J Netw Comput Appl"},{"key":"5473_CR40","doi-asserted-by":"publisher","first-page":"133","DOI":"10.1016\/j.jnca.2018.11.005","volume":"126","author":"C Vicentini","year":"2019","unstructured":"Vicentini C, Santin A, Viegas E, Abreu V (2019) Sdn-based and multitenant-aware resource provisioning mechanism for cloud-based big data streaming. J Netw Comput Appl 126:133\u2013149","journal-title":"J Netw Comput Appl"},{"key":"5473_CR41","doi-asserted-by":"crossref","unstructured":"Fischer L, Bernstein A (2015) Workload scheduling in distributed stream processors using graph partitioning proceedings. IEEE International Conference on Big Data, Big Data., 124\u2013133","DOI":"10.1109\/BigData.2015.7363749"},{"key":"5473_CR42","doi-asserted-by":"crossref","unstructured":"Li B, Zhang Z, Zheng T, Zhong Q, Huang Q, Cheng X (2020) Marabunta: continuous distributed processing of skewed streams. 2020 20th IEEE\/ACM Inter-national Symposium on Cluster, Cloud and Internet Computing (CCGRID), 252\u2013261","DOI":"10.1109\/CCGrid49817.2020.00-68"}],"container-title":["The Journal of Supercomputing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-023-05473-z.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s11227-023-05473-z\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-023-05473-z.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,10,20]],"date-time":"2023-10-20T21:09:35Z","timestamp":1697836175000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s11227-023-05473-z"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2023,6,18]]},"references-count":42,"journal-issue":{"issue":"18","published-print":{"date-parts":[[2023,12]]}},"alternative-id":["5473"],"URL":"https:\/\/doi.org\/10.1007\/s11227-023-05473-z","relation":{},"ISSN":["0920-8542","1573-0484"],"issn-type":[{"value":"0920-8542","type":"print"},{"value":"1573-0484","type":"electronic"}],"subject":[],"published":{"date-parts":[[2023,6,18]]},"assertion":[{"value":"1 June 2023","order":1,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"18 June 2023","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":"Conflict of interest"}}]}}