预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共21页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN114579286A(43)申请公布日2022.06.03(21)申请号202210481629.7(22)申请日2022.05.05(71)申请人支付宝(杭州)信息技术有限公司地址310000浙江省杭州市西湖区西溪路556号8层B段801-11(72)发明人简道红顾科才丁皓吴华(74)专利代理机构北京博思佳知识产权代理有限公司11415专利代理师李威(51)Int.Cl.G06F9/48(2006.01)G06F9/50(2006.01)G06F9/455(2006.01)权利要求书3页说明书12页附图5页(54)发明名称任务调度系统、方法、设备及存储介质(57)摘要本说明书一个或多个实施例提供一种任务调度系统、方法、设备及存储介质,任务调度系统包括第一数据节点和多个第二数据节点;第一数据节点包括第一任务队列,第一任务队列指示未分配且待执行的若干子任务;第二数据节点用于执行第一数据节点分配的子任务;以及每执行完一个子任务之后向第一数据节点发送子任务获取请求;第一数据节点用于在非首次子任务分配过程中,若第一任务队列非空,响应于子任务获取请求,根据第一任务队列获取新的子任务,并将新的子任务调度到第二数据节点上。有利于提高运行效率。CN114579286ACN114579286A权利要求书1/3页1.一种任务调度系统,所述任务调度系统包括第一数据节点和多个第二数据节点;所述第一数据节点包括第一任务队列,所述第一任务队列指示未分配且待执行的若干子任务;所述第二数据节点用于执行所述第一数据节点分配的子任务;以及每执行完一个所述子任务之后向所述第一数据节点发送子任务获取请求;所述第一数据节点用于若所述第一任务队列非空,响应于所述子任务获取请求,根据所述第一任务队列获取新的子任务,并将所述新的子任务调度到所述第二数据节点上。2.根据权利要求1所述的系统,所述若干子任务从运筹优化任务中分解得到;其中,所述运筹优化任务含有M个决策变量,每个所述子任务用于求解所述运筹优化任务中的N个决策变量,N小于M且N、M均为大于0的整数。3.根据权利要求1所述的系统,所述第一数据节点还用于在首次子任务分配过程中,根据所述第一任务队列向各个所述第二数据节点分配其一次能够执行的至少一个子任务。4.根据权利要求3所述的系统,所述第二数据节点启动有至少一个进程,每个进程用于执行一个所述子任务;所述第二数据节点一次能够并行执行的子任务数量根据所述第二数据节点中的进程数量确定;所述第二数据节点中的进程数量根据所述第二数据节点的总资源和执行所述子任务所需资源确定。5.根据权利要求4所述的系统,所述进程与所述第一数据节点通信连接;所述进程用于每执行完一个所述子任务之后向所述第一数据节点发送子任务获取请求;所述第一数据节点还用于响应于所述子任务获取请求,将所述新的子任务调度到所述进程上。6.根据权利要求1所述的系统,所述第二数据节点还用于向所述第一数据节点上报在本节点上执行的子任务的状态信息;所述第一数据节点还用于在所述状态信息指示在所述第二数据节点上执行的子任务已执行完成的情况下,响应于所述子任务获取请求。7.根据权利要求6所述的系统,所述第二数据节点启动有至少一个进程,每个进程用于执行一个所述子任务;所述进程与所述第一数据节点通信连接;所述状态信息由执行所述子任务的进程向所述第一数据节点上报。8.根据权利要求6所述的系统,所述第一数据节点还包括第二任务队列,所述第二任务队列指示已分配的子任务;所述第一数据节点还用于将已分配的子任务的唯一标识写入所述第二任务队列中,并标记所述子任务的执行状态为未完成;以及在接收到所述第二数据节点上报的状态信息指示子任务已完成的情况下,将所述状态信息指示的子任务的执行状态修改为已完成。9.根据权利要求1所述的系统,所述第一数据节点还用于在确定所述第二数据节点异常的情况下,调用指定接口重启所述第二数据节点的镜像数据节点,并将在所述第二数据节点中运行的至少一个子任务分配给所述镜像数据节点。2CN114579286A权利要求书2/3页10.根据权利要求1至9任意一项所述的系统,所述任务调度系统应用于K8s集群,所述第一数据节点和所述第二数据节点为K8s集群中的两种不同的Pod。11.一种任务调度方法,应用于任务调度系统,所述任务调度系统包括第一数据节点和多个第二数据节点;所述方法由所述第一数据节点执行,所述第一数据节点包括第一任务队列,所述第一任务队列指示未分配且待执行的若干子任务;所述方法包括:接收所述第二数据节点每执行完一个所述子任务之后发送的子任务获取请求;若所述第一任务队列非空,响应于所述子任务获取请求,根据所述第一任务队列获取新的子任务,并将所述新的子任务调度到所述第二数据