全部产品
Search
文档中心

实时计算Flink版:任务编排(公测)

更新时间:Sep 12, 2024

任务编排是一个全托管的工作流调度服务,通过可视化的操作界面轻松地编排批作业运行的顺序,构建数据仓库,在实时计算Flink版平台实现开发、调度、部署和运维一体化。

重要
  • 任务编排目前为公测功能,公测阶段不保障服务等级协议SLA,详情请参见实时计算Flink版服务等级协议(SLA)。如果您在使用过程中遇到相关问题,可以提交工单

  • 仅华东2(上海)、华东1(杭州)、华北2(北京)、华南1(深圳)、华北3(张家口)、新加坡地域支持任务编排功能。

功能介绍

任务编排.png

  • 可视化管理:支持通过可视化的方式创建或管理工作流。

  • 调度类型:支持手动触发和周期调度两种调度类型。

  • 定时管理:支持使用Cron表达式设置复杂规则。

  • 资源队列:支持工作流和工作流节点选择不同的部署目标。

基本概念

  • 工作流

    通过任务编排创建工作流,并在工作流中定义调度节点以及调度策略,从而安排任务在指定的时间运行。工作流是一个Dag(有向无环图)。

  • 工作流节点

    工作流中一个具体执行任务的节点。工作流节点需关联到一个已经部署的作业。

  • 工作流实例

    工作流每运行一次会产生一条工作流实例。

  • 工作流节点实例

    工作流实例中的每个节点对应的就是工作流节点实例。

  • 依赖

    节点之间运行的相互依赖。例如节点A—>节点B,即节点A是节点B的上游依赖,节点B的运行依赖节点A,在满足节点B运行的其他条件外,还需要节点A完成运行,节点B才能运行。

  • 工作流版本

    工作流版本指工作流每次编辑(例如添加或删除节点、变更依赖关系等)保存后会生成一个新的工作流版本。

使用流程

image

相关文档