参数

描述

时间属性

选择 时间属性 。 时间属性 包括：

• 正常调度 ：按照调度周期的时间配置调度，并正常执行，通常任务默认选中该项。

• 空跑调度 ：按照调度周期的时间配置调度，但都是空跑执行，即一调度到该任务便直接返回成功，没有真正的执行任务。

暂停调度

暂停调度 选择 是 后，即可暂停该任务的调度，会按照下面的调度周期时间配置调度，但是一旦调度到该任务会直接返回失败，不会执行。通常用于某个任务暂时不用执行，但后面还会继续使用的场景。

调度周期

调度周期 可选择 日 、 周 、 月 、 小时 和 分钟 ：

• 日 调度，即调度任务每天自动运行一次。新建周期任务时，系统默认的时间周期为每天0点运行一次。您可以根据需要，单击 图标，指定运行的时间点。

• 周 调度，即调度任务每周的特定几天，在特定时间点自动运行一次。您可以根据需要，单击 图标，指定运行的时间点。

  如果您没有指定日期，为保证下游实例正常运行，系统会生成实例后直接设置为运行成功，而不会真正执行任何逻辑，也不会占用资源。

• 月 调度，即调度任务在每月的特定几天，在特定时间点自动运行一次。您可以根据需要，单击 图标，指定运行的时间点。

  如果在没有被指定的日期时，为保证下游实例正常运行，系统会每天生成实例后直接设置为运行成功，而不会真正执行任何逻辑，也不会占用资源。

• 小时 调度，即每天指定的时间段内，调度任务按间隔时间数的时间间隔运行一次。或选择指定的时间点，调度系统会自动为任务生成实例并运行。您可以根据业务需求选中 时间段 或 时间点 ：

  • 如果您选中了 时间段 ，您可以单击 开始 或 结束 后的 图标，指定运行的开始和结束时间。同时您可以单击 间隔 后的 图标，在下拉列表中选择间隔时间。

  • 如果您选中了 时间点 ，单击下拉列表框，在下拉列表中选择时间点。

  例如，每天00:00~23:59的时间段内，每隔1小时会自动调度一次，因此调度系统会自动为任务生成实例并运行。

• 分钟 调度，即每天指定的时间段内，调度任务按间隔时间数的时间间隔运行一次。 您可以单击 开始 或 结束 后的 图标，指定运行的开始和结束时间。同时您可以单击 间隔 后的 图标，在下拉列表中选择间隔时间。

依赖上周期

根据业务场景选择本周期节点的运行，是否需要依赖上一周期本节点或其他节点的运行结果。

选择节点类型。系统支持选择 自定义 和 当前 。适用场景说明如下：

• 本周期节点是否运行取决于上一周期本节点是否正常产出数据，则需要选择 当前 。只有上一周期本节点运行成功，才会启动运行本节点。

• 代码任务没有用到某个节点的产出表，但业务上需要依赖该节点的上一周期是否正常产出数据，则需要选择依赖 自定义 节点。

优先级

优先级定义了同一时间同一批待调度任务的优先级。 优先级 包括：

• 最低优先级 。

• 低优先级 。

• 中等优先级 。

• 高优先级 。

• 最高优先级 。

时间参数

您可以对代码中所用参数的具体赋值。单击 节点参数配置说明 ，查看Dataphin调度系统的配置规则及支持配置的时间参数。

参数

描述

生产环境集群

默认为创建Flink SQL任务时选择的生产环境集群。您可在此处切换集群。

生产环境引擎版本

默认为创建Flink SQL任务时选择的生产环境引擎版本。您可在此处切换引擎版本。

开发环境集群及引擎版本

支持系统默认配置和自行配置。

• 系统默认配置 ：默认选择，使用与生产环境相同的环境集群与引擎版本。

• 自行配置 ：您可自行选择开发环境任务运行的环境集群及引擎版本。

  
  说明

  若您的项目空间为Basic模式，则无需配置该配置项。

并行度

配置任务运行的并行数。默认为1，可填任意大于0的整数, -1代表自动推断。

Task Manager数量

默认与并行度一致，可填任意大于0的整数。

Job Manager Memory

该任务在Flink集群的控制单元中所占用的内存资源大小。默认为1Gi，建议使用Gi/Mi/单位；可填数字（单位Byte），或填入包含以下内存单位（Gi/Mi）的数字。

Task Manager Memory

该任务在Flink集群的 Task Manager 中所占用的内存资源大小。默认为1Gi，建议使用Gi/Mi/单位；可填数字（单位Byte），或填入包含以下内存单位（Gi/Mi）的数字。

参数

描述

自动解析

当节点的任务类型为SQL时，您可以单击 自动解析 ，系统会解析代码中的表，并查找到与该表名相同的输出名称。输出名称所在的节点作为当前节点的上游依赖。

如果代码中引用项目变量或不指定项目，则系统默认解析为生产项目名，以保证生成调度的稳定性。例如，开发项目名称为 onedata_dev ：

• 如果代码里指定 select * from s_order ，则调度解析依赖为 onedata.s_order 。

• 如果代码里指定 select * from ${onedata}.s_order ，则调度解析依赖为 onedata.s_order 。

• 如果代码里指定 select * from onedata.s_order ，则调度解析依赖为 onedata.s_order 。

• 如果代码里指定 select * from onedata_dev.s_order ，则调度解析依赖为 onedata_dev.s_order 。

上游依赖

通过执行如下操作，添加该节点任务调度时依赖的上游节点：

1. 单击 手动添加上游 。

2. 在 新建上游依赖 对话框中，您可以通过以下两种方式搜索依赖节点：

   • 输入所依赖节点的输出名称的关键字进行搜索节点。

   • 输入 virtual 搜索虚拟节点（每个租户或企业在初始化时都会有一个根节点）。

   说明

   节点的输出名称是全局唯一的，且不区分大小写。

3. 单击 确定新增 。

同时您还可以单击 操作 列下的 图标，删除已添加的依赖节点。

当前节点

通过执行如下操作，设置当前节点的输出名称，根据需要您可以设置多个输出名称，供其他节点依赖使用：

1. 单击 手动添加输出 。

2. 在 新增当前节点输出 对话框中，填写输出名称。输出名称的命名规则请尽量统一，一般命名规则为 生成项目名.表名 且不区分大小写，以标识本节点产出的表，同时其他节点更好地选择调度依赖关系。

   例如，开发项目名称为 onedata_dev ，建议将输出名称设置为 onedata.s_order 。如果您将输出名称设置为 onedata_dev.s_order ，则仅限代码 select * from onedata_dev.s_order 能解析出上游依赖节点。

3. 单击 确定新增 。

同时您还可以对当前节点已添加的输出名称执行如下操作：

• 单击 操作 列下的 图标，删除已添加的输出名称。

• 如果该节点已提交或已发布，且被任务所依赖（任务已提交），则单击 操作 列下的 图标，查看下游节点。