{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,19]],"date-time":"2026-03-19T14:15:48Z","timestamp":1773929748996,"version":"3.50.1"},"reference-count":32,"publisher":"Springer Science and Business Media LLC","issue":"1","license":[{"start":{"date-parts":[[2026,1,28]],"date-time":"2026-01-28T00:00:00Z","timestamp":1769558400000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2026,1,28]],"date-time":"2026-01-28T00:00:00Z","timestamp":1769558400000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Grid Computing"],"published-print":{"date-parts":[[2026,3]]},"DOI":"10.1007\/s10723-026-09823-y","type":"journal-article","created":{"date-parts":[[2026,1,28]],"date-time":"2026-01-28T09:44:45Z","timestamp":1769593485000},"update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":0,"title":["A Three-tier Load Balancing Model with Dynamic Data Partitioning Strategy for Distributed Stream Processing"],"prefix":"10.1007","volume":"24","author":[{"given":"Hongjian","family":"Li","sequence":"first","affiliation":[]},{"given":"Yifan","family":"Ren","sequence":"additional","affiliation":[]},{"given":"Wei","family":"Luo","sequence":"additional","affiliation":[]},{"given":"Xiaolin","family":"Duan","sequence":"additional","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2026,1,28]]},"reference":[{"key":"9823_CR1","doi-asserted-by":"publisher","unstructured":"Hass, G., Simon, P., Kashef, R.: Business applications for current developments in big data clustering: an overview. In: 2020 IEEE International Conference on Industrial Engineering and Engineering Management (IEEM), pp. 195\u2013199. (2020). https:\/\/doi.org\/10.1109\/IEEM45057.2020.9309941","DOI":"10.1109\/IEEM45057.2020.9309941"},{"key":"9823_CR2","doi-asserted-by":"publisher","first-page":"138","DOI":"10.1016\/j.jmsy.2019.11.004","volume":"54","author":"R Sahal","year":"2020","unstructured":"Sahal, R., Breslin, J.G., Ali, M.I.: Big data and stream processing platforms for industry 4 requirements mapping for a predictive maintenance use case. J. Manuf. Syst. 54, 138\u2013151 (2020). https:\/\/doi.org\/10.1016\/j.jmsy.2019.11.004","journal-title":"J. Manuf. Syst."},{"issue":"4","key":"9823_CR3","doi-asserted-by":"publisher","first-page":"2039","DOI":"10.1109\/TII.2017.2670505","volume":"13","author":"J Wan","year":"2017","unstructured":"Wan, J., Tang, S., Li, D., et al.: A manufacturing big data solution for active preventive maintenance. IEEE Trans. Industr. Inf. 13(4), 2039\u20132047 (2017). https:\/\/doi.org\/10.1109\/TII.2017.2670505","journal-title":"IEEE Trans. Industr. Inf."},{"issue":"3","key":"9823_CR4","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/3355399","volume":"53","author":"X Liu","year":"2020","unstructured":"Liu, X., Buyya, R.: Resource management and scheduling in distributed stream processing systems: a taxonomy, review, and future directions. ACM Comput. Survey 53(3), 1\u201341 (2020). https:\/\/doi.org\/10.1145\/3355399","journal-title":"ACM Comput. Survey"},{"issue":"7","key":"9823_CR5","doi-asserted-by":"publisher","first-page":"6679","DOI":"10.1109\/TITS.2021.3060576","volume":"23","author":"L Hu","year":"2021","unstructured":"Hu, L., Zhang, F., Qin, M., et al.: A dynamic pyramid tilling method for traffic data stream based on flink. IEEE Trans. Intell. Transp. Syst. 23(7), 6679\u20136688 (2021). https:\/\/doi.org\/10.1109\/TITS.2021.3060576","journal-title":"IEEE Trans. Intell. Transp. Syst."},{"key":"9823_CR6","doi-asserted-by":"publisher","first-page":"107681","DOI":"10.1016\/j.future.2024.107681","volume":"166","author":"H Li","year":"2025","unstructured":"Li, H., Li, J., Duan, X., et al.: Energy-aware scheduling and two-tier coordinated load balancing for streaming applications in apache flink. Futur. Gener. Comput. Syst. 166, 107681 (2025). https:\/\/doi.org\/10.1016\/j.future.2024.107681","journal-title":"Futur. Gener. Comput. Syst."},{"key":"9823_CR7","doi-asserted-by":"publisher","unstructured":"Zvara, Z., Szab, P.G.N., Lrnt, B.B., et al: System-aware dynamic partitioning for batch and streaming workloads. In: Proceedings of the 14th IEEE\/ACM International Conference on Utility and Cloud Computing, pp. 1\u201310. (2021). https:\/\/doi.org\/10.1145\/3468737.3494087","DOI":"10.1145\/3468737.3494087"},{"key":"9823_CR8","doi-asserted-by":"publisher","first-page":"417","DOI":"10.1007\/s10586-020-03117-y","volume":"24","author":"A Muhammad","year":"2021","unstructured":"Muhammad, A., Aleem, M., Islam, M.A.: Top-storm: a topology-based resource-aware scheduler for stream processing engine. Clust. Comput. 24, 417\u2013431 (2021). https:\/\/doi.org\/10.1007\/s10586-020-03117-y","journal-title":"Clust. Comput."},{"key":"9823_CR9","doi-asserted-by":"publisher","unstructured":"Cao, Q., She, P., Chai, X.: Flink task scheduling based on lgba. In: 2023 4th International Conference on Information Science, Parallel and Distributed Systems (ISPDS), pp. 216\u2013221. (2023). https:\/\/doi.org\/10.1109\/ISPDS58840.2023.10235469","DOI":"10.1109\/ISPDS58840.2023.10235469"},{"issue":"10","key":"9823_CR10","doi-asserted-by":"publisher","first-page":"1582","DOI":"10.1109\/TC.2020.3019689","volume":"70","author":"H Chen","year":"2020","unstructured":"Chen, H., Zhang, F., Jin, H.: Pstream: a popularity-aware differentiated distributed stream processing system. IEEE Trans. Comput. 70(10), 1582\u20131597 (2020). https:\/\/doi.org\/10.1109\/TC.2020.3019689","journal-title":"IEEE Trans. Comput."},{"key":"9823_CR11","doi-asserted-by":"publisher","unstructured":"He, C., Huang, Y., Wang, C., et al: Dynamic data partitioning strategy based on heterogeneous flink cluster. In: 2022 5th International Conference on Artificial Intelligence and Big Data (ICAIBD), pp. 355\u2013360. (2022). https:\/\/doi.org\/10.1109\/ICAIBD55127.2022.9820336","DOI":"10.1109\/ICAIBD55127.2022.9820336"},{"issue":"3","key":"9823_CR12","doi-asserted-by":"publisher","first-page":"491","DOI":"10.14778\/3570690.3570699","volume":"16","author":"E Zapridou","year":"2022","unstructured":"Zapridou, E., Mytilinis, I., Ailamaki, A.: Dalton: learned partitioning for distributed data streams. Proc. VLDB Endow. 16(3), 491\u2013504 (2022). https:\/\/doi.org\/10.14778\/3570690.3570699","journal-title":"Proc. VLDB Endow."},{"key":"9823_CR13","doi-asserted-by":"publisher","unstructured":"Sun, D., Wu, M., Yang, Z., et al.: A two-tier coordinated load balancing strategy over skewed data streams. J. Supercomput. 1\u201329 (2023). https:\/\/doi.org\/10.1007\/s11227-023-05473-z","DOI":"10.1007\/s11227-023-05473-z"},{"key":"9823_CR14","doi-asserted-by":"publisher","first-page":"107673","DOI":"10.1016\/j.future.2024.107673","volume":"166","author":"M Wu","year":"2025","unstructured":"Wu, M., Sun, D., Gao, S., et al.: Straggler mitigation via hierarchical scheduling in elastic stream computing systems. Futur. Gener. Comput. Syst. 166, 107673 (2025). https:\/\/doi.org\/10.1016\/j.future.2024.107673","journal-title":"Futur. Gener. Comput. Syst."},{"key":"9823_CR15","doi-asserted-by":"publisher","unstructured":"Pu, Y.: Optimization method based on data migration on metaverse. In: 2024 2nd International Conference on Intelligent Metaverse Technologies and Applications\u00a0(iMETA), pp. 149\u2013155. (2024). https:\/\/doi.org\/10.1109\/IMETA62882.2024.10808091","DOI":"10.1109\/IMETA62882.2024.10808091"},{"key":"9823_CR16","doi-asserted-by":"publisher","first-page":"2767","DOI":"10.7717\/peerj-cs.2767","volume":"11","author":"R Ali","year":"2025","unstructured":"Ali, R., Muhammad, A., Aleem, M., et al.: Wg-storm: a resource-aware scheduler for distributed stream processing engines. PeerJ Comput. Sci. 11, 2767 (2025). https:\/\/doi.org\/10.7717\/peerj-cs.2767","journal-title":"PeerJ Comput. Sci."},{"key":"9823_CR17","doi-asserted-by":"publisher","unstructured":"Dai, Q., Qin, G., Li, J., et al.: A resource occupancy ratio-oriented load balancing task scheduling mechanism for flink. J. Intell. Fuzz. Syst. 1\u201311 (2023). https:\/\/doi.org\/10.3233\/JIFS-222524","DOI":"10.3233\/JIFS-222524"},{"key":"9823_CR18","doi-asserted-by":"publisher","unstructured":"Lang, K., Chai, X.: Implementation of load balancing algorithm based on flink cluster. In: 2022 International Conference on Cloud Computing, Big Data Applications and Software Engineering (CBASE), pp. 264\u2013268. (2022). https:\/\/doi.org\/10.1109\/CBASE57816.2022.00058","DOI":"10.1109\/CBASE57816.2022.00058"},{"key":"9823_CR19","doi-asserted-by":"publisher","unstructured":"Liu, X., Lin, Y., Buyya, R.: Dynamic resource-efficient scheduling in data stream management systems deployed on computing clouds. In: Dynamic Resource-efficient Scheduling in Data Stream Management Systems Deployed on Computing Clouds, pp. 133\u2013163. Springer, Cham (2022). https:\/\/doi.org\/10.1007\/978-3-031-05528-7_5","DOI":"10.1007\/978-3-031-05528-7_5"},{"key":"9823_CR20","doi-asserted-by":"publisher","unstructured":"Li, H., Xia, J., Luo, W., et al.: Cost-efficient scheduling of streaming applications in apache flink on cloud. IEEE Trans. Big Data (2022). https:\/\/doi.org\/10.1109\/TBDATA.2022.3233031","DOI":"10.1109\/TBDATA.2022.3233031"},{"issue":"5","key":"9823_CR21","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1007\/s11227-025-07216-8","volume":"81","author":"D Sun","year":"2025","unstructured":"Sun, D., Fan, Y., Guan, C., et al.: An elastic reconfiguration strategy for operators in distributed stream computing systems. J. Supercomput. 81(5), 1\u201331 (2025). https:\/\/doi.org\/10.1007\/s11227-025-07216-8","journal-title":"J. Supercomput."},{"issue":"1","key":"9823_CR22","doi-asserted-by":"publisher","first-page":"39","DOI":"10.1007\/s10723-024-09756-4","volume":"22","author":"H Li","year":"2024","unstructured":"Li, H., Luo, W., Xie, W., et al.: Adaptive scheduling framework of streaming applications based on resource demand prediction with hybrid algorithms. J. Grid Comput. 22(1), 39 (2024). https:\/\/doi.org\/10.1007\/s10723-024-09756-4","journal-title":"J. Grid Comput."},{"issue":"2","key":"9823_CR23","doi-asserted-by":"publisher","first-page":"681","DOI":"10.1145\/3267809.3267818","volume":"29","author":"L Liu","year":"2021","unstructured":"Liu, L., Xu, H.: Elasecutor: elastic executor scheduling in data analytics systems. IEEE\/ACM Trans. Network 29(2), 681\u2013694 (2021). https:\/\/doi.org\/10.1145\/3267809.3267818","journal-title":"IEEE\/ACM Trans. Network"},{"key":"9823_CR24","doi-asserted-by":"publisher","first-page":"11353","DOI":"10.1007\/s11227-021-03725-4","volume":"77","author":"S Son","year":"2021","unstructured":"Son, S., Im, H., Moon, Y.S.: Stochastic distributed data stream partitioning using task locality: design, implementation, and optimization. J. Supercomput. 77, 11353\u201311389 (2021). https:\/\/doi.org\/10.1007\/s11227-021-03725-4","journal-title":"J. Supercomput."},{"key":"9823_CR25","doi-asserted-by":"publisher","first-page":"193","DOI":"10.1016\/j.future.2020.05.021","volume":"112","author":"D Sun","year":"2020","unstructured":"Sun, D., Gao, S., Liu, X., et al.: Dynamic redirection of real-time data streams for elastic stream computing. Futur. Gener. Comput. Syst. 112, 193\u2013208 (2020). https:\/\/doi.org\/10.1016\/j.future.2020.05.021","journal-title":"Futur. Gener. Comput. Syst."},{"key":"9823_CR26","doi-asserted-by":"publisher","unstructured":"Li, W., Liu, D., Chen, K., et al.: Hone: mitigating stragglers in distributed stream processing with tuple scheduling. IEEE Trans. Parallel Distr. Syst. 32(8)(2021). https:\/\/doi.org\/10.1109\/TPDS.2021.3051059","DOI":"10.1109\/TPDS.2021.3051059"},{"key":"9823_CR27","doi-asserted-by":"publisher","first-page":"117","DOI":"10.1016\/j.future.2021.10.005","volume":"128","author":"D Sun","year":"2022","unstructured":"Sun, D., Gao, S., Liu, X., et al.: A multi-level collaborative framework for elastic stream computing systems. Futur. Gener. Comput. Syst. 128, 117\u2013131 (2022). https:\/\/doi.org\/10.1016\/j.future.2021.10.005","journal-title":"Futur. Gener. Comput. Syst."},{"key":"9823_CR28","doi-asserted-by":"publisher","first-page":"138","DOI":"10.1016\/j.future.2023.11.002","volume":"152","author":"D Sun","year":"2024","unstructured":"Sun, D., Zhang, C., Gao, S., et al.: An adaptive load balancing strategy for stateful join operator in skewed data stream environments. Futur. Gener. Comput. Syst. 152, 138\u2013151 (2024). https:\/\/doi.org\/10.1016\/j.future.2023.11.002","journal-title":"Futur. Gener. Comput. Syst."},{"key":"9823_CR29","doi-asserted-by":"publisher","unstructured":"Sun, D., Chen, Z., Lv, W., et al: A frequency-aware grouping strategy for stateful operators in distributed stream processing systems. In: 2023 IEEE 29th International\u00a0Conference on Parallel and Distributed Systems (ICPADS), pp. 126\u2013131. (2023). https:\/\/doi.org\/10.1109\/ICPADS60453.2023.00027","DOI":"10.1109\/ICPADS60453.2023.00027"},{"issue":"3","key":"9823_CR30","doi-asserted-by":"publisher","first-page":"46","DOI":"10.25236\/ajets.2024.070612","volume":"7","author":"W Zhang","year":"2024","unstructured":"Zhang, W., Zhou, G., Yin, Z., Hu, K.: Research on data engine of space command and display system based on flink task scheduling strategy. Acad. J. Comput. Infor. Sci. 7(3), 46\u201353 (2024). https:\/\/doi.org\/10.25236\/ajets.2024.070612","journal-title":"Acad. J. Comput. Infor. Sci."},{"key":"9823_CR31","doi-asserted-by":"publisher","unstructured":"Ntouni, O., Petrakis, E.G.M.: Talos: Task level autoscaler for apache flink. In: International Conference on Cooperative Information Systems. (2024). https:\/\/doi.org\/10.1007\/978-3-031-81375-7_16","DOI":"10.1007\/978-3-031-81375-7_16"},{"key":"9823_CR32","doi-asserted-by":"publisher","unstructured":"Lu, P., Yuan, L., Zhang, Y., Cao, H., Li, K.: Autoflow: Hotspot-aware, dynamic load balancing for distributed\u00a0stream processing. (2021). arXiv:2103.08888, https:\/\/doi.org\/10.1007\/978-3-030-95391-1_9","DOI":"10.1007\/978-3-030-95391-1_9"}],"container-title":["Journal of Grid Computing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10723-026-09823-y.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s10723-026-09823-y","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10723-026-09823-y.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2026,3,19]],"date-time":"2026-03-19T11:15:16Z","timestamp":1773918916000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s10723-026-09823-y"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026,1,28]]},"references-count":32,"journal-issue":{"issue":"1","published-print":{"date-parts":[[2026,3]]}},"alternative-id":["9823"],"URL":"https:\/\/doi.org\/10.1007\/s10723-026-09823-y","relation":{},"ISSN":["1570-7873","1572-9184"],"issn-type":[{"value":"1570-7873","type":"print"},{"value":"1572-9184","type":"electronic"}],"subject":[],"published":{"date-parts":[[2026,1,28]]},"assertion":[{"value":"11 September 2025","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"5 January 2026","order":2,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"28 January 2026","order":3,"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"}},{"value":"Not applicable.","order":3,"name":"Ethics","group":{"name":"EthicsHeading","label":"Ethics Approval and Consent to Participate"}},{"value":"Not applicable.","order":4,"name":"Ethics","group":{"name":"EthicsHeading","label":"Consent for Publication"}}],"article-number":"3"}}