指定构建矢量金字塔的并行任务数，默认为0（表示并行最大化）。并行任务数最大不应该超过CPU数量的4倍。并行构建使用了两阶段事务机制，需要设置数据库max_prepared_transactions参数，需要设置max_prepared_transactions=100或者更高，...
指定构建矢量金字塔的并行任务数，默认为0（表示并行最大化）。并行任务数最大不应该超过CPU数量的4倍。并行构建使用了两阶段事务机制，需要设置数据库max_prepared_transactions参数，需要设置max_prepared_transactions=100或者更高，...
获取
任务列表。接口说明 在调用该接口前，需要在POM文件添加以下依赖：<dependency><groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-schedulerx2</artifactId> <version>1.0.5</version> </dependency>调试 您可以在OpenAPI ...
ErrorMsg 如果导入任务状态为CANCELLED，则显示失败的原因，包括type和msg两部分。如果导入任务成功则显示N/A。type的取值意义如下：USER-CANCEL：取消的任务。ETL-RUN-FAIL：在ETL阶段失败的导入任务。ETL-QUALITY-UNSATISFIED：数据质量...
提供计算侧的文件访问缓存加速，支持计算作业直接读写OSS文件，解决并行任务的I/O和吞吐问题 大规模并行计算调度，提供容器/虚拟机执行环境，支持多种异构计算，加速基因分析。工程化的流程执行引擎，支持GA4GH标准（WDL/CWL）,无需迁移...
当发现节点故障时，ACK会根据故障原因触发对应恢复任务，并记录相应的事件。当恢复任务完成后，故障状态解除，节点恢复正常状态。当恢复任务完成后，故障状态依然存在，节点会被置为恢复失败状态。说明 如果集群中存在多个节点池，节点池...
调用GetJobInfo获取指定Jobid任务详情，通常用来更新任务。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 ...
调用ListJobs获取
任务列表。说明 在调用该接口前，需要在POM文件添加以下依赖：<dependency><groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-schedulerx2</artifactId> <version>1.0.5</version> </dependency>调试 您可以在Open...
事件中心 统一的报警、事件、故障任务流转处理 事件中心是统一的任务流转中心，统一管理整个企业业务系统运行过程中的所有报警、事件、故障。管理系统历史的所有报警记录、报警消息及时通知订阅对象，帮助企业实时发现问题，规避风险；管理...
异常原因 任务运行日志保存在指定Project下名为internal-diagnostic_log的Logstore中。当internal-diagnostic_log中的索引被删除或者未及时更新时，日志服务将不能对目标Project进行有效的任务监控。解决方案 您可以在 CloudLens for SLS ...
异常原因 任务运行日志保存在指定Project下名为internal-diagnostic_log的Logstore中。当internal-diagnostic_log中的索引被删除或者未及时更新时，日志服务将不能对目标Project进行有效的任务监控。解决方案 您可以在 CloudLens for SLS ...
问题原因 任务正在运行，无法删除。解决方案 等待任务运行结束或手动暂停任务，然后删除。版本编辑冲突问题 问题现象 出现${draft_version} is editing，can not create new version with${base_version} 报错。问题原因 基于同一个版本${...
即使其中一个节点发生故障或异常中断，其他节点仍然可以继续执行剩余的子任务，提高任务的容错性和可靠性。任务重复执行 由于各种原因导致计算任务被多次执行的情况，如重复操作、消息重复、调度重复等原因。常见的容错策略如下：去重：...
专业版公测 并行计算任务支持用户在切分子任务时自定义子任务标签，控制台子任务列表支持基于子任务查询。企业级分布式批处理方案 支持ElasticJob开发的执行器对接。兼容ElasticJob 2022-01-26 变更类型 功能描述 相关文档 新增 支持概览页...
专业版公测 并行计算任务支持用户在切分子任务时自定义子任务标签，控制台子任务列表支持基于子任务查询。支持ElasticJob开发的执行器对接。无 2022-01-26 变更类型 功能描述 相关文档 新增 支持概览页。支持日志服务。支持查看堆栈。控制...
修复RO节点的物理机出现故障时，RW节点在特殊情况下未将其复制关系中断，而引发RW节点刷脏受阻的问题。修复HA后，因表数量过多而引发table cache淘汰导致Autoinc回退的问题。修复多主集群缓存中心重启情况下，读写节点可能无法启动的问题。...
在拓扑任务中，您可以添加并行网关实现多个节点并行处理效果，满足业务存在多个独立任务需要并行处理的需求，以此提高整体处理性能。本文将快速引导您如何在拓扑任务中使用并行网关。操作步骤 创建拓扑子任务。创建两个或两个以上的简单或...
该配置项会影响到任务执行的并行度，一般配置为总文件数/Worker总数/迁移线程数（workerTaskThreadNum），最大值不要超过50000，如果不知道总文件数，请使用默认值。taskObjectSizeLimit 每个Task最大数据量，整型，单位bytes，默认1GB。该...
2024-3-12 灰度发布中 PolarDB MySQL推出数据与缓存一站式功能 任务管理 为了便于用户管理 PolarDB 集群的任务，及时感知集群备份恢复等长时任务的进度，提高集群运维效率，PolarDB 支持在任务列表查看当前任务进度和历史任务详情。...
任务调度 任务调度（Task Scheduler，简称 TS）提供分布式任务调度框架，实现任务的分布式处理，并能规范化、自动化、可视化和集中化地对金融企业不同业务系统的任务进行统一的调度和全方位的监控运维管理。产品架构 产品优势 支持集群任务...
不同表的导入，同时提交，有并行度的n个任务同时导入，出于资源控制的原因，剩余任务也需要排队串行执行。导入使用的是HybridDB for MySQL内部的资源，与查询一样，属于同一个实例的资源。推荐导入任务在查询量比较低的时段进行，比如凌晨...
配置项 描述 资源配置 开源Flink实时计算源 对于开源Flink创建的实时任务，任务的实时模式资源配置支持配置任务的生产环境和开发环境的资源队列、引擎版本以及任务的并行度、Task Manager数量、Job Manager Momory和Task Manager Momory。...
配置 PolarDB分布式版 下多个RDS MySQL至目标库的DTS任务，如其中一个DTS任务发生故障，则不影响其他DTS任务的运行，且只需恢复发生故障的DTS任务即可。稳定性一般。仅配置一个以 PolarDB分布式版 为源的DTS任务，如该DTS任务发生故障，则...
配置 PolarDB分布式版 下多个RDS MySQL至目标库的DTS任务，如其中一个DTS任务发生故障，则不影响其他DTS任务的运行，且只需恢复发生故障的DTS任务即可。稳定性一般。仅配置一个以 PolarDB分布式版 为源的DTS任务，如该DTS任务发生故障，则...
在 故障演练>任务列表 页签找到目标演练任务，在 任务状态 列查看故障演练的任务状态。故障演练任务有以下状态：已完成：任务演练完成。到达演练时长自动完成或手动结束演练任务。演练中：演练执行中，可手动结束演练任务。结束中：演练...
本文介绍如何进入任务中心，以及如何处理能力接入、应用部署等审批任务。操作步骤 登录BizWorks，您可以通过以下两种方式进入 任务中心 页面。...如果任务为并行审批任务，只要有一人审批通过（单击 同意），该审批任务即为 已完成 审批状态。
Serverless 工作流 提供了丰富的控制原语让您描述业务逻辑，例如您可以串行执行任务、并行执行任务、有选择的执行某些任务以及针对一组数据并行执行一系列任务。具体的流程描述请参见 基本介绍。如果您想了解 Serverless 工作流 是如何解决...
单击页面右上角的 高级参数配置，对同步任务运行时的并行度和资源进行配置，您可以根据Kafka Topic数据流量和分区数量确定对应配置项的取值，建议按照如下规则进行配置：读端并发数=Kafka Topic分区数 写端并发数=Kafka Topic分区数 内存=1...
对于流批一体任务的实时模式您需定义该任务实时相关的属性，包括任务资源、时间参数、Checkpoint 等。本文为您介绍流批一体任务实时模式配置的相关内容。实时模式配置入口 在Dataphin首页，单击顶部菜单栏的 研发。按照下图操作指引，进入 ...
Ververica Flink流批一体任务离线模式的资源配置支持配置任务的生产环境和开发的资源集群、引擎版本以及任务的并行度、Task Manager数量、Job Manager Momory和Task Manager Momory。本文为您如何配置流批一体任务实时模式的资源配置。操作...
保护组进入增量复制状态后，您就可以进行故障切换操作。本文介绍故障切换和恢复的基本操作。故障切换类型 数据同步后切换 该故障切换会先停止保护组中被保护的实例，并且等到所有被保护的实例停止后再进行最后一轮数据同步，等待数据同步...
Ververica Flink流批一体任务离线模式的资源配置支持配置任务的生产环境和开发的资源集群、引擎版本以及任务的并行度、Task Manager数量、Job Manager Momory和Task Manager Momory。本文为您如何配置流批一体任务实时模式的资源配置。操作...
Task 即子任务，并行计算/内存网格/网格计算，通过Map方法会产生Task。Work Flow 即工作流，Work Flow是一个DAG（有向无环图），用来做任务编排。调度时间 JobInstance每次调度的时间叫做调度时间，JobProcessor可以根据 context....
对于流批一体任务的离线模式您需定义该任务实时相关的属性，包括任务资源、时间参数、Checkpoint 等。本文为您介绍流批一体任务实时模式配置的相关内容。离线模式配置入口 在Dataphin首页，单击顶部菜单栏的 研发。按照下图操作指引，进入 ...
云工作流 提供了丰富的控制原语让您描述业务逻辑，例如您可以串行执行任务、并行执行任务、有选择的执行某些任务以及针对一组数据并行执行一系列任务。具体的流程描述，请参见 流程定义介绍。如果您想了解 云工作流 是如何解决复杂的业务...
补数据功能说明 为什么小时分钟任务补数据选择了并行但实际不生效？为什么补数据选择业务时间后不运行，实例显示黄色，实例状态显示等待时间？为什么补数据选择业务时间昨天和今天，也会出现等待时间的情况？为什么补数据选择补0点~1点生成...
Task 即子任务，并行计算/内存网格/网格计算，通过Map方法会产生Task。Work Flow 即工作流，Work Flow是一个DAG（有向无环图），用来做任务编排。调度时间 JobInstance每次调度的时间叫做调度时间，JobProcessor可以根据 context....
Task 即子任务，并行计算/内存网格/网格计算，通过Map方法会产生Task。Work Flow 即工作流，Work Flow是一个DAG（有向无环图），用来做任务编排。调度时间 JobInstance每次调度的时间叫做调度时间，JobProcessor可以根据 context....
当发生故障或异常时，通过AI助手底层的告警系统可以自动和PAI进行交互，上报故障信息，并根据故障触发阶段和并行策略选择规避故障方法，对故障机自动进行隔离，并从Checkpoint快速恢复任务。AI助手提供的具体功能如下：异常采集和上报：...
开源Flink流批一体任务实时模式的资源配置支持配置任务的生产环境和开发的资源队列、引擎版本以及任务的并行读度、Task Manager数量、Job Manager Momory和Task Manager Momory。本文为您介绍如何配置流批一体任务实时模式的资源配置。操作...