管理工作流

使用限制

• 仅已部署的批作业支持创建工作流进行任务调度。

• 任务编排目前为公测功能，公测阶段不保障服务等级协议SLA。如果您在使用过程中遇到相关问题，可以提交工单。

• 仅中国地区支持任务编排功能。

创建工作流

1. 登录实时计算控制台。

2. 在Flink全托管页签，单击目标工作空间操作列下的控制台。

3. 在左侧导航栏，单击任务编排。

4. 单击创建工作流，填写如下信息。

   参数	描述
   工作流名称	工作流名称在当前项目中必须保持唯一。
   调度类型	支持两种调度类型： 手动触发：只能通过手动单击触发运行工作流，触发一次运行一次。 周期调度：根据调度器规则触发工作流运行，支持按分钟、小时、天等定时运行。
   调度周期	仅周期调度类型需要设置。支持使用Cron表达式设置复杂规则，示例如下： 0 0 */4 ? * *：每隔4小时执行。 0 0 2 ? * *：每天2点执行。 0 0 5,17 ? * MON-FRI：周一至周五5点和17点执行。
   调度开始时间	生效时间点。仅周期调度类型需要设置。 重要 周期调度工作流创建后，需要将调度状态开启，才能在生效时间点触发运行。
   失败重试次数	为工作流中的节点统一设置失败重试的次数，默认失败不重试。
   失败通知	工作流节点失败时默认的通知邮箱。
   资源队列	工作流的部署目标，详情请参见管理资源队列。默认对节点生效，无需对节点做额外配置。 说明 此处的配置不会修改对应已部署批作业的部署目标。
   标签	可以选择为工作流设置标签名和标签值。

5. 单击创建。

   创建后会进入工作流节点编辑页面。

6. 配置工作流初始节点。

   工作流节点编辑页面默认存在一个初始节点，单击初始节点，在弹出的编辑节点面板中，配置节点相关参数，单击保存。

   参数	说明
   作业	仅支持选择当前项目空间下的已部署批作业。支持模糊搜索方式搜索添加。
   节点名称	节点在当前工作流中的名称。
   上游节点	当前节点的上游依赖，仅能选择当前工作流中的其他节点。 说明 初始节点无上游依赖，不支持选择上游节点。
   失败重试次数	为工作流中的节点设置失败重试的次数。默认与工作流重试次数一致，如设置则节点优先级高。
   状态订阅	配置节点状态订阅策略及通知邮箱，支持启动和失败状态订阅。
   超时时间	节点执行时间超时时长，超过该时间则认为节点运行失败。
   资源队列	节点的部署目标，详情请参见管理资源队列。不填写时默认使用工作流配置的资源队列。 说明 此处的配置不会修改对应已部署批作业的部署目标。
   标签	可以选择为工作流节点设置标签名和标签值。

7. （可选）单击页面下方的添加节点来添加更多节点。

8. 保存工作流相关配置。

   1. 单击节点编辑页面右上方的保存。

   2. 在弹出的对话框中，单击确定。

运行工作流

每运行一次工作流，在工作流详情页面的工作流实例列表与详情页签都会产生一个工作流实例。

• 手动触发

  单击目标工作流操作列下的触发运行，每单击触发一次工作流即运行一次。

• 周期调度

  需要将目标工作流的调度状态开启，才能在生效时间点触发工作流运行。

工作流状态

您可以在目标工作流的运行状态列，查看该工作流运行的所有工作流实例的运行状态。例如，一个工作流每天运行一次，运行5天，则产生5条工作流实例，运行状态列为这5条工作流实例的运行状况数量统计。

编辑工作流

1. 登录实时计算控制台。

2. 在Flink全托管页签，单击目标工作空间操作列下的控制台。

3. 在左侧导航栏，单击任务编排。

4. 单击目标工作流操作列下的编辑工作流。

   具体参数配置说明请参见创建工作流。

   说明

   工作流调度状态为开启时无法进行编辑。

相关文档

• 任务编排的相关基本概念，详情请参见任务编排（公测）。

• 查看工作流实例、节点日志等，详情请参见管理工作流实例和节点实例。

• 您可以通过添加资源队列进行资源隔离和管理，详情请参见管理资源队列。

• 批作业（SQL、JAR、Python）部署，具体操作请参见部署作业。