一种流应用的配置方法、节点及流计算系统

摘要

本发明实施例公开了一种流应用的配置方法、节点及流计算系统，涉及计算机技术领域，可以对流应用进行升级，以使得流应用能够处理新增业务逻辑的待处理业务，并避免对系统资源的过多占用。具体方案为：控制节点获取流应用的增量流图和数据流格式文件；控制节点根据增量流图生成控制指令，并向至少一个工作节点发送控制指令，控制指令用于指示至少一个工作节点创建待新增算子，并创建待新增算子与待新增算子的上、下游算子之间的消息通道；控制节点向至少一个工作节点发送数据流格式文件，以指示至少一个工作节点根据数据流格式文件，为至少一个工作节点上创建的待新增算子和待新增算子的上、下游算子，配置数据格式。

主权项

一种流应用的配置方法，应用于流计算系统中的控制节点，所述流计算系统包括所述控制节点和至少一个工作节点，多个算子分布于所述至少一个工作节点中的一个或多个工作节点上，用于对所述流计算系统上部署的流应用的数据进行处理，其特征在于，所述方法包括：所述控制节点获取流应用的增量流图和数据流格式文件，所述增量流图用于指示待新增算子以及所述待新增算子与所述待新增算子的上、下游算子之间的数据流走向，所述数据流格式文件用于指示所述待新增算子的数据格式和所述待新增算子的上、下游算子的数据格式，所述数据格式包括输入数据格式和输出数据格式；所述控制节点根据所述增量流图生成控制指令，并向所述至少一个工作节点发送所述控制指令，所述控制指令用于指示所述至少一个工作节点创建所述待新增算子，并根据所述待新增算子与所述待新增算子的上、下游算子之间的数据流走向，创建所述待新增算子与所述待新增算子的上、下游算子之间的消息通道；所述控制节点向所述至少一个工作节点发送所述数据流格式文件，以指示所述至少一个工作节点根据所述数据流格式文件，为所述至少一个工作节点上创建的所述待新增算子和所述待新增算子的上、下游算子，配置所述数据格式。