(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211269138.2 (22)申请日 2022.10.17 (71)申请人 平凯星辰 （北京） 科技有限公司 地址 100192 北京市海淀区西小口路6 6号 中关村东升科技园 ·北领地C-1楼2层 207 (72)发明人 李霞　莫航杰　黄潇　刘奇　 黄东旭　崔秋　 (74)专利代理 机构 北京市立方律师事务所 11330 专利代理师 张筱宁 (51)Int.Cl. G06F 9/48(2006.01) G06F 16/27(2019.01) (54)发明名称 DDL任务的分布式处理方法、 节点及分布式 数据库系统 (57)摘要 本申请实施例提供了一种DDL任务的分布式 处理方法、 节点及分布式数据库系统， 涉及数据 库领域。 该方法包括： 从分布式数据库系统中的 DDL任务队列中获得待执行的DDL任务； 将DDL任 务拆分为多个子任务； 创建每个子任务的调度信 息， 调度信息包括执行状态信息， 初始的执行状 态信息为未执行， 以使 得各节点中的至少一个执 行节点根据各子任务的调度信息确定未执行的 目标子任务， 以及根据执行目标子任务的情况， 更新目标子任务的调度信息。 本申请实施例实现 了通过多个节点执行一个DDL任务， 相比现有技 术实现了去中心化的处理方式， 并且解决了现有 的DDL任务执 行能力、 灵活性和效率 不足的问题。 权利要求书2页 说明书10页 附图5页 CN 115454613 A 2022.12.09 CN 115454613 A 1.一种数据定义语言DDL任务的分布式处理方法， 其特征在于， 应用于分布式数据库系 统的各节点中的至少一个主节点， 所述方法包括： 从分布式数据库系统中的D DL任务队列中获得待执 行的DDL任务； 将所述DDL任务拆分为多个子任务； 创建每个子任务的调度信息， 所述调度信息包括执行状态信息， 初始 的执行状态信息 为未执行， 以使得所述各节点中的至少一个执行节点根据各子任务的调 度信息确定未执行 的目标子任务， 以及根据执 行所述目标子任务的情况， 更新所述目标子任务的调度信息 。 2.根据权利要求1所述的方法， 其特征在于， 所述将所述DDL任务拆分为多个子任务， 包 括： 分多轮对所述D DL任务进行拆分； 其中， 每一轮拆分的子任务的数量与各节点在当前轮的回调线程的数量相关， 且在每 一轮拆分后， 根据所述DDL任务尚未拆分的部分确定是否展示各节点调整在下一轮的回调 线程的数量； 每个回调线程用于执 行一个子任务。 3.根据权利要求1所述的方法， 其特 征在于， 更新后的执 行状态信息包括已完成； 所述方法还 包括： 根据所述DDL任务的所有子任务对应的执行状态信息均 为已完成， 确定所述DDL任务执 行完成。 4.根据权利要求1所述的方法， 其特征在于， 所述调度信息还包括子任务所属的DDL任 务的任务标识； 所述方法还 包括： 确定取消执 行的DDL任务的任务标识； 确定包括所述取消执 行的DDL任务的任务标识的目标调度信息； 将所述目标调度信 息的执行状态信 息更新为待取消执行， 以使得执行相应子任务的执 行节点根据目标调度信息的执行状态信息更新为待取消执行， 取消执行对应的子任务， 并 在取消执 行后将目标调度信息的执 行状态信息更新 为已取消执 行。 5.根据权利要求1 ‑4任意一项所述的方法， 其特征在于， 所述调度信 息还包括子任务的 子任务标识、 子任务的起始值、 结束值、 当前处理的值、 执行所述子任务的回调线程的线程 标识、 租约信息、 处 理行数或错误信息中的至少一种。 6.一种数据定义语言DDL任务的分布式处理方法， 其特征在于， 应用于分布式数据库系 统的各节点中的至少一个执 行节点， 所述方法包括： 获取DDL任务的各子任务的调度信息， 所述调度信 息包括执行状态信息， 初始的执行状 态信息为未 执行； 根据各子任务的调度信息确定未 执行的目标子任务； 发起抢占所述目标子任务， 若抢占成功则执 行所述目标子任务； 根据执行所述目标子任务的情况， 更新所述目标子任务的调度信息； 其中， 所述子任务是分布式数据库系统中的主节点从DDL任务队列中获得待执行的DDL 任务后拆分得到的， 所述子任务的调度信息是 所述主节点创建的。 7.根据权利要求6所述的方法， 其特 征在于， 所述执 行节点包括至少一个回调线程；权　利　要　求　书 1/2 页 2 CN 115454613 A 2所述发起抢占所述目标子任务， 若抢占成功则执 行所述目标子任务， 包括： 由状态为空闲的回调线程发起抢占所述目标子任务， 若抢占成功， 则由所述回调线程 执行所述目标子任务， 并将所述回调线程的状态更新 为忙碌。 8.根据权利要求6所述的方法， 其特 征在于， 所述执 行所述目标子任务， 还 包括： 若根据所述目标子任务的执行状态信息更新为待取消执行， 停止执行所述目标子任 务； 所述根据执行所述目标子任务的情况， 更新所述目标子任务的调度信息， 包括： 根据停止执 行所述目标子任务， 更新所述目标子任务的执 行状态信息为已取消执 行。 9.一种分布式数据库系统中的主节点， 其特 征在于， 包括： 任务获取模块， 用于从分布式数据库系统中的D DL任务队列中获得待执 行的DDL任务； 任务拆分模块， 用于将所述D DL任务拆分为多个子任务； 调度信息创建模块， 用于创建每个子任务的调度信息， 所述调度信息包括执行状态信 息， 初始的执行状态信息为未执行， 以使得所述各节点中的至少一个执行节点根据各子任 务的调度信息确定未执行 的目标子任务， 以及根据执行所述 目标子任务的情况， 更新所述 目标子任务的调度信息 。 10.一种分布式数据库系统中的执 行节点， 其特 征在于， 包括： 调度信息获取模块， 用于获取DDL任务的各子任务的调度信 息， 所述调度信息包括执行 状态信息， 初始的执 行状态信息为未 执行； 子任务确定模块， 用于根据各子任务的调度信息确定未 执行的目标子任务； 子任务执 行模块， 用于发起抢占所述目标子任务， 若抢占成功则执 行所述目标子任务； 调度信息更新模块， 用于根据执行所述目标子任务的情况， 更新所述目标子任务的调 度信息； 其中， 所述子任务是分布式数据库系统中的主节点从DDL任务队列中获得待执行的DDL 任务后拆分得到的， 所述子任务的调度信息是 所述主节点创建的。 11.一种分布式数据库系统， 其特征在于， 包括至少一个如权利要求9所述的主节点以 及至少一个如权利要求10所述的执 行节点。 12.一种电子设备， 包括存储器、 处理器及存储在存储器上的计算机程序， 其特征在于， 所述处理器执行所述计算机程序以实现权利要求1 ‑8任一项所述DDL任务的分布式处理方 法的步骤。 13.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1 ‑8任一项所述的D DL任务的分布式处 理方法的步骤。权　利　要　求　书 2/2 页 3 CN 115454613 A 3