(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211117416.2 (22)申请日 2022.09.14 (71)申请人 阿里云计算有限公司 地址 310024 浙江省杭州市西湖区转塘科 技经济区块12号 (72)发明人 刘宇　 (74)专利代理 机构 北京太合九思知识产权代理 有限公司 1 1610 专利代理师 柴艳波　刘戈 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 计算任务分配方法、 分布式计算系统及设备 (57)摘要 本申请实施例提供一种计算任务分配方法、 分布式计算系统及设备。 其中， 方法包括如下的 步骤： 针对计算任务， 生成任务待分配消息； 任务 待分配消息中包括： 计算任务对应的多个子任务 的需求信息； 在分布式计算系统中传播任务待分 配消息； 根据被传播到的计算节 点针对任务待分 配消息发送 来的子任务申领消息， 从分布式计算 系统中确定出各子任务对应的目标计算节点； 子 任务申领消息是被传播到的计算节点根据任务 待分配消息以及自身的资源分配情况生成的； 将 各子任务分配给对应的目标计算节 点。 本申请实 施例提供的技术方案有助于提升整个分布式计 算系统的负载均衡程度， 同时还 可避免由一个节 点完成整个分配工作导致该节点负荷较重的问 题。 权利要求书3页 说明书14页 附图5页 CN 115525423 A 2022.12.27 CN 115525423 A 1.一种计算任务分配方法， 其中， 包括： 针对计算任务， 生成任务待分配消息； 所述任务待分配消息 中包括： 所述计算任务对应 的多个子任务的需求信息； 在分布式计算系统中传播所述任务待分配消息； 所述分布式计算系统包括多个计算节 点； 根据被传播到的计算节点针对所述任务待分配消息发送来的子任务申领消息， 从所述 分布式计算系统中确定出各子任务对应的目标计算节点； 所述子任务申领消息是所述被传 播到的计算节点 根据所述任务待分配消息以及自身的资源分配情况生成的； 将各子任务分配给对应的目标计算节点。 2.根据权利要求1所述的方法， 其中， 所述任务待分配消息中还包括： 针对所述计算任 务生成的任务版本信息； 所述方法， 还 包括： 当所述计算任务对应有待重新分配子任务 时， 重新生成任务版本信 息； 其中， 所述重新 生成的任务版本信息与历史上针对所述计算任务 生成的任务版本信息不同； 根据所述待重新分配子任务以及所述重新生成的任务版本信 息， 重新生成任务待分配 消息； 其中， 所述重新生成的任务待分配消息中所述待重新分配子任务的申领状态为未申 领状态、 其他子任务的申领状态为已申领状态； 所述重新生成的任务待分配消息中还包括 所述重新 生成的任务版本信息； 根据所述重新 生成的任务待分配消息， 分配所述待重新分配子任务。 3.根据权利要求2所述的方法， 其中， 还 包括： 若未在预设时刻 之前接收到所述计算任务对应的第 一子任务的计算结果， 则确定所述 计算任务对应有 待重新分配子任务； 其中， 所述待重新分配子任务包括所述第一子任务。 4.根据权利要求2所述的方法， 其中， 还 包括： 接收到针对所述计算任务对应的第 二子任务的更新请求 时， 确定所述计算任务对应有 待重新分配子任务； 根据所述更新请求， 更新所述第二子任务； 其中， 所述待重新分配子任务包括更新后的所述第二子任务。 5.根据权利要求2至4中任一项所述的方法， 其中， 当所述计算任务对应有待重新分配 子任务时， 重新 生成任务版本信息， 包括： 当所述计算任务对应有待重新分配子任务 时， 判断针对所述待重新分配子任务的分配 次数是否小于或等于 重试阈值； 当针对所述待重新分配子任务的分配次数小于或等于重试阈值 时， 重新生成任务版本 信息。 6.根据权利要求2至4中任一项所述的方法， 其中， 在分布式计算系统中传播所述任务 待分配消息， 包括： 在所述分布式计算系统中向邻居计算节点传播所述任务待分配消息； 其中， 所述分布式计算系统中被传播到的计算节点用于： 根据所述任务待分配消息中 所述多个子任务各自对应的申领状态， 确定出未被申领子任务； 根据自身的资源分配情况 以及所述任务待分配消息中所述未被申领子任务的需求信息， 生成子任务申领消息； 更新权　利　要　求　书 1/3 页 2 CN 115525423 A 2所述任务分配消息中所述子任务申领消息所申领子任务的申领状态后， 将所述任务分配消 息发送给邻居计算节点。 7.根据权利要求6所述的方法， 其中， 所述被传播到的计算节点还用于： 接收到所述任务待分配消息后， 判断所述任务待分配消息 中的任务版本信 息是否在历 史消息接收记录中； 若所述任务版本信息在所述历史消息 接收记录中， 则忽略所述任务待分配消息 。 8.根据权利要求1至4中任一项所述的方法， 其中， 所述子任务申领消息中包括： 所 申领 子任务对应的预计完成时间点； 根据被传播到的计算节点针对所述任务待分配消息发送来的子任务申领消息， 从所述 分布式计算系统中确定出 各子任务对应的目标计算节点， 包括： 根据多个被传播到的计算节点针对所述任务待分配消息发送来的子任务申领消息， 确 定各子任务对应的至少一个预计完成时间点； 根据各子任务对应的至少一个预计完成时间点， 从所述分布式计算系统中确定出各子 任务对应的目标计算节点。 9.一种计算任务分配方法， 其中， 所述方法， 包括： 接收传播来的任务待分配消息； 所述任务待分配消息 中包括计算任务对应的多个子任 务的需求信息； 所述任务待分配消息由分布式计算系统中发起所述计算任务的任务 发起计 算节点生成； 根据自身的资源分配情况以及所述任务待分配消息， 生成子任务申领消息； 将所述子任务申领消息发送给所述任务发起计算节点， 以由所述任务发起计算节点根 据所述子任务申领消息对所述多个子任务进行分配。 10.根据权利要求9所述的方法， 其中， 还 包括： 接收到所述任务待分配消息后， 判断所述任务待分配消息 中的任务版本信 息是否在历 史消息接收记录中； 若所述任务版本信 息不在所述历史消息接收记录中， 则在所述历史消息接收记录 中记 录所述任务版本信息， 并处 理所述任务待分配消息； 若所述任务版本信息在所述历史消息 接收记录中， 则忽略所述任务待分配消息 。 11.根据权利要求10所述的方法， 其中， 若所述任务版本信 息不在所述历史消息接收记 录中， 则在所述历史消息接收记录中记录所述任务版本信息， 并处理所述任务待分配消息， 包括： 若所述任务版本信 息不在所述历史消息接收记录中， 则判断所述任务待分配消息是否 超期； 若所述任务待分配消息未超期， 则在所述历史消息接收记录中记录所述任务版本信 息， 并处理所述任务待分配消息 。 12.根据权利要求9至1 1中任一项所述的方法， 其中， 还 包括： 根据所述任务待分配消息 中所述多个子任务各自对应的申领状态， 确定出未被申领子 任务； 根据自身的资源分配情况以及所述任务待分配消息中所述未被申领子任务的需求信 息， 生成子任务申领消息；权　利　要　求　书 2/3 页 3 CN 115525423 A 3