1 .一种分布式系统的任务处理方法,所述分布式系统包括至少两个控制节点和至少两
个工作节点,所述至少两个控制节点与元数据表连接,所述元数据表适于存储任务信息,且
所述至少两个控制节点包括动态选举出的主控制节点,所述方法包括:
控制节点在要创建任务时,判断自己是否为主控制节点,若是,创建任务并将任务信息
写入到元数据表中,否则,停止创建任务;
主控制节点从元数据表中获取任务,并将获取的任务下发到工作节点,以便工作节点
执行所述任务。
2.如权利要求1所述的方法,还包括:
主控制节点定期从工作节点收集状态被标记为无效的任务,将元数据表中该任务的状
态更新为无效,并不再对该任务进行下发,其中,工作节点在接收到主控制节点下发的第一
任务时,会将第一任务与正在执行的第二任务进行对比,若第一任务与第二任务重复,则将
第一任务的状态标记为无效,并不再执行第一任务。
3 .如权利要求1或2所述的方法,还包括:
主控制节点定期从工作节点获取正在执行的任务所处的任务阶段,将获取的任务阶段
与元数据表中该任务的任务阶段进行比较,若二者不一致,则将元数据表中的该任务的任
务阶段更新为所获取的任务阶段,并基于更新后的任务阶段进行任务的下发。
4 .如权利要求1至3中任一项所述的方法,还包括:
主控制节点定期从工作节点获取状态异常的任务,所述状态异常包括由于工作节点宕
机恢复或者迁移引起的节点标识发生变化;
主控制节点将元数据库中该任务的节点标识更新为变化后的节点标识,并将更新后的
任务重新下发到工作节点。
5 .如权利要求1至4中任一项所述的方法,所述任务为:用于将本地数据归档到云存储
的任务、用于对本地数据执行过期处理的任务、用于对数据结构和索引进行重建操作的任
务或者用于对数据进行压缩操作的任务。
6 .一种分布式系统的任务处理方法,所述分布式系统包括至少两个控制节点和至少两
个工作节点,所述至少两个控制节点与元数据表连接,所述元数据表适于存储任务信息,且
所述至少两个控制节点包括动态选举出的主控制节点,所述方法包括:
主控制节点从元数据表中获取任务,并将获取的任务下发到工作节点,以便工作节点
执行所述任务;
主控制节点定期从工作节点收集状态被标记为无效的任务,将元数据表中该任务的状
态更新为无效,并不再对该任务进行下发,其中,工作节点在接收到主控制节点下发的第一
任务时,会将第一任务与正在执行的第二任务进行对比,若第一任务与第二任务重复,则将
第一任务的状态标记为无效,并不再执行第一任务。
7 .一种分布式系统的任务处理方法,所述分布式系统包括至少两个控制节点和至少两
个工作节点,所述至少两个控制节点与元数据表连接,所述元数据表适于存储任务信息,且
所述至少两个控制节点包括动态选举出的主控制节点,所述方法包括:
主控制节点从元数据表中获取任务,并将获取的任务下发到工作节点,以便工作节点
执行所述任务;
主控制节点定期从工作节点获取正在执行的任务所处的任务阶段,将获取的任务阶段
权 利 要 求 书
1/4 页
2
评论