买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉浙江大学申请的专利一种在分布式流计算引擎Apache Flink中实时均衡负载的方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN119440718B 。

龙图腾网通过国家知识产权局官网在2025-11-07发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202411415621.6，技术领域涉及：G06F9/455；该发明授权一种在分布式流计算引擎Apache Flink中实时均衡负载的方法是由赵洋;王闻箫;林彬彬;蔡登设计研发完成，并于2024-10-11向国家知识产权局提交的专利申请。

本一种在分布式流计算引擎Apache Flink中实时均衡负载的方法在说明书摘要公布了：本发明公开了一种在分布式流计算引擎ApacheFlink中实时均衡负载的方法，包括在Flink内核中新增可以进行子任务重新分配的重启功能及其接口；为Flink增加根据节点数评估子任务计算量并综合考虑计算节点计算能力的子任务分配策略；在新增计算节点时自动将正在执行中的流任务的工作负载均衡到新增计算节点上；在遇到突发流量时自动均衡计算节点集群的工作负载。本发明依靠高效的重启功能、更加均衡的子任务分配策略、更实时且自动的均衡负载手段，使本发明方法在保证用户无感知的前提下，能更快、更好的实现分布式Flink系统的负载均衡，提升流计算引擎整体的任务执行效率和资源利用率。

本发明授权一种在分布式流计算引擎Apache Flink中实时均衡负载的方法在权利要求书中公布了：1.一种在分布式流计算引擎ApacheFlink中实时均衡负载的方法，其特征在于，包括如下步骤： 1为Flink增加重启任务的新功能，并提供外部的重启功能接口以供调用； 为Flink增加重启任务的新功能，具体为：使用流任务部署过程中生成的任务执行计划图，忽略已有的子任务分配计划，根据配置中选择的子任务分配策略对指定的流任务进行重新部署，然后依靠Flink提供的保存点和检查点机制，恢复原有的执行状态，继续执行； 2为Flink增加根据节点数评估子任务计算量的子任务分配策略； 3监控计算节点集群中各计算节点的CPU利用率情况，当出现某个或某些节点CPU利用率在原本未达最大的前提下增加，并导致计算节点的CPU利用率达到最大且十分钟内没有下降，如果此时计算节点集群中还有空闲的taskslot，且有空闲的taskslot的计算节点的CPU利用率未达最大，那么对CPU利用率暴涨的计算节点上的子任务的流量进行检查； 查找CPU利用率暴涨期间流量增加最多的子任务所在的流任务，对该计算节点上其它的流任务，选择最后部署成功的流任务使用步骤1中的重启功能进行重新部署，同时使用步骤2中的策略进行子任务分配，分配时忽略此时CPU利用率暴涨的计算节点。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人浙江大学，其通讯地址为：310058 浙江省杭州市西湖区余杭塘路866号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。