任务开发完成后,可提交上线,操作步骤如下:
注意
在提交上线过程中,如果触发了流水线管理,您需要确保流水线运行成功后,任务才能真正被提交到运维中心。操作详见4 流水线管理。
登录DataLeap控制台。
选择数据开发 > 任务开发 > 数据开发页签,进入任务开发页面。
选择要上线的任务,单击左上角提交上线图标,弹出提交上线窗口。

设置回溯数据、监控设置、提交设置等信息后,单击确认按钮,即完成任务提交。
离线任务提交上线参数说明:
参数 | 说明 |
|---|
回溯说明:提交上线时,是否重跑历史数据,此操作只回溯当前任务本身。 |
否 | 不进行任务回溯。 |
是 | 需要重跑历史数据。 - 回溯业务时间:选择回溯的业务开始和结束时间。
- 最大并行:设置最大并行数,此次回溯中,包含的所有实例,允许同时运行的实例个数,使用动态分区的任务下多个实例重跑时,并行度需设置为1。
- 表分区检查:
- 回溯实例执行前,根据依赖设置,检查依赖上游任务,登记产出的数据表及对应分区是否存在。
- 若“1”中检查不通过,则实例状态变为:终止(终止,表分区不存在)。
- 若“忽略上游依赖”,则被忽略的任务产出的表对应分区将不再检查。
- 生成实例状态:
- 依赖检查:
- 遵循依赖设置,上游完成后再开始执行
- 忽略上游依赖,立即执行
- 指定回溯队列:任务本身支持队列配置,且回溯任务责任人有指定队列权限,否则不生效
- 指定可调度时段:指定可调度时段后,此次回溯生成的全部回溯实例,都将在该运行时段执行。如:
- 若设置时间为:06:00~22:00,则回溯实例将在当日早上6点到晚上10点执行
- 若设置时间为:22:00~06:00,则回溯实例将在当日晚上10点到次日早上6点执行
说明 - “00:00~08:00”是核心任务执行高峰时段,为避免回溯/重跑影响例行,引发全局事故,建议开启该设置,且避开该时段。
- “调度”不等价于“执行”,系统仅负责将对应实例提交调度至引擎,是否执行由引擎侧决定。
|
监控设置 |
默认监控规则 | - 目前,默认监控规则由系统提供,用户不可修改。
- 任务上线时/上线后,用户可选择是否使用默认监控规则。
- 默认监控规则:离线任务重试结束仍失败,报警以飞书形式发送给任务负责人,且仅发送1次;
说明 若选中任务中包含Kafka->HDFS任务,默认监控规则对该类型任务不生效。 |
自定义监控规则 | - 从项目已创建的监控规则中,选择适用规则,对该任务运行进行监控。
- 可选择多个监控规则,对任务运行进行监控。
监控规则创建请参见“监控规则管理”。 |
基线监控规则 | - 从项目已创建的基线中,选择适用基线,对该任务及其全部上游任务进行监控。
- 一个任务,只允许加入一条基线。
基线监控创建请参见“基线监控”。 |
提交设置 |
提交设置 | - 仅提交:任务仅提交,发布需前往发布中心操作发布。请参见“待发布”。
- 提交并发布:提交并直接发布任务到运维中心。
- 复查人:项目下配置复查策略时,需选定复查人员,复查配置请参见“配置发布复查策略”。
|
流式任务提交上线参数说明:
参数 | 说明 |
|---|
上线检查 | - 配置检查:检查任务的基本配置、流式SQL等配置信息。
- 资源检查:Flink任务资源配置上下限和队列资源相关检查信息。
|
监控设置 | 流式任务支持自定义监控规则设置: - 可从项目已创建的监控规则中,选择适用规则,对该任务运行进行监控;
- 可选择多个监控规则,对任务运行进行监控。
监控规则创建请参见“报警监控”。 |
提交设置 | - 提交设置:
- 仅提交:任务仅提交,发布需前往发布中心操作发布。
- 提交并发布:提交并直接发布任务到运维中心。
- 复查人:项目下配置复查策略时可见,需选定复查人员,复查配置详见“配置发布复查策略”。
- 提交说明:输入本次提交说明,方便后续版本管理。
|
启动设置 | 流式任务上线后,可选择是**否**直接启动运行。选择直接重启时,您可按需选择以下重启模式: - 使用最新状态重启:可选择流式作业的最新可用快照,进行重启。
- 使用历史快照重启:若当前任务有历史快照保存,您可选择保存的历史快照信息,进行重启。
- 无状态重启:不使用快照信息,直接重启。
除Datagen数据源连接器外,您需额外判断任务是否需要重置offset,开启重置offset,您还需配置消费起始位置,可选择以下位置:
- 最新:直接从最新的消费起始位置重启;
- 最老:从最老的消费起始位置重启;
- 时间戳:您可根据实际情况指定时间所在的消费起始位置重启。
|
说明
实时任务运维列表的“重启”功能以线上配置为准,不应用最新版本草稿。
提交上线信息后,单击确认按钮,即完成任务提交。