公开(公告)号：CN115509721A

公开(公告)日：2022-12-23

申请号：CN202211330158.6

申请日：2022-10-27

Applicant: 中国兵器工业计算机应用技术研究所

Inventor： 孟英谦 ,  杜宏博 ,  杨亮 ,  王嘉岩 ,  葛天恒 ,  徐天敕 ,  葛晋鹏 ,  冯国清 ,  薛行 ,  崔琳 ,  许童

IPC: G06F9/48

Abstract: 本发明涉及一种数据处理任务协同控制调度方法及系统，属于数据处理技术领域；解决现有技术中的数据处理任务调度方法无法实现流数据处理任务与批数据处理任务的混合编排，无法满足用户选择流数据或批数据处理任务类型时无感操作的要求；本发明的方法包括以下步骤：获取当前节点的数据处理任务；根据数据处理任务的任务类型及数据处理进度设置相应的数据状态；并根据数据处理任务的执行状态设置相应的任务状态；获取当前节点的一个或多个下游任务，基于下游任务的任务类型，适配下游任务所需的数据结构；基于当前节点的任务状态、数据状态以及当前节点下游任务的任务类型，判断是否开始运行下游任务，以进行数据处理任务的协同控制调度。