问题描述 Dataphin集成任务运行失败报错："Operation category READ is not supported in state standby。经Dlink智能分析,该任务最可能的错误原因是:com.alibaba.dt.dlink.core.exception.DlinkException: Code:[Framework-02],...
import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache.rocketmq.client.AccessChannel;import org.apache.rocketmq.client.exception.MQClientException;...
前提条件 部署开源Apache Kafka集群 购买并部署 云消息队列 Kafka 版 实例：购买并部署VPC实例 购买并部署公网/VPC实例 创建迁移任务 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在左侧菜单栏单击 迁移...
本文以一个示例为您介绍Apache Nifi如何连接Hologres。背景信息 Apache NiFi 是一个易用、可靠的数据处理与分发系统，Apache NiFi的设计目标是自动化管理系统间的数据流。Apache Nifi是一个基于WEB-UI用户界面，具有很强交互性和易用性，为...
报错：org.apache.flink.util.SerializedThrowable 报错：You are using the new V4 state engine to restore old state data from a checkpoint 报错：No space left on device 报错：java.lang.IllegalArgumentException:Illegal ...
② 去Apache Flink Dashboard 与 刷新 去Apache Flink Dashboard：Apache Flink Dashboard仅支持Flink引擎版本为 1.14及以上，单击 去Apache Flink Dashboard，您可前往 Apache Flink Dashboard 进行查看。说明 查看Apache Flink Dashboard...
管理Docker守护进程 sudo systemctl start docker#运行Docker守护进程 sudo systemctl stop docker#停止Docker守护进程 sudo systemctl restart docker#重启Docker守护进程 sudo systemctl enable docker#设置Docker开机自启动 sudo ...
调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用，用来给RAM用户或RAM...
85)at org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:134).30 more 报错原因 实时计算引擎vvr-3.0.7-flink-1.12及以前的版本，CDC Source只能单并发运行。但在实时计算引擎vvr-4.0.8-flink-1.13版本后...
设置使用接入方式为阿里云，在使用云上消息轨迹的时候，需要设置此项，如果不开启消息轨迹功能，则运行不设置此项。producer.setAccessChannel(AccessChannel.CLOUD);设置为您从阿里云控制台获取的接入点信息，类似...
42)at OSSManagerImpl.main(OSSManagerImpl.java:63)错误原因是OSS Java SDK使用了Apache HttpClient 4.4.1，而您的工程使用了与Apache HttpClient 4.4.1冲突的Apache HttpClient或commons-httpclient jar包。要查看工程使用的jar包及版本...
org.apache.flink.metrics.prometheus.PrometheusReporter dataphin.vvp.v2:true execution.checkpointing.interval:'180s' execution.checkpointing.min-pause:'180s' table.exec.state.ttl:36 h 运行参数合并及优先级说明：基于模板新建...
import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.client.producer....
Dataphin支持在实时模板中配置运行参数信息，基于当前实时模板创建的实时任务将继承所配置运行参数。本文为您介绍如何配置实时模板运行参数。操作步骤 请参见 数据开发入口，进入数据 开发 页面。在数据 开发 页面，按照下图操作指引，选择...
层可以为您提供公共依赖库、运行时环境及函数扩展等发布与部署能力。您可以将函数依赖的公共库提炼到层或者使用 函数计算 官方公共层，以减少部署或更新函数时的代码包体积。本文介绍层的功能原理、各运行时使用层说明、如何构建层的ZIP包...
spark-><dependency><groupId>org.
apache.spark</groupId><artifactId>spark-core_2.12</artifactId><version>${spark.version}</version></dependency><dependency><groupId>org.
apache.spark</groupId><artifactId>spark-sql_2.12...
base：<dependency><groupId>org.
apache.flink</groupId><artifactId>flink-connector-base</artifactId><version>${flink.version}</version></dependency>其中，${flink.version} 是作业
运行环境对应的Flink版本，如您的作业
运行在 1.15-...
本文主要介绍在 文件存储 HDFS 版 上使用Apache HBase的方法。前提条件 已开通 文件存储 HDFS 版 服务并创建文件系统实例和挂载点。具体操作，请参见 文件存储HDFS版快速入门。已为Hadoop集群所有节点安装JDK，且JDK版本不低于1.8。已部署...
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
本示例中使用的 example.conf 文件如下所示：#Listen:Allows you to bind Apache to specific IP addresses and/or#ports,instead of the default.See also the<VirtualHost>#directive.#Change this to Listen on specific IP addresses ...
模式 描述 特点 Session模式 Seesion模式会根据您设置的资源参数创建一个Flink集群，所有作业都将被提交到这个集群上运行。该集群在作业运行结束之后不会自动释放。例如，某个作业发生异常，导致一个Task Manager关闭，则其他所有运行在该...
层可以为您提供公共依赖库、运行时环境及函数扩展等发布与部署能力。您可以将函数依赖的公共库提炼到层或者使用 函数计算 官方公共层，以减少部署或更新函数时的代码包体积。本文介绍层的注意事项、各运行时使用层说明、如何构建层的ZIP包...
问题描述 代码任务中运行JAR包报错“Java heap space”，本地运行正常。Exception in thread"main"java.lang.OutOfMemoryError:Java heap space at org.apache.http.util.CharArrayBuffer.<init>(CharArrayBuffer.java:56)at org.apache....
pom依赖<dependency><groupId>org.elasticsearch.client</groupId><artifactId>rest</artifactId><version>5.5.3</version></dependency><dependency><groupId>org.
apache.logging.log4j</groupId><artifactId>log4j-core</artifactId>...
应用运行环境 应用运行的环境，例如HSF应用的运行环境EDAS-Container或开源应用的运行容器（如Apache Tomcat）。应用诊断 EDAS针对应用提供了详细的问题排查和性能分析，包括提供当前应用运行的单机上的JVM堆／非堆内存、类加载...
最近运行状态 运行状态根据最近一次任务的运行情况来定义，包含待运行、运行中、运行成功、运行失败、手动终止、未运行（-），其中：待运行：出现并行任务时，排队中的任务状态显示为待运行。手动终止：当任务在待运行或运行中时，通过单击...
关于Apache Paimon的详细信息，请参见 Apache Paimon。前提条件 当前执行操作的账号已具备创建MaxCompute表（CreateTable）的权限。更多表权限信息，请参见 MaxCompute权限。已创建MaxCompute项目。具体操作，请参见 创建MaxCompute项目。...
groupId>org.
apache.spark</groupId><artifactId>spark-core_2.12</artifactId><version>3.1.1</version><scope>provided</scope></dependency><dependency><groupId>org.
apache.spark</groupId><artifactId>spark-sql_2.12...
实例统计展示系统内离线实例和实时实例的运行详情、运行趋势、运行失败实例数排行、失败报警实例数排行等信息，帮助您从项目视角或全局视角，把控实例运行的情况。本文为您介绍运维中心的实例统计。实例统计入口 请参见 运维中心入口，进入...
实例统计展示系统内离线实例和实时实例的运行详情、运行趋势、运行失败实例数排行、失败报警实例数排行等信息，帮助您从项目视角或全局视角，把控实例运行的情况。本文为您介绍运维中心的实例统计。实例统计入口 请参见 运维中心入口，进入...
说明 请确保在代码运行环境设置了环境变量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET。具体配置方法，请参见 配置方案。String accessKeyId=System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");String accessKeySecret=...
实例运行状态及实例运行流程如下：运行状态标识 标识描述 运行流程图 未运行 等待调度时间 限流中 等待调度资源 运行中 成功 失败 实例是否能成功运行，受其上游依赖、调度时间、资源、实例本身运行情况等多方因素影响。当实例运行失败或长...
实例运行状态及实例运行流程如下：运行状态标识 标识描述 运行流程图 未运行 等待调度时间 限流中 等待调度资源 运行中 成功 失败 实例是否能成功运行，受其上游依赖、调度时间、资源、实例本身运行情况等多方因素影响。当实例运行失败或长...
Flink SQL Flink SQL节点是基于Apache Flink（以下简称Flink）开发的商业版，适用于以YARN模式部署运行的Flink节点，具体操作，请参见 新建Flink SQL类型的公共节点。Spark Stream Spark Stream节点是适用于在Hadoop+yarn集群上运行的Spark...
待到日常环境测试阶段运行结束后，空闲下来，开始再次运行，此时是接续持续集成阶段第三次运行的版本继续运行，而不是接续持续集成阶段第二次运行的版本继续运行。亦支持在前一阶段运行完成时，若后一阶段正在运行，强制中止后一阶段当前...
package org.myorg.example import org.apache.flink.streaming.api.scala._import org.apache.flink.table.sources._import org.apache.flink.table.api.scala.StreamTableEnvironment import org.apache.flink.table.api._import org....
创建HBase集群后，您可以使用HBase Shell连接HBase，并进行读取和写入数据等操作。本文为您介绍如何连接HBase，以及常用的HBase ...drop 'table1' 相关文档 您可以查看Apache HBase Shell官方文档了解更多信息，详情请参见 Apache HBase官网。
运行实例入口 在DataTrust首页，单击顶部菜单栏的 通用计算。进入 运行实例 页面。按照下图指引，进入 运行实例 页面。查看及管理隐私计算运行实例 隐私计算任务运行后，您可在运维列表查看实例日志及重新运行实例。区域 描述 ① 筛选及...
调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 GetPartitions 系统规定参数。取值：...
Fat JAR Fat JAR Fat JAR 是一种可执行的 JAR 包（Executable JAR），包含编译后的类及代码运行所需依赖 jar 的存档，可以使用 java-jar 命令运行该应用程序。Fat JAR 和普通的 JAR 不同在于它包含了依赖的 JAR 包。Gradle Gradle ...