从Kafka源表中读取数据，将JDBC表作为维表，并将二者生成的表信息写入Kafka结果表中，其具体步骤如下： 参考增强型跨源连接，在 DLI 上根据MySQL和Kafka所在的虚拟私有云和子网分别创建相应的增强型跨源连接，并绑定所要使用的Flink弹性资源池。 设置MySQL和Kafka的安全组，添加

查看更多 →

选择“SDKs”，单击加号选择“JDK”。 在弹出的“Select Home Directory for JDK”窗口，选择对应的JDK目录，然后单击“OK”。 完成JDK选择后，单击“Apply”。 选择“Project”，在“Project SDK”下的下拉菜单中选择在“SDKs”中添加的JDK，在“Project

查看更多 →

值不离散，查询会全表扫描，导致JDBC连接超时。 图1 非索引列 解决方案 优先联系DBA修改表结构，将需要过滤的列配置为索引列，然后重试。 如果由于数据不离散，导致还是失败请参考2~4，通过增大JDBC超时时间解决。 根据作业找到对应的MySQL连接名称，查找连接信息。 图2 连接信息

查看更多 →

创建或获取该任务中创建Loader作业的业务用户和密码。 确保用户已授权访问作业执行时操作的Hive表。 获取关系型数据库使用的用户和密码。 检查磁盘空间，确保没有出现告警且余量满足导入、导出数据的大小。 如果设置的作业需要使用指定YARN队列功能，该用户需要已授权有相关YARN队列的权限。 设置任务的用户需要

查看更多 →

如果设置的作业需要使用指定YARN队列功能，该用户需要已授权有相关YARN队列的权限。 设置任务的用户需要获取该任务的执行权限，并获取该任务对应的连接的使用权限。 操作前需要进行如下配置： 从MySQL数据库安装路径下获取MySQL客户端jar包（如mysqlclient-5.8

查看更多 →

如果设置的作业需要使用指定YARN队列功能，该用户需要已授权有相关YARN队列的权限。 设置任务的用户需要获取该任务的执行权限，并获取该任务对应的连接的使用权限。 操作前需要进行如下配置： 从MySQL数据库安装路径下获取MySQL客户端jar包（如mysqlclient-5.8

查看更多 →

编写开机运行脚本 应用容器化时，一般需要准备开机运行的脚本，写作脚本的方式和写一般shell脚本相同。该脚本的主要目的包括： 启动应用所依赖的软件。 将需要修改的配置设置为环境变量。 开机运行脚本与应用实际需求直接相关，每个应用所写的开机脚本会有所区别。请根据实际业务需求来写该脚本。

查看更多 →

GaussDB (for MySQL)与RDS for MySQL的区别 GaussDB(for MySQL)拥有较好的性能、扩展性和易用性，详情请参见表1。 表1 GaussDB(for MySQL)与RDS for MySQL的差异 类别 RDS for MySQL GaussDB(for

查看更多 →

通过JDBC访问Spark SQL的程序 场景说明 Java样例代码 Scala样例代码 Python样例代码 父主题： 开发Spark应用

查看更多 →

设置任务的用户需要获取该任务的执行权限，并获取该任务对应的连接的使用权限。 操作前需要进行如下配置： 获取关系型数据库对应的驱动jar包保存在Loader服务主备节点的lib路径：“${BIGDATA_HOME}/ FusionInsight _Porter_8.1.0.1/inst

查看更多 →

选择“SDKs”，单击加号选择“JDK”。 在弹出的“Select Home Directory for JDK”窗口，选择对应的JDK目录，然后单击“OK”。 完成JDK选择后，单击“Apply”。 选择“Project”，在“Project SDK”下的下拉菜单中选择在“SDKs”中添加的JDK，在“Project

查看更多 →

gMap的名称可以命名为“template-dbconfig”等。使用相同的前缀，可以使用户更方便识别Kubernetes资源的归属，同时降低命名冲突的可能性。 建议3：当全局变量的值是多行文本时，文本中出现的空行应不含任何空格字符。 全局变量将用于生成Chart包中的“values

查看更多 →

不建议分区列选择类型为float或double的字段，因为精度问题，可能导致分区列字段的最小值、最大值所在记录无法导入。 id 分区列空值 配置对数据库列中为null值记录的处理方式。 值为“true”时，分区列的值为null的数据会被处理； 值为“false”时，分区列的值为null的数据不会被处理。 true

查看更多 →

不建议分区列选择类型为float或double的字段，因为精度问题，可能导致分区列字段的最小值、最大值所在记录无法导入。 id 分区列空值 配置对数据库列中为null值记录的处理方式。 值为“true”时，分区列的值为null的数据会被处理； 值为“false”时，分区列的值为null的数据不会被处理。 true

查看更多 →

如上图，实线为DCG指示激活AZ1，虚线为DCG指示激活为AZ2。DCG指示当前激活的数据中心，SDK根据DCG的指示，在相应的数据中心操作，读写操作都在一边进行。 配置如下： # 基础信息 - 可选项, 当配置etcd后为必选 props: version: v1 // 项目版本号，自定义

查看更多 →

<keytool工具的安装路径> 请替换为JDK或JRE安装路径的bin目录，例如C:\Program Files (x86)\Java\jdk11.0.7\bin。 <MySQLCACert> 请设置truststore文件的名称。建议设置为具有业务意义的名称，便于后续识别。 <ca

查看更多 →

xxx:3306 数据库连接地址 mysql.connection-user xxxx 数据库登录用户名 mysql.connection-password xxxx 数据库密码 重启Presto服务。 启用Kerberos认证的集群，执行以下命令连接本集群的Presto Server。

查看更多 →

设置任务的用户需要获取该任务的执行权限，并获取该任务对应的连接的使用权限。 操作前需要进行如下配置： 获取关系型数据库对应的驱动jar包保存在Loader服务主备节点的lib路径：“${BIGDATA_HOME}/FusionInsight_Porter_xxx/install/

查看更多 →

是 数据源类型，‘jdbc’表示使用JDBC connector，必须为jdbc connector.url 是 数据库的URL connector.table 是 读取数据库中的数据所在的表名 connector.driver 否 连接数据库所需要的驱动。若未配置，则会自动通过URL提取

查看更多 →

无 String 指定要使用的连接器，这里应该是'jdbc'。 url 是 无 String 数据库的URL。 table-name 是 无 String 读取数据库中的数据所在的表名。 driver 否 无 String 连接数据库所需要的驱动。若未配置，则会自动通过URL提取。

查看更多 →

基于JDBC开发 JDBC（Java Database Connectivity，java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问接口，应用程序可基于它操作数据。 GaussDB库提供了对JDBC 4.0特性的支持，需要使用JDK1

查看更多 →