常见报错
本文介绍配置任务和任务运行时系统返回的报错信息（如重试信息或错误码）以及解决方法。说明 本文以正则表达式（(.*)?的形式表示报错信息中的变量。若报错无法解决，您可以 通过钉钉（钉钉通讯客户端下载地址）进入到DTS客户交流钉钉群...
Blink和Flink常见问题及诊断
本文为您介绍使用Hologres过程中关于Blink和Flink的常见问题。基本概念 Hologres性能 写入性能 列存表：InsertOrIgnore>InsertOrReplace>InsertOrUpdate 行存表：InsertOrReplcae=InsertOrUpdate>InsertOrIgnore 参数 说明 InsertOrIgnore ...
MapReduce常见问题
解决措施 MapReduce接口的Table Info Builder是ProjectName和TableName，两个接口分别设置为Project名称和Table名称。执行MaxCompute MapReduce时，报错ODPS-0123144，如何解决？问题现象：执行MaxCompute MapReduce时，返回报错如下。...
常见问题
解决办法：您需要在连接串中对特殊字符进行转义处理，转义规则如下。21@:%40#:%23$:%24%:%25^:%5e&:%26*:%2a(:%28):%29_:%5f+:%2b=:%3d 示例：密码为 ab@c 时，在连接串中对特殊字符进行转义处理，密码对应为 ab%40%23c。常见原因6：云数据...
使用本地客户端（odpscmd）连接
如果您习惯使用命令行工具或者需要快速执行任务且不需要图形界面，建议您使用MaxCompute客户端访问MaxCompute项目并执行命令。MaxCompute客户端直接在您的本地计算机上运行，提供了一个简单且高效的方式来执行命令和管理MaxCompute服务。...
PyODPS常见问题
本文为您介绍使用PyODPS时的常见问题。问题类别 常见问题 安装PyODPS 安装PyODPS时，提示Warning:XXX not ...table_names=['table1',.,'tableN']dfs=[o.get_table(tn).to_df()for tn in table_names]reduce(lambda x,y:x.union(y),dfs)...
从Kafka同步数据
当您需要将消息队列Kafka的数据实时同步至云数据库ClickHouse中时，本文档为您提供了详细的解决方案，以满足您的数据实时处理需求。说明 云数据库ClickHouse 集群从Kafka进行数据同步目前仅支持云消息队列Kafka和部署在ECS上的自建Kafka。...
X-Engine引擎常见问题
使用集群主地址 连接数据库集群，根据需要查询的库名和表名在 XENGINE_SUBTABLE 表中查询该表对应的 TABLE_SPACE_ID，并通过查询到的 TABLE_SPACE_ID 在 INFORMATION_SCHEMA 的 XENGINE_TABLE_SPACE 表中查看该表已使用的extent数量，再...
不兼容SQL重写
报错信息：FAILED:ODPS-0130131:[1,50]Table not found-table meta_dev.not_exist_table cannot be resolved worker.restart.instance.timeout 旧版MaxCompute UDF每输出一条记录，便会触发一次对分布式文件系统的写操作，同时会向Fuxi发送...
关键缺陷通知
您可以通过报错或问题描述，检查您当前的业务中是否产生了相关问题，提前进行问题规避。建议加入实时数仓Hologres交流群联系对应技术支持协助您将产品升级到最新版本，详情请参见 如何获取更多的在线支持？背景信息 缺陷及修复说明 缺陷...
通过Flink导入数据
云数据库 SelectDB 版 兼容Apache Doris，支持通过Flink Doris Connector，将Kafka中的非结构化数据以及MySQL等上游业务数据库中的变更数据，实时同步到 云数据库 SelectDB 版 中，有效地满足海量数据的分析需求。功能介绍 Flink Doris ...
填写输入框（网页）
1.组件介绍 说明 必要前置组件：打开新网页 或 获取已打开的网页 利用本组件可以对Chrome、Edge、IE浏览器内，指定网页中的指定文本输入框进行内容填写,支持以文本或快捷键的方式覆盖或追加输入内容，支持模拟人工的方式进行输入。...
SQL 编辑和执行
格式化 单击该按钮对选中的 SQL 语句或当前 SQL 窗口中的所有 SQL 语句进行统一的格式化（缩进、换行和高亮关键字等操作）。IN 值转化 批量复制转化工具，适用于查询数据时对复制的行或列结果进行格式转化。将批量数据粘贴在 SQL 编辑区后...
Hologres权限相关
解决办法 方法一：可以根据业务需求在 简单权限模型 下授予相关的权限。方法二：将DB的简单权限模型切换成专家权限模型，具体操作，请参见 权限模型转换。重要 专家权限模型权限粒度较细，管理难度较高，不建议轻易切换成专家权限模型。
Table Group设置最佳实践
数据总规模 推荐Shard数 推荐规格 4000万行以下 10～20 32Core以上 4000万行～4亿行 20～40 64Core以上 4亿行～40亿行 40～80 128Core以上 40亿行～400亿行 80～240 256Core以上，考虑创建新的Table Group 400亿行～4000亿行 160～400 512...
如何使用RPA操作MySQL数据库
通过RPA编辑器获取到页面数据之后，除了可将数据保存到本地表格之外，也可直接将数据处理后传输到数据库中，本文档主要介绍使用RPA获取页面数据场景中、将获取到的数据传输到数据库的实践方法。重要 本文档仅针对获取数据并传输到数据库的...
MariaDB数据源
如果您的表数字后缀的长度一致，例如 'table_000'、'table_001'、'table_002' 直到 'table_999'，您可以配置为 '"table":["table_00[0-9]","table_0[10-99]","table_[100-999]"]'。说明 任务会读取匹配到的所有表，具体读取这些表中 column...
图解MySQL 8.0优化器查询解析篇
本文重点介绍了优化器基于规则的其中一部分优化，更多的偏重于SQL中的基本操作符，如表、列、函数、聚合、分组和排序等元素的解析和设置，以及一些显而易见的结构变化。背景和架构 通过编写程序来动态实现应用所需要的逻辑，从而在程序执行...
使用存储过程将数据导入Hologres内部表（Beta）
示例如下：CREATE FOREIGN TABLE customer("c_customer_sk"int8,"c_customer_id"text,"c_current_cdemo_sk"int8,"c_current_hdemo_sk"int8,"c_current_addr_sk"int8,"c_first_shipto_date_sk"int8,"c_first_sales_date_sk"int8,"c_...
GBase8a数据源
GBase8a数据源为您提供读取和写入GBase8a双向通道的功能，本文为您介绍DataWorks的GBase8a数据同步的能力支持情况。使用限制 目前Gbase8a Reader和Gbase8a Writer仅支持使用 新增和使用独享数据集成资源组。insert into.：当主键或唯一性...
Spark FAQ
解决方案：具体解决办法请参见 Spark Executor出现Dead怎么处理。2.查看Driver日志，是否有异常信息导致Task终止并重试。查看方式：单击展开对应作业的 操作 列表，点击 SparkUI 进入 Spark 页面，切换到 Executors 页面，找到 Executor ID...
通过PrestoDB使用Tablestore
写入数据 插入一行数据 以下示例用于在main_table中插入一行数据。insert into main_table values(10001,10001,true,100,'hangzhou');批量导入数据 重要 批量导入数据前，请确保已创建目标表，且目标表的表结构与源数据表的表结构保持一致...
SQL诊断
仅包含 CREATE TABLE、DROP TABLE、TRUNCATE TABLE、ALTER TABLE、CALL、CREATE EXTENSION、CREATE FOREIGN TABLE、ALTER FOREIGN TABLE、IMPORT FOREIGN SCHEMA、DROP FOREIGN TABLE、CREATE SCHEMA、CREATE VIEW、DROP VIEW、GRANT、...
MySQL数据源
如果您的表数字后缀的长度一致，例如 'table_000'、'table_001'、'table_002' 直到 'table_999'，您可以配置为 '"table":["table_00[0-9]","table_0[10-99]","table_[100-999]"]'。说明 任务会读取匹配到的所有表，具体读取这些表中 column...
对接MaxCompute常见问题与诊断
如果以上操作都做完了，还是导入不了，如果使用的是 insert on conflict 命令，请排查是否外表重复数据太多，重复数据太多也会导致导入性能不好，可以在MaxCompute做重复数据去重，再进行导入，详情请参见 多行数据合并为一行数据。...
ODC 常见问题
得到结果：character_set_client utf8mb4 character_set_connection utf8mb4 character_set_filesystem binary character_set_results utf8mb4 character_set_system utf8mb4 从现象可看出数据的字符集是 utf8mb4，且数据库认为客户端使用...
MaxCompute UDF（Python）常见问题
问题现象三：MaxCompute UDF中使用 get_cache_table(table_name)时，运行报错描述为 odps.distcache.DistributedCacheError:Table resource"xxx_table_name"not found。产生原因：原因一：表资源不存在。注册MaxCompute UDF时未同步指定表...
JDBC数据源
例如 mysql-connector-java-8.0.25.jar，SelectDB会自动在本地 jdbc_drivers/目录下查找相应jar包，其中默认包含了 mysql-connector-java-8.0.25.jar、postgresql-42.5.1.jar、mssql-jdbc-11.2.3.jre8.jar、ojdbc8.jar 这4个常用的Driver包...
CREATE TRIGGER
语法 CREATE[CONSTRAINT]TRIGGER name { BEFORE|AFTER|INSTEAD OF } { event[OR.]} ON table_name[FROM referenced_table_name][NOT DEFERRABLE|[DEFERRABLE][INITIALLY IMMEDIATE|INITIALLY DEFERRED]][REFERENCING { { OLD|NEW } TABLE...
图解MySQL 8.0优化器查询转换篇
背景和架构 在 图解MySQL 8.0优化器查询解析篇 一文中我们重点介绍了MySQL最新版本8.0.25关于SQL基本元素表、列、函数、聚合、分组、排序等元素的解析、设置和转换过程，本篇我们继续来介绍更为复杂的子查询、分区表和JOIN的转换优化过程。...
更新或删除数据（UPDATE|DELETE）
推荐方案：UPDATE table1 SET col1=(SELECT value1 FROM table2 WHERE table1.id=table2.id AND table1.region=table2.region);不推荐方案：UPDATE table1 SET col1=1 WHERE id='2021063001'AND region='beijing';UPDATE table1 SET col1=2...
DM（达梦）数据源
DM（达梦）数据源作为数据中枢，为您提供读取和写入DM数据库的双向通道，能够快速解决海量数据的计算问题。本文为您介绍DataWorks的DM数据同步的能力支持情况。使用限制 离线同步支持读取视图表。DM Reader和DM Writer仅支持使用 独享数据...
使用OSS Foreign Table进行数据湖分析
本文介绍如何使用OSS Foreign Table（OSS外表，简称OSS FDW）导入OSS中的数据并进行数据分析。功能介绍 OSS FDW基于PG FDW（PostgreSQL Foreign Data Wrapper）框架进行开发，通过OSS FDW，您可以进行如下操作：将OSS数据导入本地表（行存...
使用SQL导入MaxCompute的数据至Hologres
CREATE FOREIGN TABLE foreign_customer("c_customer_sk"int8,"c_customer_id"text,"c_current_cdemo_sk"int8,"c_current_hdemo_sk"int8,"c_current_addr_sk"int8,"c_first_shipto_date_sk"int8,"c_first_sales_date_sk"int8,"c_salutation...
Python SDK常见问题
本文为您介绍Python SDK常见问题，即PyODPS。问题类别 常见问题 安装PyODPS 安装PyODPS时，提示Warning:XXX not ...table_names=['table1',.,'tableN']dfs=[o.get_table(tn).to_df()for tn in table_names]reduce(lambda x,y:x.union(y),...
ALTER TABLE
命令格式 alter table<table_name>changeowner to;参数说明 table_name：必填。待修改Owner的表名。new_owner：必填。修改后的Owner账号。使用示例-将表test1的所有人修改为ALIYUN$xxx@aliyun.com。alter table test1 changeowner to '...
pg_hint_plan
示例命令如下：/*+NestLoop(t1 t2)MergeJoin(t1 t2 t3)Leading(t1 t2 t3)*/SELECT*FROM table1 t1 JOIN table table2 t2 ON(t1.key=t2.key)JOIN table table3 t3 ON(t2.key=t3.key);说明 其中 NestLoop(t1 t2)：指定表t1和t2的连接方法。...
pg_hint_plan
示例命令如下：/*+NestLoop(t1 t2)MergeJoin(t1 t2 t3)Leading(t1 t2 t3)*/SELECT*FROM table1 t1 JOIN table table2 t2 ON(t1.key=t2.key)JOIN table table3 t3 ON(t2.key=t3.key);说明 其中 NestLoop(t1 t2)：指定表t1和t2的连接方法。...
CREATE TABLE
本文介绍 AnalyticDB for MySQL 的 CREATE TABLE 建表语法。您将了解到如何创建分区表和维表，以及如何定义表的分布键、分区键、索引、生命周期、冷热数据分层等。设置默认值、自增列 设置主键 设置分布键 设置分区键与生命周期 设置聚集...
CREATE DATABASE AS（CDAS）语句
例如/新建CTAS作业同步新增加的表new_table CREATE TABLE IF NOT EXISTS new_table AS TABLE mysql.tpcds.new_table/*+OPTIONS('server-id'='8008-8010')*/;停止现有CDAS作业，清理已同步的数据后，以全新状态重启CDAS作业来重新同步数据。...
- 产品推荐
- 这些文档可能帮助您