如上图所示，假设整个DataWorks有6个任务节点，任务D和任务E是基线上的任务，则影响任务D和任务E数据产出的上游任务，即上图中的任务A、任务B、任务D和任务E，均会被纳入监控范围，监控范围内的任务出现异常（出错或变慢），均会被智能基线...
问题修复 修复 修复Map任务在多个节点间无法互联的问题。修复JobContext有可能是nil导致panic的问题。无 v0.0.4，2024-03-08 功能名称 变更类型 功能描述 相关文档 任务执行模式 新增 支持MapReduce任务 Golang任务 v0.0.2，2023-12-14 ...
任务重复执行 由于各种原因导致计算任务被多次执行的情况，如重复操作、消息重复、调度重复等原因。常见的容错策略如下：去重：可以使用唯一标识符来标识任务，检查任务是否已经在系统中存在。如果任务已经存在，则不再重复执行，而是直接...
Java SDK 产品降价 优化 任务托管CU大幅降价，用的越多省的越多。SchedulerX降价公告 2024-01-25 功能名称 变更类型 功能描述 相关文档 Go版本SDK 新增 支持MapReduce任务。Golang SDK接入 Golang任务 Go SDK 工作流 新增 支持通过流程图和...
条件 可以为SWITCH任务配置多个条件，当条件满足时，会执行指定的分支，可以配置多个不同的条件来满足不同的业务，使用字符串判断时需要使用"。例如：${switchValue}="A。分支流转 默认的流转分支，当所有条件均不满足时，则运行默认流转...
如果任务失败或者部分失败，在 output 中根据不同的任务也会输出响应的 code 和 message 信息指明失败的原因，对于有的任务包含多个子任务，有可能会分别有多个成功和失败的任务。output.task_id String 查询任务的 task_id a8532587-xxxx-...
每个任务最多只能添加16个资源。演练方式 选择演练方式。取值：立即开始：演练任务创建成功后立即开始执行演练。暂不演练：仅创建演练任务，暂不执行演练。设置演练任务的演练时长。默认为180分钟，最大值72小时，最小值1分钟。描述 输入...
修复客户端实例数很多的时候，子任务详情机器列表无法分页的问题。修复任务管理查看历史记录无数据的问题。2020-09-30 新特性 公网region支持pop API。支持使用appKey鉴权（应用Key，代替AccessKey ID或AccessKey Secret）。HTTP任务支持...
每个迁移源和迁移任务最多可以绑定20个标签，区分大小写。标签所在的所有迁移源或迁移任务被删除后，对应的标签也会被删除。解绑标签后，如果该标签不再绑定任何资源，则会被自动删除。新建标签时的限制：键是必选项，最多支持64个字符，不...
如需对该任务的多个不连续的时间段补数据，可单击 添加多段业务日期，配置多个时间段。当 业务日期 晚于当前日期，可选择 立即运行定时时间大于此刻的补数据实例，后续当实际时间大于配置的 业务日期 时，平台会立即运行该补数据实例。例如...
iTAG官方模板提供了多种RLHF模板，如多模态RLHF标注、对话排序、对话改写、图生文模板，您可以基于系统提供的这些模板修改为符合自己业务需求的模板，然后再创建对应的标注任务并进行处理，从而提高您的模型训练效果。进入智能标注 iTAG-...
通过轮询 GetTask-获取任务信息 直到任务完成同样可以获取到任务状态，但这种方式的效率很低，在任务处理时间比较长的场景中，需要大量的 GetTask-获取任务信息 调用，如果堆积的任务比较多，可能会触发全局限流，影响其他接口的调用。...
云原生数据仓库 AnalyticDB PostgreSQL 版 的定时任务，支持在指定时间点执行批处理任务，如定时更新数据、备份数据或清理过期数据等，能够确保任务按照预定计划进行，避免遗漏或延迟，节省时间和人力成本，实现自动准确高效的任务执行，...
修复MapTask Master在子任务比较多的情况下，可能会频繁误failover的问题。无 1.2.5.2，2021-4-8 变更类型 功能描述 相关文档 新增 秒级别任务间隔支持到毫秒级别。无 优化 MapReduce模型，root Task固定在master node执行，方便排查问题。...
文件处理 API 标题 API概述 压缩解压 压缩解压 CreateFileCompressionTask 创建文件压缩任务 文件压缩任务可以将您的多个文件，打包为zip等压缩包。您提交任务后会异步打包文件，将结果存储到指定位置。在打包时支持对文件进行重命名操作，...
批量创建 当一次录入多个服务后，MSHA控制台会异步执行这些任务，此时任务的运行状态为 同步任务创建中。当同步任务状态为 同步中 时，说明该服务已经从源注册中心同步到目标注册中心。相关操作 注册中心同步配置完成后，在注册中心同步...
说明 同一个迁移任务最多可绑定20个标签。中转实例规格 可根据实际需求选择中转实例规格。选择中转实例规格：系统会选择该实例规格创建中转实例。若该实例规格库存不足，则迁移任务创建失败。不选择中转实例规格：系统默认会按照顺序选择...
使用限制 单一转码任务只支持一路转码规格进行转码，单账号并发转码任务最多支持10路，如果您有其他需求，请联系您的阿里云客户经理。转码任务输入的直播流当前只支持RTMP协议。输出流地址当前只支持基于阿里云视频直播创建的播流域名，...
请合理规划任务定时时间，错开任务运行时间，选择购买高规格资源组，或单个资源组购买多台机器。并发任务数说明 不同规格资源组支持同时运行的任务数不同，详情请参见：独享调度资源组计费说明：包年包月。说明 任务下发到对应引擎上执行时...
分布式任务可以选择拉模型，所有计算节点向master节点拉取子任务，控制全局最多同时运行多少子任务。任务优先级队列 应用级别的流控，一个应用同时最多运行多少个任务。企业可观测能力 SchedulerX拥有丰富的可视化能力，例如：用户大盘 ...
在 任务管理 的 操作 列，单击目标任务的 更多，然后选择 指定机器。在 指定机器 页面，选择 指定类型 为 标签，勾选对应的机器，单击 确定。灰度验证通过后，所有机器都将上线新的任务实现类。可将指定标签删除，实现动态生效。
SchedulerX可以对多重任务进行调度（定时、编排、重刷历史数据等），提供Java、Python、Shell和Go等多语言分片模型，帮助您处理大数据业务需求。背景信息 分片模型主要包含静态分片和动态分片。静态分片：主要场景是处理固定的分片数，例如...
离线计算任务支持的批量操作 操作 描述 批量获取锁 支持同时获取多个计算任务的编辑锁并锁定。批量提交 支持同时提交多个计算任务。批量下线 支持同时下线多个计算任务。批量下线删除 支持同时下线多个计算任务并删除。批量移动 支持同时...
离线计算任务支持的批量操作 操作 描述 批量获取锁 支持同时获取多个计算任务的编辑锁并锁定。批量提交 支持同时提交多个计算任务。批量下线 支持同时下线多个计算任务。批量下线删除 支持同时下线多个计算任务并删除。批量移动 支持同时...
实时计算任务支持的批量操作如下：批量获取锁：支持同时获取多个计算任务的编辑锁并锁定。批量提交：支持同时提交多个计算任务。批量下线：支持同时下线多个计算任务。批量下线删除：支持同时下线多个计算任务并删除。批量移动：支持同时...
实时计算任务支持的批量操作如下：批量获取锁：支持同时获取多个计算任务的编辑锁并锁定。批量提交：支持同时提交多个计算任务。批量下线：支持同时下线多个计算任务。批量下线删除：支持同时下线多个计算任务并删除。批量移动：支持同时...
监控任务管理可针对不同来源的任务进行统一监控任务的配置管理，支持批量创建、手动创建以及通过内置监控端对第三方系统和其他需要监控的任务创建。本文介绍如何手动创建监控任务。前提条件 任务来源处已完成任务配置且任务已运行。已添加...
监控任务管理可针对不同来源的任务进行统一监控任务的配置管理，支持批量创建、手动创建以及通过内置监控端对第三方系统和其他需要监控的任务创建。本文介绍如何手动创建监控任务。前提条件 任务来源处已完成任务配置且任务已运行。已添加...
用API创建K8s任务，控制台报错无法打开页面怎么办？K8s任务必须配置xAttrs属性。更多信息，请参见 Demo。支持API创建工作流吗？暂不支持。API触发任务，可以指定单次运行的机器或者Label吗？可以。触发任务的时候支持指定机器或者Label，...
在拓扑任务中，您可以添加并行网关实现多个节点并行处理效果，满足业务存在多个独立任务需要并行处理的需求，以此提高整体处理性能。本文将快速引导您如何在拓扑任务中使用并行网关。操作步骤 创建拓扑子任务。创建两个或两个以上的简单或...
一个业务应用通常包括多个定时任务。如果定时任务调度频率较高，可以直接使其与业务应用处于同一进程中。但进程内调用会消耗在线应用自身的CPU和内存，无法与在线业务隔离。所以，当一个定时任务资源消耗大且调度频率不高（例如每小时或...
您也可以勾选多个评估任务，单击页面下方的 批量重试。在弹出的对话框中，单击 确认，即可重试目标评估任务。说明 如果重试已生成报告的评估任务，原有报告将被覆盖。停止评估任务 登录 OceanBase 管理控制台。在左侧导航栏，单击 迁移评估...
本文介绍如何将Golang应用通过SDK快速接入SchedulerX。控制台配置 请参见 创建应用，创建一个普通应用，并参见 步骤2，生成配置信息。endpoint=xxxx namespace=xxxx groupId=xxx appKey=xxx...更多信息，请参见 创建调度任务。相关文档 Golang
本文介绍如何将Golang应用通过SDK快速接入SchedulerX。控制台配置 请参见 创建应用，创建一个普通应用，并参见 步骤2，生成配置信息。请参见 任务管理，创建一个Golang类型任务。...更多信息，请参见 创建调度任务。相关文档 Golang任务
DescribeReplicationJobs 查询一个或多个迁移任务的详细信息 调用DescribeReplicationJobs查询一个或多个迁移任务的详细信息。CutOverReplicationJob 停止周期执行自动增量任务 将指定的自动增量迁移任务停止周期执行，并完成迁移任务。...
前提条件 已新增实时任务，具体操作，请参见 新增实时任务、新增多表实时任务。操作步骤 登录 数据资源平台控制台。在页面左上角，单击 图标，选择 协同。在顶部菜单栏，单击 图标，选择目标工作组，单击 资产加工。在左侧导航栏，单击 ...
按量付费升级为包年包月说明 按量付费升级为包年包月服务，本质为前期使用按量付费方式执行任务，后续购买包年包月服务并以该方式执行任务。您可参考本文进行服务升级及使用：升级为包年包月服务 包年包月服务使用指导 费用情况说明 两种...
离线管道：离线管道即处理离线集成任务的一条管道脚本，可以将一个或多个来源数据源的单表或多表同步到一个或多个目标数据源中。具体操作，请参见 通过单条管道创建集成任务。脚本任务：，可以通过直接编写数据同步的JSON脚本来完成数据...
离线管道：离线管道即处理离线集成任务的一条管道脚本，可以将一个或多个来源数据源的单表或多表同步到一个或多个目标数据源中。具体操作，请参见 通过单条管道创建集成任务。脚本任务：，可以通过直接编写数据同步的JSON脚本来完成数据...
集群任务 Cluster task 支持在单个执行步骤中把数据拆分成多个数据分片（data chunk），把一个任务的数据分散到不同的机器上运行。适用于数据量很大的业务场景。调度过程分为拆分阶段和执行阶段。任务拓扑 Topology 由许多通过事件触发的...