SQL搜索处理
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$validate(FlinkPlannerImpl.scala:149) \tat org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate...
示例代码
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;...
Linux实例如何在Web服务中绑定域名
Tomcat服务绑定域名 Apache服务绑定域名 Apache服务配置实现多域名跳转 Apache服务配置二级域名 Apache禁止未经许可的域名访问ECS实例上的网站 Nginx服务绑定域名 如下为配置Nginx服务绑定域名的步骤，此处的Nginx程序以通过Yum安装的Nginx...
开发运行中的其他问题
org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery.getUpsertKeysInKeyGroupRange(Lorg/apache/calcite/rel/RelNode;[I)Ljava/util/Set;报错：Task did not exit gracefully within 180+seconds.报错：Can not retract ...
Java常见问题
如果您的工程使用与Apache httpclient 4.4.1冲突的版本，请您使用4.4.1版本，并在pom.xml删除其它版本的Apache httpclient依赖。如果您的工程使用了commons-httpclient，也可能存在冲突，请删除commons-httpclient。解除依赖冲突。如果您的...
收发普通消息（三种方式）
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;import ...
收发顺序消息
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;...
收发事务消息
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....
使用Hive访问
Derby，下载地址为 官网地址，本文中使用的Apache Derby 版本为10.13.1.1。下载Hive压缩包，下载地址为 官网地址 本文中使用的Apache Hive版本为2.3.7。配置 Apache Derby 解压Hive压缩包到指定目录。tar-zxvf db-derby-10.13.1.1-bin.tar....
CreateTable-新增元数据表
新增数据湖的元数据表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI ...SerdeInfo":{"Parameters":{},"SerializationLib":"org.apache.hadoop.hive.ql.io.orc.OrcSerde"}
安装软件包
install apache2 说明 若您需要安装其他软件包，请将上述命令中 apache2 替换为您实际需要安装的软件包名称。在OpenSUSE上安装软件包 远程连接Linux实例。具体操作，请参见 通过密码或密钥认证登录Linux实例。执行以下命令，安装Apache软件...
系统检查点或作业快照的超时与失败
org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.aliyun.oss.AliyunOSSOutputStream.close(AliyunOSSOutputStream.java:82) at org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.FSDataOutputStream$PositionCache....
Dataphin计算源为CDH,代码任务运行报错“java.lang....
Error,return code 2 from org.apache.hadoop.hive.ql.exec.tez.TezTask.Vertex failed,vertexName=Map 1,vertexId=vertex_1647589880332_0092_1_00, diagnostics=[Task failed,taskId=task_1647589880332_0092_1_00_000000, diagnostics=...
收发定时消息和延时消息
社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持配置延时...
从JDBC connector导入
org.apache.flink.table.api._import org.apache.flink.types.Row import org.apache.flink.table.api.{ TableEnvironment,TableSchema,Types, ValidationException } import org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink ...
已接入CDN的网站迁移至Windows实例后，访问该站点提示...
通过Apache的 error_log 信息可以判断，该Windows实例上没有线程来处理访问请求，导致该问题。说明 Windows操作系统中Apache程序使用 mpm_winnt 模块，该模块默认的线程数为64。当Web请求数超过该线程数时，Apache将无法正常提供服务。更多...
自定义Source
org.apache.flume flume-ng-core 1.9.0 说明 1.9.0 为Flume的版本信息，需要根据您Flume的版本信息进行替换。编写自定义的Source类。org.example.MySource 实现了一个按照特定格式打印日志的Source。package org.example;import java.text....
使用Flink SQL消费实时变更数据示例
org.apache.flink flink-java 1.13.2 org.apache.flink flink-streaming-java_2.12 1.13.2 org.apache.flink flink-connector-kafka_2.11 1.13.2 org.apache.flink flink-clients_2.12 1.13.2 org.apache.flink flink-table 1.13.2 pom org...
对象存储OSS使用JavaSDK的ContentMD5提示“log4j”...
请参见以下操作进行处理：log4j是Apache的服务，可在工程的src文件夹下面创建 log4j.properties 文件，内容如下所示。Configure logging for testing:optionally with log file log4j.rootLogger=WARN, stdout#log4j.rootLogger=WARN,...
部署LAMP环境（Ubuntu）
systemctl start apache2 sudo systemctl enable apache2 运行以下命令，查看Apache服务状态。sudo systemctl status apache2 返回结果类似如下所示，表示Apache已启动。步骤二：安装并配置MySQL 安装MySQL。运行以下命令，安装MySQL。sudo...
其他常见问题
com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl$FragmentContentDriver.next(XMLDocumentFragmentScannerImpl.java:2784) at com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next...
使用Flink访问
本文介绍使用自建的Apache Flink访问文件引擎。准备工作 开通文件引擎，详情请参见 开通指南。在计算节点上安装JDK，版本不能低于1.8。在计算节点上安装Scala。Scala下载地址为 官方链接，其版本要与使用的Apache Spark版本相兼容。下载...
SSL接入点PLAIN机制收发消息
org.apache.kafka kafka-clients 2.4.0 org.slf4j slf4j-log4j12 1.7.6 说明 建议您保持服务端和客户端版本一致，即保持客户端库版本和 云消息队列 Kafka 版 实例的大版本一致。您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面获取 ...
Dataphin中数据集成任务运行报错“java.io....
org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.getFileInfo(ClientNamenodeProtocolTranslatorPB.java:788) [hadoop-hdfs-2.6.0-cdh5.16.2.jar:na]&at sun.reflect.NativeMethodAccessorImpl.invoke0(Native ...
Dataphin中代码任务运行jar包报错“Java heap space”
org.apache.http.util.CharArrayBuffer.(CharArrayBuffer.java:56)&at org.apache.http.util.EntityUtils.toString(EntityUtils.java:224)&at org.apache.http.util.EntityUtils.toString(EntityUtils.java:270)&at org.apache....
Low Level REST Client(5.x)
rest 5.5.3 org.apache.logging.log4j log4j-core 2.7.1 org.apache.logging.log4j log4j-api 2.7.1 重要 Log4j可能存在远程代码执行漏洞，详细信息请参见 漏洞公告|Apache Log4j2远程代码执行漏洞。示例 单击下载 完整示例代码。通过Java ...
数据服务集群
DataServing是阿里云E-MapReduce提供的基于Apache HBase的数据服务集群类型。本文为您介绍数据服务集群支持的特性，适用场景以及技术架构。特性介绍 Apache HBase是具有高可靠性、高性能、列存储、可伸缩、实时读写的开源NoSQL分布式系统。...
使用Cloud Toolkit开发Dubbo微服务应用样例工程
Toolkit快速创建Apache Dubbo应用样例工程，验证后，再使用Cloud Toolkit部署到EDAS上。本文以IntelliJ IDEA为例介绍如何创建一个以Nacos作为注册中心的Apache Dubbo应用样例工程。准备工作 在使用Cloud Toolkit创建Apache Dubbo应用样例...
数据湖元数据配置
org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions。说明 Iceberg 0.11.0开始引入，仅Spark 3.x支持。spark.sql.catalog.iceberg.Catalog名称。固定值为 org.apache.iceberg.spark.SparkCatalog。spark.sql.catalog....
在文件存储 HDFS 版上使用Presto
presto-hadoop-apache2/target/hadoop-apache2-2.7.4-9.jar presto-server-0.265.1/plugin/hive-hadoop2/配置presto-cli-xxx-executable.jar。将下载的presto-cli-xxx-executable.jar复制到 presto-server-0.265.1/bin/目录。cp presto-cli...
SQL常见问题
org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.aliyun.oss.AliyunOSSFileSystemStore.listObjects(AliyunOSSFileSystemStore.java:506) at org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.aliyun.oss....
基础使用
spark.sql.extensions=org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions \-conf spark.sql.catalog.iceberg=org.apache.iceberg.spark.SparkCatalog \ conf spark.sql.catalog.iceberg.catalog-impl=org.apache.iceberg...
JAR作业开发
true apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true检查您的 settings.xml 配置文件中是否存在*配置。如果存在*配置，则需要将此配置改为 oss....
Dataphin中提交Spark任务报错“Missing application ...
org.apache.spark.launcher.CommandBuilderUtils.checkArgument(CommandBuilderUtils.java:241) at org.apache.spark.launcher.SparkSubmitCommandBuilder.buildSparkSubmitArgs(SparkSubmitCommandBuilder.java:160) at org.apache.spark....
MapReduce开发手册
作业内容如下所示：ossref:/jars/wordcount.jar org.apache.hadoop.examples.EmrWordCount oss:/data/WordCount/Input oss:/data/WordCount/Output 代码中的 需要替换为您实际的OSS Bucket，oss:/data/WordCount/Input 和 oss:/data/...
Hive作业异常排查及处理
org.apache.hadoop.hive.ql.exec.GroupByOperator.updateAggregations(GroupByOperator.java:611) at org.apache.hadoop.hive.ql.exec.GroupByOperator.processHashAggr(GroupByOperator.java:813) at org.apache.hadoop.hive.ql.exec....
开发代码示例
org.apache.httpcomponents httpclient 4.5.2 com.alibaba fastjson 1.2.82 示例代码 package org.hitsdb.client;import java.io.IOException;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java....
GetPartitions
org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat 表的InputFormat。Location String oss:/data/xxx 表的路径。OutputFormat String org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat 表的OutputFormat。...
Spark批式读写Iceberg
provided org.apache.spark spark-sql_2.12 3.1.1 provided org.apache.iceberg iceberg-core 0.12.0 provided 说明 由于EMR集群的Iceberg软件包与开源依赖包存在一定差异，例如EMR Iceberg默认集成了DLF Catalog，所以建议您在本地使用...
PHP
打开Apache2配置文件/etc/apache2/apache2.conf，找到如下片段进行相应修改。Options Indexes FollowSymLinks AllowOverride All Require all granted 在 var/www/html/aliyun-oss-appserver-php 目录下，新建一个.htaccess 文件，填写如下...
- 产品推荐
- 这些文档可能帮助您