{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,6,10]],"date-time":"2026-06-10T01:01:31Z","timestamp":1781053291872,"version":"3.54.1"},"reference-count":42,"publisher":"Elsevier BV","license":[{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.elsevier.com\/tdm\/userlicense\/1.0\/"},{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.elsevier.com\/legal\/tdmrep-license"},{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-017"},{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-037"},{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-012"},{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-029"},{"start":{"date-parts":[[2026,11,1]],"date-time":"2026-11-01T00:00:00Z","timestamp":1793491200000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-004"}],"funder":[{"DOI":"10.13039\/501100013804","name":"Fundamental Research Funds for the Central Universities","doi-asserted-by":"publisher","id":[{"id":"10.13039\/501100013804","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"publisher","id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["elsevier.com","sciencedirect.com"],"crossmark-restriction":true},"short-container-title":["Future Generation Computer Systems"],"published-print":{"date-parts":[[2026,11]]},"DOI":"10.1016\/j.future.2026.108616","type":"journal-article","created":{"date-parts":[[2026,5,27]],"date-time":"2026-05-27T16:27:54Z","timestamp":1779899274000},"page":"108616","update-policy":"https:\/\/doi.org\/10.1016\/elsevier_cm_policy","source":"Crossref","is-referenced-by-count":0,"special_numbering":"C","title":["A multi-domain cooperative scheduling framework for distributed stream computing systems"],"prefix":"10.1016","volume":"184","author":[{"ORCID":"https:\/\/orcid.org\/0000-0003-3137-6257","authenticated-orcid":false,"given":"Dawei","family":"Sun","sequence":"first","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Zhongyuan","family":"Zhao","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Yueru","family":"Wang","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-2947-7780","authenticated-orcid":false,"given":"Shang","family":"Gao","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Rajkumar","family":"Buyya","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"78","reference":[{"issue":"6","key":"10.1016\/j.future.2026.108616_b1","doi-asserted-by":"crossref","first-page":"847","DOI":"10.1007\/s00778-018-0514-9","article-title":"A survey of state management in big data processing systems","volume":"27","author":"To","year":"2018","journal-title":"VLDB J."},{"key":"10.1016\/j.future.2026.108616_b2","series-title":"Apache spark","year":"2026"},{"key":"10.1016\/j.future.2026.108616_b3","series-title":"Apache samza","year":"2026"},{"key":"10.1016\/j.future.2026.108616_b4","doi-asserted-by":"crossref","first-page":"567","DOI":"10.1016\/j.future.2020.06.009","article-title":"Throughput optimization for storm-based processing of stream data on clouds","volume":"112","author":"Cao","year":"2020","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108616_b5","series-title":"Apache storm","year":"2026"},{"key":"10.1016\/j.future.2026.108616_b6","series-title":"Apache flink","year":"2026"},{"issue":"3","key":"10.1016\/j.future.2026.108616_b7","doi-asserted-by":"crossref","DOI":"10.1145\/3355399","article-title":"Resource management and scheduling in distributed stream processing systems: A taxonomy, review, and future directions","volume":"53","author":"Liu","year":"2020","journal-title":"ACM Comput. Surv."},{"issue":"6","key":"10.1016\/j.future.2026.108616_b8","doi-asserted-by":"crossref","DOI":"10.1145\/3419634","article-title":"A survey on IoT big data: Current status, 13 V\u2019s challenges, and future directions","volume":"53","author":"Bansal","year":"2020","journal-title":"ACM Comput. Surv."},{"issue":"3","key":"10.1016\/j.future.2026.108616_b9","doi-asserted-by":"crossref","first-page":"3561","DOI":"10.1007\/s11227-021-04000-2","article-title":"Data balancing-based intermediate data partitioning and check point-based cache recovery in Spark environment","volume":"78","author":"Li","year":"2022","journal-title":"J. Supercomput."},{"issue":"4","key":"10.1016\/j.future.2026.108616_b10","doi-asserted-by":"crossref","first-page":"2275","DOI":"10.1109\/TSC.2020.3044104","article-title":"Fairness-aware mechanism for load balancing in distributed systems","volume":"15","author":"Kishor","year":"2022","journal-title":"IEEE Trans. Serv. Comput."},{"issue":"5","key":"10.1016\/j.future.2026.108616_b11","doi-asserted-by":"crossref","first-page":"821","DOI":"10.1007\/s00778-019-00565-w","article-title":"On the performance and convergence of distributed stream processing via approximate fault tolerance","volume":"28","author":"Cheng","year":"2019","journal-title":"VLDB J."},{"issue":"6","key":"10.1016\/j.future.2026.108616_b12","doi-asserted-by":"crossref","first-page":"1298","DOI":"10.1109\/TPDS.2018.2881176","article-title":"Energy-efficient task scheduling for CPU-intensive streaming jobs on hadoop","volume":"30","author":"Jin","year":"2019","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"issue":"12","key":"10.1016\/j.future.2026.108616_b13","doi-asserted-by":"crossref","first-page":"2672","DOI":"10.1109\/TPDS.2018.2846234","article-title":"Adaptive scheduling parallel jobs with dynamic batching in spark streaming","volume":"29","author":"Cheng","year":"2018","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"issue":"3","key":"10.1016\/j.future.2026.108616_b14","doi-asserted-by":"crossref","DOI":"10.1007\/s10723-021-09567-x","article-title":"BAN-storm: a bandwidth-aware scheduling mechanism for stream jobs","volume":"19","author":"Muhammad","year":"2021","journal-title":"J. Grid Comput."},{"issue":"7","key":"10.1016\/j.future.2026.108616_b15","doi-asserted-by":"crossref","first-page":"1628","DOI":"10.1109\/TPDS.2019.2891587","article-title":"Pec: Proactive elastic collaborative resource scheduling in data stream processing","volume":"30","author":"Wei","year":"2019","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"issue":"4","key":"10.1016\/j.future.2026.108616_b16","doi-asserted-by":"crossref","first-page":"1086","DOI":"10.1109\/TBDATA.2022.3233031","article-title":"Cost-efficient scheduling of streaming applications in apache flink on cloud","volume":"9","author":"Li","year":"2023","journal-title":"IEEE Trans. Big Data"},{"key":"10.1016\/j.future.2026.108616_b17","doi-asserted-by":"crossref","DOI":"10.1016\/j.sysarc.2022.102598","article-title":"Energy-aware scheduling for dependent tasks in heterogeneous multiprocessor systems","volume":"129","author":"Chen","year":"2022","journal-title":"J. Syst. Archit."},{"issue":"11s","key":"10.1016\/j.future.2026.108616_b18","doi-asserted-by":"crossref","DOI":"10.1145\/3514496","article-title":"Runtime adaptation of data stream processing systems: The state of the art","volume":"54","author":"Cardellini","year":"2022","journal-title":"ACM Comput. Surv."},{"key":"10.1016\/j.future.2026.108616_b19","series-title":"2024 IEEE International Conference on High Performance Computing and Communications","first-page":"450","article-title":"A task dependency-aware scheduling strategy for cross-domain stream computing environments","author":"Sun","year":"2024"},{"key":"10.1016\/j.future.2026.108616_b20","series-title":"Proceedings of the Australasian Computer Science Week Multiconference","first-page":"26:1","article-title":"P-scheduler: Adaptive hierarchical scheduling in apache storm","author":"Eskandari","year":"2016"},{"key":"10.1016\/j.future.2026.108616_b21","doi-asserted-by":"crossref","first-page":"617","DOI":"10.1016\/j.future.2018.07.011","article-title":"T3-scheduler: A topology and traffic aware two-level scheduler for stream processing systems in a heterogeneous cluster","volume":"89","author":"Eskandari","year":"2018","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108616_b22","doi-asserted-by":"crossref","first-page":"219","DOI":"10.1016\/j.future.2020.11.011","article-title":"I-Scheduler: Iterative scheduling for distributed stream processing systems","volume":"117","author":"Eskandari","year":"2021","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108616_b23","doi-asserted-by":"crossref","DOI":"10.1016\/j.eswa.2021.116322","article-title":"SP-ant: An ant colony optimization based operator scheduler for high performance distributed stream processing on heterogeneous clusters","volume":"191","author":"Farrokh","year":"2022","journal-title":"Expert Syst. Appl."},{"issue":"1","key":"10.1016\/j.future.2026.108616_b24","doi-asserted-by":"crossref","first-page":"461","DOI":"10.1007\/s11227-022-04669-z","article-title":"An elastic and traffic-aware scheduler for distributed data stream processing in heterogeneous clusters","volume":"79","author":"Hadian","year":"2023","journal-title":"J. Supercomput."},{"key":"10.1016\/j.future.2026.108616_b25","doi-asserted-by":"crossref","first-page":"142","DOI":"10.1016\/j.future.2021.08.014","article-title":"Optimal data placement strategy considering capacity limitation and load balancing in geographically distributed cloud","volume":"127","author":"Li","year":"2022","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108616_b26","series-title":"Proceedings of the Twentieth European Conference on Computer Systems","isbn-type":"print","doi-asserted-by":"crossref","first-page":"654","DOI":"10.1145\/3689031.3696085","article-title":"CAPSys: Contention-aware task placement for data stream processing","author":"Wang","year":"2025","ISBN":"https:\/\/id.crossref.org\/isbn\/9798400711961"},{"key":"10.1016\/j.future.2026.108616_b27","series-title":"Proceedings of the 16th Annual Middleware Conference","first-page":"149","article-title":"R-storm: Resource-aware scheduling in storm","author":"Peng","year":"2015"},{"issue":"4","key":"10.1016\/j.future.2026.108616_b28","doi-asserted-by":"crossref","first-page":"11","DOI":"10.1145\/3092819.3092823","article-title":"Optimal operator replication and placement for distributed stream processing systems","volume":"44","author":"Cardellini","year":"2017","journal-title":"SIGMETRICS Perform. Eval. Rev."},{"key":"10.1016\/j.future.2026.108616_b29","series-title":"Computational Science - ICCS 2022, PT I","first-page":"734","article-title":"Elastic resource allocation based on dynamic perception of operator influence domain in distributed stream processing","author":"Liu","year":"2022"},{"issue":"1","key":"10.1016\/j.future.2026.108616_b30","doi-asserted-by":"crossref","first-page":"359","DOI":"10.1137\/S1064827595287997","article-title":"A fast and high quality multilevel scheme for partitioning irregular graphs","volume":"20","author":"Karypis","year":"1998","journal-title":"SIAM J. Sci. Comput."},{"key":"10.1016\/j.future.2026.108616_b31","doi-asserted-by":"crossref","first-page":"125","DOI":"10.1109\/OJCOMS.2020.2964303","article-title":"Latency-constrained cost-minimized request allocation for geo-distributed cloud services","volume":"1","author":"Xu","year":"2020","journal-title":"IEEE Open J. Commun. Soc."},{"key":"10.1016\/j.future.2026.108616_b32","article-title":"Energy and carbon-aware initial VM placement in geographically distributed cloud data centers","volume":"39","author":"Khodayarseresht","year":"2023","journal-title":"Sustain. Comput.: Inform. Syst."},{"issue":"4","key":"10.1016\/j.future.2026.108616_b33","doi-asserted-by":"crossref","first-page":"749","DOI":"10.1109\/TPDS.2019.2943457","article-title":"Power-aware allocation of graph jobs in geo-distributed cloud networks","volume":"31","author":"Hosseinalipour","year":"2020","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"key":"10.1016\/j.future.2026.108616_b34","doi-asserted-by":"crossref","DOI":"10.1016\/j.jpdc.2024.104940","article-title":"PA-SPS: A predictive adaptive approach for an elastic stream processing system","volume":"192","author":"Wladdimiro","year":"2024","journal-title":"J. Parallel Distrib. Comput."},{"issue":"23","key":"10.1016\/j.future.2026.108616_b35","doi-asserted-by":"crossref","first-page":"24009","DOI":"10.1109\/JIOT.2022.3188933","article-title":"Joint task offloading and resource allocation for cooperative mobile-edge computing under sequential task dependency","volume":"9","author":"Li","year":"2022","journal-title":"IEEE Internet Things J."},{"issue":"2","key":"10.1016\/j.future.2026.108616_b36","doi-asserted-by":"crossref","first-page":"1059","DOI":"10.1007\/s11227-020-03289-9","article-title":"A3-storm: topology-, traffic-, and resource-aware storm scheduler for heterogeneous clusters","volume":"77","author":"Muhammad","year":"2021","journal-title":"J. Supercomput."},{"key":"10.1016\/j.future.2026.108616_b37","series-title":"2017 17th IEEE\/ACM International Symposium on Cluster, Cloud and Grid Computing","first-page":"371","article-title":"Acyclic partitioning of large directed acyclic graphs","author":"Herrmann","year":"2017"},{"key":"10.1016\/j.future.2026.108616_b38","doi-asserted-by":"crossref","DOI":"10.1016\/j.jnca.2023.103691","article-title":"Time-efficient distributed virtual network embedding for round-trip delay minimization","volume":"217","author":"Dimolitsas","year":"2023","journal-title":"J. Netw. Comput. Appl."},{"key":"10.1016\/j.future.2026.108616_b39","series-title":"Performance Evaluation and Benchmarking","first-page":"24","article-title":"A survey of stream processing system benchmarks","author":"Yue","year":"2026"},{"key":"10.1016\/j.future.2026.108616_b40","series-title":"2016 IEEE International Parallel and Distributed Processing Symposium Workshops","first-page":"1789","article-title":"Benchmarking streaming computation engines: Storm, flink and spark streaming","author":"Chintapalli","year":"2016"},{"key":"10.1016\/j.future.2026.108616_b41","series-title":"Yahoo streaming benchmarks","author":"Yahoo! Inc.","year":"2026"},{"issue":"14","key":"10.1016\/j.future.2026.108616_b42","doi-asserted-by":"crossref","DOI":"10.1002\/cpe.8085","article-title":"Lc-stream: An elastic scheduling strategy with latency constraints in geo-distributed stream computing environments","volume":"36","author":"Sun","year":"2024","journal-title":"Concurr. Comput.-Pract. Exp."}],"container-title":["Future Generation Computer Systems"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/api.elsevier.com\/content\/article\/PII:S0167739X26002505?httpAccept=text\/xml","content-type":"text\/xml","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/api.elsevier.com\/content\/article\/PII:S0167739X26002505?httpAccept=text\/plain","content-type":"text\/plain","content-version":"vor","intended-application":"text-mining"}],"deposited":{"date-parts":[[2026,6,10]],"date-time":"2026-06-10T00:42:27Z","timestamp":1781052147000},"score":1,"resource":{"primary":{"URL":"https:\/\/linkinghub.elsevier.com\/retrieve\/pii\/S0167739X26002505"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026,11]]},"references-count":42,"alternative-id":["S0167739X26002505"],"URL":"https:\/\/doi.org\/10.1016\/j.future.2026.108616","relation":{},"ISSN":["0167-739X"],"issn-type":[{"value":"0167-739X","type":"print"}],"subject":[],"published":{"date-parts":[[2026,11]]},"assertion":[{"value":"Elsevier","name":"publisher","label":"This article is maintained by"},{"value":"A multi-domain cooperative scheduling framework for distributed stream computing systems","name":"articletitle","label":"Article Title"},{"value":"Future Generation Computer Systems","name":"journaltitle","label":"Journal Title"},{"value":"https:\/\/doi.org\/10.1016\/j.future.2026.108616","name":"articlelink","label":"CrossRef DOI link to publisher maintained version"},{"value":"article","name":"content_type","label":"Content Type"},{"value":"\u00a9 2026 Elsevier B.V. All rights are reserved, including those for text and data mining, AI training, and similar technologies.","name":"copyright","label":"Copyright"}],"article-number":"108616"}}