This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-website.git
The following commit(s) were added to refs/heads/master by this push:
new a9b5bd2f326 [doc](fix) improve streaming job doc (#3516)
a9b5bd2f326 is described below
commit a9b5bd2f326f9fd1a0325a5ec87c16b569231ebb
Author: wudi <[email protected]>
AuthorDate: Fri Apr 3 15:31:57 2026 +0800
[doc](fix) improve streaming job doc (#3516)
## Versions
- [x] dev
- [x] 4.x
- [ ] 3.x
- [ ] 2.1
## Languages
- [x] Chinese
- [x] English
## Docs Checklist
- [ ] Checked by AI
- [ ] Test Cases Built
---
.../streaming-job/continuous-load-mysql-multi.md | 18 +++-----------
.../streaming-job/continuous-load-mysql-single.md | 18 +++-----------
.../streaming-job/continuous-load-overview.md | 29 ++++++++++++++++++----
.../continuous-load-postgresql-multi.md | 14 ++---------
.../continuous-load-postgresql-single.md | 16 +++---------
.../prerequisites/amazon-aurora-mysql.md | 2 +-
.../prerequisites/amazon-aurora-postgresql.md | 2 +-
.../prerequisites/amazon-rds-mysql.md | 2 +-
.../prerequisites/amazon-rds-postgresql.md | 2 +-
.../table-valued-functions/cdc-stream.md | 8 +++---
.../sql-statements/job/CREATE-STREAMING-JOB.md | 8 +++---
.../streaming-job/continuous-load-mysql-multi.md | 18 +++-----------
.../streaming-job/continuous-load-mysql-single.md | 18 +++-----------
.../streaming-job/continuous-load-overview.md | 29 ++++++++++++++++++----
.../continuous-load-postgresql-multi.md | 14 ++---------
.../continuous-load-postgresql-single.md | 16 +++---------
.../prerequisites/amazon-aurora-mysql.md | 2 +-
.../prerequisites/amazon-aurora-postgresql.md | 2 +-
.../prerequisites/amazon-rds-mysql.md | 2 +-
.../prerequisites/amazon-rds-postgresql.md | 2 +-
.../table-valued-functions/cdc-stream.md | 6 ++---
.../sql-statements/job/CREATE-STREAMING-JOB.md | 8 +++---
.../streaming-job/continuous-load-mysql-multi.md | 18 +++-----------
.../streaming-job/continuous-load-mysql-single.md | 18 +++-----------
.../streaming-job/continuous-load-overview.md | 29 ++++++++++++++++++----
.../continuous-load-postgresql-multi.md | 14 ++---------
.../continuous-load-postgresql-single.md | 16 +++---------
.../prerequisites/amazon-aurora-mysql.md | 2 +-
.../prerequisites/amazon-aurora-postgresql.md | 2 +-
.../prerequisites/amazon-rds-mysql.md | 2 +-
.../prerequisites/amazon-rds-postgresql.md | 2 +-
.../table-valued-functions/cdc-stream.md | 6 ++---
.../sql-statements/job/CREATE-STREAMING-JOB.md | 8 +++---
.../streaming-job/continuous-load-mysql-multi.md | 18 +++-----------
.../streaming-job/continuous-load-mysql-single.md | 18 +++-----------
.../streaming-job/continuous-load-overview.md | 29 ++++++++++++++++++----
.../continuous-load-postgresql-multi.md | 14 ++---------
.../continuous-load-postgresql-single.md | 16 +++---------
.../prerequisites/amazon-aurora-mysql.md | 2 +-
.../prerequisites/amazon-aurora-postgresql.md | 2 +-
.../prerequisites/amazon-rds-mysql.md | 2 +-
.../prerequisites/amazon-rds-postgresql.md | 2 +-
.../table-valued-functions/cdc-stream.md | 8 +++---
.../sql-statements/job/CREATE-STREAMING-JOB.md | 8 +++---
44 files changed, 186 insertions(+), 286 deletions(-)
diff --git
a/docs/data-operate/import/streaming-job/continuous-load-mysql-multi.md
b/docs/data-operate/import/streaming-job/continuous-load-mysql-multi.md
index 9c3d8e98a72..d8d6d231760 100644
--- a/docs/data-operate/import/streaming-job/continuous-load-mysql-multi.md
+++ b/docs/data-operate/import/streaming-job/continuous-load-mysql-multi.md
@@ -19,18 +19,6 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc), Doris supports
3. LOAD privilege is required. If the downstream table does not exist, CREATE
privilege is also required.
4. During automatic table creation, if the target table already exists, it
will be skipped, and users can customize tables according to different
scenarios.
-## Prerequisites
-
-Enable Binlog on MySQL by adding the following to my.cnf:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-If you are using a cloud service, see the [Setup
Guide](./continuous-load-overview.md).
-
## Quick Start
### Creating an Import Job
@@ -42,7 +30,7 @@ CREATE JOB multi_table_sync
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -65,7 +53,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING"
ExecuteType: STREAMING
RecurringStrategy: \N
Status: RUNNING
- ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-j-8.0.31.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
+ ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-java-8.0.25.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
CreateTime: 2025-12-10 10:19:35
SucceedTaskCount: 1
FailedTaskCount: 0
@@ -96,7 +84,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| Parameter | Default | Description
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | MySQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/docs/data-operate/import/streaming-job/continuous-load-mysql-single.md
b/docs/data-operate/import/streaming-job/continuous-load-mysql-single.md
index 6be8aa1da41..a2fd7bfc674 100644
--- a/docs/data-operate/import/streaming-job/continuous-load-mysql-single.md
+++ b/docs/data-operate/import/streaming-job/continuous-load-mysql-single.md
@@ -17,19 +17,7 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc) reading capabili
1. Supports exactly-once semantics.
2. Currently only primary key tables are supported for synchronization.
3. LOAD privilege is required.
-3. Binlog must be enabled on the MySQL side. If you are using a cloud service,
see the [Setup Guide](./continuous-load-overview.md).
-
-## Prerequisites
-
-Enable Binlog on MySQL by adding the following to my.cnf:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-If you are using a cloud service, refer to the corresponding prerequisites
guide.
+3. Binlog must be enabled on the MySQL side. See the [Setup
Guide](./continuous-load-overview.md).
## Quick Start
@@ -45,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -69,7 +57,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | Data source type, set to `mysql`
|
| jdbc_url | - | MySQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git a/docs/data-operate/import/streaming-job/continuous-load-overview.md
b/docs/data-operate/import/streaming-job/continuous-load-overview.md
index f5a5550bdb0..6bdfaf22d30 100644
--- a/docs/data-operate/import/streaming-job/continuous-load-overview.md
+++ b/docs/data-operate/import/streaming-job/continuous-load-overview.md
@@ -12,11 +12,11 @@ Doris supports continuously loading data from multiple data
sources into Doris t
Continuous Load supports the following data sources and import modes:
-| Data Source | Single-table Import | Multi-table Import | Prerequisites |
-|:------|:--------|:--------|:--------|
-| MySQL | [MySQL Single-table](./continuous-load-mysql-single.md) | [MySQL
Multi-table](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
-| PostgreSQL | [PostgreSQL
Single-table](./continuous-load-postgresql-single.md) | [PostgreSQL
Multi-table](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
-| S3 | [S3 Continuous Load](./continuous-load-s3.md) | - | - |
+| Data Source | Supported Versions | Single-table Import | Multi-table Import
| Setup Guide |
+|:------|:--------|:--------|:--------|:--------|
+| MySQL | 5.6, 5.7, 8.0.x | [MySQL
Single-table](./continuous-load-mysql-single.md) | [MySQL
Multi-table](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
+| PostgreSQL | 14, 15, 16, 17 | [PostgreSQL
Single-table](./continuous-load-postgresql-single.md) | [PostgreSQL
Multi-table](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
+| S3 | - | [S3 Continuous Load](./continuous-load-s3.md) | - | - |
:::tip
- **Single-table Import**: Uses CDC Stream TVF or S3 TVF to continuously load
data into a specific Doris table, supporting flexible column mapping and data
transformation.
@@ -106,3 +106,22 @@ DROP JOB WHERE jobName = <job_name>;
| Parameter | Default | Description |
| ------------ | ------- | ---------------------------------------------- |
| max_interval | 10s | Idle scheduling interval when no new data |
+
+## FAQ
+
+### MySQL connection error: Public Key Retrieval is not allowed
+
+**Cause:** The MySQL user uses SHA256 password authentication, which requires
TLS or other protocols to transmit the password.
+
+**Solution 1:** Add `allowPublicKeyRetrieval=true` to the JDBC URL:
+
+```
+jdbc:mysql://127.0.0.1:3306?allowPublicKeyRetrieval=true
+```
+
+**Solution 2:** Change the MySQL user's authentication method to
`mysql_native_password`:
+
+```sql
+ALTER USER 'username'@'%' IDENTIFIED WITH mysql_native_password BY 'password';
+FLUSH PRIVILEGES;
+```
diff --git
a/docs/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
b/docs/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
index 92ee5d38f43..83355b10e03 100644
--- a/docs/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
+++ b/docs/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
@@ -19,16 +19,6 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc), Doris supports
3. LOAD privilege is required. If the downstream table does not exist, CREATE
privilege is also required.
4. During automatic table creation, if the target table already exists, it
will be skipped, and users can customize tables according to different
scenarios.
-## Prerequisites
-
-Enable logical replication on PostgreSQL by adding the following to
postgresql.conf:
-
-```ini
-wal_level=logical
-```
-
-If you are using a cloud service, see the [Setup
Guide](./continuous-load-overview.md).
-
## Quick Start
### Creating an Import Job
@@ -40,7 +30,7 @@ CREATE JOB test_postgres_job
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -67,7 +57,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| Parameter | Default | Description
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | PostgreSQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/docs/data-operate/import/streaming-job/continuous-load-postgresql-single.md
b/docs/data-operate/import/streaming-job/continuous-load-postgresql-single.md
index 9bde12b44a4..0e6e14f3bab 100644
---
a/docs/data-operate/import/streaming-job/continuous-load-postgresql-single.md
+++
b/docs/data-operate/import/streaming-job/continuous-load-postgresql-single.md
@@ -17,17 +17,7 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc) reading capabili
1. Supports exactly-once semantics.
2. Currently only primary key tables are supported for synchronization.
3. LOAD privilege is required.
-3. Logical replication must be enabled on the PostgreSQL side. If you are
using a cloud service, see the [Setup Guide](./continuous-load-overview.md).
-
-## Prerequisites
-
-Enable logical replication on PostgreSQL by adding the following to
postgresql.conf:
-
-```ini
-wal_level=logical
-```
-
-If you are using a cloud service, refer to the corresponding prerequisites
guide.
+3. Logical replication must be enabled on the PostgreSQL side. See the [Setup
Guide](./continuous-load-overview.md).
## Quick Start
@@ -43,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -68,7 +58,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | Data source type, set to `postgres`
|
| jdbc_url | - | PostgreSQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
b/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
index 9d7cf60ed20..0f0e65e9294 100644
---
a/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
+++
b/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon Aurora
MySQL, you need to ensure that the Aurora cluster has Binlog enabled and
properly configured. This guide walks you through all prerequisite
configuration steps.
+Doris continuous load supports Amazon Aurora MySQL 5.6, 5.7, and 8.0.x. Before
synchronizing data, you need to ensure that the Aurora cluster has Binlog
enabled and properly configured. This guide walks you through all prerequisite
configuration steps.
## Step 1: Check Current Configuration
diff --git
a/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
b/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
index 6773b56861a..230cc7e4d58 100644
---
a/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
+++
b/docs/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon Aurora
PostgreSQL, you need to ensure that the Aurora cluster has logical replication
enabled. This guide walks you through all prerequisite configuration steps.
+Doris continuous load supports Amazon Aurora PostgreSQL-Compatible Edition 14
and above. Before synchronizing data, you need to ensure that the Aurora
cluster has logical replication enabled. This guide walks you through all
prerequisite configuration steps.
## Step 1: Check Current Configuration
diff --git
a/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
b/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
index 81045552f09..94c87f2d814 100644
--- a/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
+++ b/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon RDS MySQL,
you need to ensure that the RDS instance has Binlog enabled and properly
configured. This guide walks you through all prerequisite configuration steps.
+Doris continuous load supports Amazon RDS MySQL 5.6, 5.7, and 8.0.x. Before
synchronizing data, you need to ensure that the RDS instance has Binlog enabled
and properly configured. This guide walks you through all prerequisite
configuration steps.
## Step 1: Check Current Configuration
diff --git
a/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
b/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
index d8c0b85a645..de60483ea86 100644
---
a/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
+++
b/docs/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon RDS
PostgreSQL, you need to ensure that the RDS instance has logical replication
enabled. This guide walks you through all prerequisite configuration steps.
+Doris continuous load supports Amazon RDS PostgreSQL 14 and above. Before
synchronizing data, you need to ensure that the RDS instance has logical
replication enabled. This guide walks you through all prerequisite
configuration steps.
## Step 1: Check Current Configuration
diff --git a/docs/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
b/docs/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
index 4197015cfc1..687281d0a6a 100644
--- a/docs/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
+++ b/docs/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
@@ -72,7 +72,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -92,7 +92,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -113,7 +113,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -134,7 +134,7 @@ cdc_stream(
FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
diff --git a/docs/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
b/docs/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
index 5211b2c634d..eaf91dd3f15 100644
--- a/docs/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
+++ b/docs/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
@@ -148,7 +148,7 @@ The user executing this SQL command must have at least the
following privileges:
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -167,7 +167,7 @@ The user executing this SQL command must have at least the
following privileges:
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -186,7 +186,7 @@ The user executing this SQL command must have at least the
following privileges:
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -206,7 +206,7 @@ The user executing this SQL command must have at least the
following privileges:
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-multi.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-multi.md
index 42f7478c724..3f54ca4c068 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-multi.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-multi.md
@@ -19,18 +19,6 @@
3. 需要 Load 权限,若下游表不存在还需有 Create 权限。
4. 自动创建表阶段,如果目标表已存在则会跳过,用户可以根据不同的场景自定义表。
-## 前提条件
-
-需要在 MySQL 端开启 Binlog,即 my.cnf 配置文件中增加:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-如果您使用的是云服务,请参考[配置指南](./continuous-load-overview.md)。
-
## 快速上手
### 创建导入作业
@@ -42,7 +30,7 @@ CREATE JOB multi_table_sync
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -65,7 +53,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING"
ExecuteType: STREAMING
RecurringStrategy: \N
Status: RUNNING
- ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-j-8.0.31.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
+ ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-java-8.0.25.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
CreateTime: 2025-12-10 10:19:35
SucceedTaskCount: 1
FailedTaskCount: 0
@@ -96,7 +84,7 @@ TO DATABASE target_test_db
| 参数 | 默认值 | 说明
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | MySQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-single.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-single.md
index fefdedaafef..7695e87e75a 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-single.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-mysql-single.md
@@ -17,19 +17,7 @@ Doris 支持通过 Job + [CDC Stream
TVF](../../../sql-manual/sql-functions/tabl
1. 支持 exactly-once 语义。
2. 目前只支持主键表同步。
3. 需要 Load 权限。
-3. 需要在 MySQL 端开启 Binlog,如果使用云服务,请参考[配置指南](./continuous-load-overview.md)。
-
-## 前提条件
-
-需要在 MySQL 端开启 Binlog,即 my.cnf 配置文件中增加:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-如果您使用的是云服务,请参考对应的配置指南。
+3. 需要在 MySQL 端开启 Binlog,请参考[配置指南](./continuous-load-overview.md)。
## 快速上手
@@ -45,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -69,7 +57,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING";
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | 数据源类型,填写 `mysql`
|
| jdbc_url | - | MySQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-overview.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-overview.md
index 888a7635b9d..42ec988d735 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-overview.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-overview.md
@@ -12,11 +12,11 @@ Doris 支持通过 Streaming Job 的方式,从多种数据源持续导入数
持续导入支持以下数据源和导入模式:
-| 数据源 | 单表导入 | 多表导入 | 配置指南 |
-|:------|:--------|:--------|:--------|
-| MySQL | [MySQL 单表导入](./continuous-load-mysql-single.md) | [MySQL
多表导入](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
-| PostgreSQL | [PostgreSQL 单表导入](./continuous-load-postgresql-single.md) |
[PostgreSQL 多表导入](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
-| S3 | [S3 持续导入](./continuous-load-s3.md) | - | - |
+| 数据源 | 支持版本 | 单表导入 | 多表导入 | 配置指南 |
+|:------|:--------|:--------|:--------|:--------|
+| MySQL | 5.6、5.7、8.0.x | [MySQL 单表导入](./continuous-load-mysql-single.md) |
[MySQL 多表导入](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
+| PostgreSQL | 14、15、16、17 | [PostgreSQL
单表导入](./continuous-load-postgresql-single.md) | [PostgreSQL
多表导入](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
+| S3 | - | [S3 持续导入](./continuous-load-s3.md) | - | - |
:::tip
- **单表导入**:通过 CDC Stream TVF 或 S3 TVF,将数据持续导入到指定的单张 Doris 表中,支持灵活的列映射和数据转换。
@@ -106,3 +106,22 @@ DROP JOB WHERE jobName = <job_name>;
| 参数 | 默认值 | 说明 |
| ------------ | ------ | -------------------------------------- |
| max_interval | 10s | 当上游没有新增数据时,空闲的调度间隔。 |
+
+## FAQ
+
+### MySQL 连接报错 Public Key Retrieval is not allowed
+
+**原因:** 配置的 MySQL 用户使用 SHA256 密码认证方式,需要通过 TLS 等协议传输密码。
+
+**解决方案一:** 在 JDBC URL 中添加 `allowPublicKeyRetrieval=true` 参数:
+
+```
+jdbc:mysql://127.0.0.1:3306?allowPublicKeyRetrieval=true
+```
+
+**解决方案二:** 将 MySQL 用户的认证方式改为 `mysql_native_password`:
+
+```sql
+ALTER USER 'username'@'%' IDENTIFIED WITH mysql_native_password BY 'password';
+FLUSH PRIVILEGES;
+```
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
index c2fb92417d7..231dda0bee6 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
@@ -19,16 +19,6 @@
3. 需要 Load 权限,若下游表不存在还需有 Create 权限。
4. 自动创建表阶段,如果目标表已存在则会跳过,用户可以根据不同的场景自定义表。
-## 前提条件
-
-需要在 PostgreSQL 端配置逻辑复制,即 postgresql.conf 增加:
-
-```ini
-wal_level=logical
-```
-
-如果您使用的是云服务,请参考[配置指南](./continuous-load-overview.md)。
-
## 快速上手
### 创建导入作业
@@ -40,7 +30,7 @@ CREATE JOB test_postgres_job
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -67,7 +57,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING";
| 参数 | 默认值 | 说明
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | PostgreSQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-single.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-single.md
index 9bb6cfa2c97..8890406ed3e 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-single.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/continuous-load-postgresql-single.md
@@ -17,17 +17,7 @@ Doris 支持通过 Job + [CDC Stream
TVF](../../../sql-manual/sql-functions/tabl
1. 支持 exactly-once 语义。
2. 目前只支持主键表同步。
3. 需要 Load 权限。
-3. 需要在 PostgreSQL 端开启逻辑复制,如果使用云服务,请参考[配置指南](./continuous-load-overview.md)。
-
-## 前提条件
-
-需要在 PostgreSQL 端配置逻辑复制,即 postgresql.conf 增加:
-
-```ini
-wal_level=logical
-```
-
-如果您使用的是云服务,请参考对应的配置指南。
+3. 需要在 PostgreSQL 端开启逻辑复制,请参考[配置指南](./continuous-load-overview.md)。
## 快速上手
@@ -43,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -68,7 +58,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING";
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | 数据源类型,填写 `postgres`
|
| jdbc_url | - | PostgreSQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
index 49d671f27a1..a2b931f313a 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon Aurora MySQL 同步数据之前,需要确保 Aurora 集群已开启 Binlog
并正确配置。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon Aurora MySQL-Compatible Edition 5.6、5.7、8.0.x
版本。在同步数据之前,需要确保 Aurora 集群已开启 Binlog 并正确配置。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
index 1edfb357633..34b76db06f9 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon Aurora PostgreSQL 同步数据之前,需要确保 Aurora
集群已开启逻辑复制(Logical Replication)。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon Aurora PostgreSQL-Compatible Edition 14 及以上版本。在同步数据之前,需要确保
Aurora 集群已开启逻辑复制(Logical Replication)。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
index 3329d8f4124..4d87d05202b 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon RDS MySQL 同步数据之前,需要确保 RDS 实例已开启 Binlog
并正确配置。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon RDS MySQL 5.6、5.7、8.0.x 版本。在同步数据之前,需要确保 RDS 实例已开启 Binlog
并正确配置。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
index 745f2f5ac3b..37de2194759 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon RDS PostgreSQL 同步数据之前,需要确保 RDS 实例已开启逻辑复制(Logical
Replication)。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon RDS PostgreSQL 14 及以上版本。在同步数据之前,需要确保 RDS 实例已开启逻辑复制(Logical
Replication)。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
index 94e1bd678d4..9f9638cbc27 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
@@ -74,7 +74,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -93,7 +93,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -114,7 +114,7 @@ cdc_stream(
FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
index 9c03d8d22df..6f7927089c5 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
@@ -172,7 +172,7 @@ SELECT * FROM S3(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -191,7 +191,7 @@ SELECT * FROM S3(
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -210,7 +210,7 @@ SELECT * FROM S3(
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -230,7 +230,7 @@ SELECT * FROM S3(
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
index 42f7478c724..3f54ca4c068 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
@@ -19,18 +19,6 @@
3. 需要 Load 权限,若下游表不存在还需有 Create 权限。
4. 自动创建表阶段,如果目标表已存在则会跳过,用户可以根据不同的场景自定义表。
-## 前提条件
-
-需要在 MySQL 端开启 Binlog,即 my.cnf 配置文件中增加:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-如果您使用的是云服务,请参考[配置指南](./continuous-load-overview.md)。
-
## 快速上手
### 创建导入作业
@@ -42,7 +30,7 @@ CREATE JOB multi_table_sync
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -65,7 +53,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING"
ExecuteType: STREAMING
RecurringStrategy: \N
Status: RUNNING
- ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-j-8.0.31.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
+ ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-java-8.0.25.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
CreateTime: 2025-12-10 10:19:35
SucceedTaskCount: 1
FailedTaskCount: 0
@@ -96,7 +84,7 @@ TO DATABASE target_test_db
| 参数 | 默认值 | 说明
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | MySQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
index fefdedaafef..7695e87e75a 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
@@ -17,19 +17,7 @@ Doris 支持通过 Job + [CDC Stream
TVF](../../../sql-manual/sql-functions/tabl
1. 支持 exactly-once 语义。
2. 目前只支持主键表同步。
3. 需要 Load 权限。
-3. 需要在 MySQL 端开启 Binlog,如果使用云服务,请参考[配置指南](./continuous-load-overview.md)。
-
-## 前提条件
-
-需要在 MySQL 端开启 Binlog,即 my.cnf 配置文件中增加:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-如果您使用的是云服务,请参考对应的配置指南。
+3. 需要在 MySQL 端开启 Binlog,请参考[配置指南](./continuous-load-overview.md)。
## 快速上手
@@ -45,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -69,7 +57,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING";
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | 数据源类型,填写 `mysql`
|
| jdbc_url | - | MySQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
index 888a7635b9d..42ec988d735 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
@@ -12,11 +12,11 @@ Doris 支持通过 Streaming Job 的方式,从多种数据源持续导入数
持续导入支持以下数据源和导入模式:
-| 数据源 | 单表导入 | 多表导入 | 配置指南 |
-|:------|:--------|:--------|:--------|
-| MySQL | [MySQL 单表导入](./continuous-load-mysql-single.md) | [MySQL
多表导入](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
-| PostgreSQL | [PostgreSQL 单表导入](./continuous-load-postgresql-single.md) |
[PostgreSQL 多表导入](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
-| S3 | [S3 持续导入](./continuous-load-s3.md) | - | - |
+| 数据源 | 支持版本 | 单表导入 | 多表导入 | 配置指南 |
+|:------|:--------|:--------|:--------|:--------|
+| MySQL | 5.6、5.7、8.0.x | [MySQL 单表导入](./continuous-load-mysql-single.md) |
[MySQL 多表导入](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
+| PostgreSQL | 14、15、16、17 | [PostgreSQL
单表导入](./continuous-load-postgresql-single.md) | [PostgreSQL
多表导入](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
+| S3 | - | [S3 持续导入](./continuous-load-s3.md) | - | - |
:::tip
- **单表导入**:通过 CDC Stream TVF 或 S3 TVF,将数据持续导入到指定的单张 Doris 表中,支持灵活的列映射和数据转换。
@@ -106,3 +106,22 @@ DROP JOB WHERE jobName = <job_name>;
| 参数 | 默认值 | 说明 |
| ------------ | ------ | -------------------------------------- |
| max_interval | 10s | 当上游没有新增数据时,空闲的调度间隔。 |
+
+## FAQ
+
+### MySQL 连接报错 Public Key Retrieval is not allowed
+
+**原因:** 配置的 MySQL 用户使用 SHA256 密码认证方式,需要通过 TLS 等协议传输密码。
+
+**解决方案一:** 在 JDBC URL 中添加 `allowPublicKeyRetrieval=true` 参数:
+
+```
+jdbc:mysql://127.0.0.1:3306?allowPublicKeyRetrieval=true
+```
+
+**解决方案二:** 将 MySQL 用户的认证方式改为 `mysql_native_password`:
+
+```sql
+ALTER USER 'username'@'%' IDENTIFIED WITH mysql_native_password BY 'password';
+FLUSH PRIVILEGES;
+```
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
index c2fb92417d7..231dda0bee6 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
@@ -19,16 +19,6 @@
3. 需要 Load 权限,若下游表不存在还需有 Create 权限。
4. 自动创建表阶段,如果目标表已存在则会跳过,用户可以根据不同的场景自定义表。
-## 前提条件
-
-需要在 PostgreSQL 端配置逻辑复制,即 postgresql.conf 增加:
-
-```ini
-wal_level=logical
-```
-
-如果您使用的是云服务,请参考[配置指南](./continuous-load-overview.md)。
-
## 快速上手
### 创建导入作业
@@ -40,7 +30,7 @@ CREATE JOB test_postgres_job
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -67,7 +57,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING";
| 参数 | 默认值 | 说明
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | PostgreSQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
index 9bb6cfa2c97..8890406ed3e 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
@@ -17,17 +17,7 @@ Doris 支持通过 Job + [CDC Stream
TVF](../../../sql-manual/sql-functions/tabl
1. 支持 exactly-once 语义。
2. 目前只支持主键表同步。
3. 需要 Load 权限。
-3. 需要在 PostgreSQL 端开启逻辑复制,如果使用云服务,请参考[配置指南](./continuous-load-overview.md)。
-
-## 前提条件
-
-需要在 PostgreSQL 端配置逻辑复制,即 postgresql.conf 增加:
-
-```ini
-wal_level=logical
-```
-
-如果您使用的是云服务,请参考对应的配置指南。
+3. 需要在 PostgreSQL 端开启逻辑复制,请参考[配置指南](./continuous-load-overview.md)。
## 快速上手
@@ -43,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -68,7 +58,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING";
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | 数据源类型,填写 `postgres`
|
| jdbc_url | - | PostgreSQL JDBC 连接串
|
-| driver_url | - | JDBC 驱动 jar 包路径
|
+| driver_url | - | JDBC 驱动 jar 包路径,支持文件名、本地绝对路径和 HTTP 地址三种方式,详见
[JDBC Catalog 概述](../../../lakehouse/catalogs/jdbc-catalog-overview.md) |
| driver_class | - | JDBC 驱动类名
|
| user | - | 数据库用户名
|
| password | - | 数据库密码
|
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
index 49d671f27a1..a2b931f313a 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon Aurora MySQL 同步数据之前,需要确保 Aurora 集群已开启 Binlog
并正确配置。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon Aurora MySQL-Compatible Edition 5.6、5.7、8.0.x
版本。在同步数据之前,需要确保 Aurora 集群已开启 Binlog 并正确配置。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
index 1edfb357633..34b76db06f9 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon Aurora PostgreSQL 同步数据之前,需要确保 Aurora
集群已开启逻辑复制(Logical Replication)。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon Aurora PostgreSQL-Compatible Edition 14 及以上版本。在同步数据之前,需要确保
Aurora 集群已开启逻辑复制(Logical Replication)。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
index 3329d8f4124..4d87d05202b 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon RDS MySQL 同步数据之前,需要确保 RDS 实例已开启 Binlog
并正确配置。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon RDS MySQL 5.6、5.7、8.0.x 版本。在同步数据之前,需要确保 RDS 实例已开启 Binlog
并正确配置。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
index 745f2f5ac3b..37de2194759 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
@@ -8,7 +8,7 @@
## 概述
-在使用 Doris 持续导入功能从 Amazon RDS PostgreSQL 同步数据之前,需要确保 RDS 实例已开启逻辑复制(Logical
Replication)。本文档将指导您完成所有前置配置步骤。
+Doris 持续导入支持 Amazon RDS PostgreSQL 14 及以上版本。在同步数据之前,需要确保 RDS 实例已开启逻辑复制(Logical
Replication)。本文档将指导您完成所有前置配置步骤。
## 步骤一:检查当前配置
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
index 94e1bd678d4..9f9638cbc27 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
@@ -74,7 +74,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -93,7 +93,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -114,7 +114,7 @@ cdc_stream(
FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
index 9c03d8d22df..6f7927089c5 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
@@ -172,7 +172,7 @@ SELECT * FROM S3(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -191,7 +191,7 @@ SELECT * FROM S3(
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -210,7 +210,7 @@ SELECT * FROM S3(
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -230,7 +230,7 @@ SELECT * FROM S3(
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
index 9c3d8e98a72..d8d6d231760 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-multi.md
@@ -19,18 +19,6 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc), Doris supports
3. LOAD privilege is required. If the downstream table does not exist, CREATE
privilege is also required.
4. During automatic table creation, if the target table already exists, it
will be skipped, and users can customize tables according to different
scenarios.
-## Prerequisites
-
-Enable Binlog on MySQL by adding the following to my.cnf:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-If you are using a cloud service, see the [Setup
Guide](./continuous-load-overview.md).
-
## Quick Start
### Creating an Import Job
@@ -42,7 +30,7 @@ CREATE JOB multi_table_sync
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -65,7 +53,7 @@ select * from jobs("type"="insert") where ExecuteType =
"STREAMING"
ExecuteType: STREAMING
RecurringStrategy: \N
Status: RUNNING
- ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-j-8.0.31.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
+ ExecuteSql: FROM
MYSQL('include_tables'='user_info','database'='test','driver_class'='com.mysql.cj.jdbc.Driver','driver_url'='mysql-connector-java-8.0.25.jar','offset'='initial','jdbc_url'='jdbc:mysql://127.0.0.1:3306','user'='root'
) TO DATABASE target_test_db ('table.create.properties.replication_num'='1')
CreateTime: 2025-12-10 10:19:35
SucceedTaskCount: 1
FailedTaskCount: 0
@@ -96,7 +84,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| Parameter | Default | Description
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | MySQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
index 6be8aa1da41..a2fd7bfc674 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-mysql-single.md
@@ -17,19 +17,7 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc) reading capabili
1. Supports exactly-once semantics.
2. Currently only primary key tables are supported for synchronization.
3. LOAD privilege is required.
-3. Binlog must be enabled on the MySQL side. If you are using a cloud service,
see the [Setup Guide](./continuous-load-overview.md).
-
-## Prerequisites
-
-Enable Binlog on MySQL by adding the following to my.cnf:
-
-```ini
-log-bin=mysql-bin
-binlog_format=ROW
-server-id=1
-```
-
-If you are using a cloud service, refer to the corresponding prerequisites
guide.
+3. Binlog must be enabled on the MySQL side. See the [Setup
Guide](./continuous-load-overview.md).
## Quick Start
@@ -45,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -69,7 +57,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | Data source type, set to `mysql`
|
| jdbc_url | - | MySQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
index f5a5550bdb0..6bdfaf22d30 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-overview.md
@@ -12,11 +12,11 @@ Doris supports continuously loading data from multiple data
sources into Doris t
Continuous Load supports the following data sources and import modes:
-| Data Source | Single-table Import | Multi-table Import | Prerequisites |
-|:------|:--------|:--------|:--------|
-| MySQL | [MySQL Single-table](./continuous-load-mysql-single.md) | [MySQL
Multi-table](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
-| PostgreSQL | [PostgreSQL
Single-table](./continuous-load-postgresql-single.md) | [PostgreSQL
Multi-table](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
-| S3 | [S3 Continuous Load](./continuous-load-s3.md) | - | - |
+| Data Source | Supported Versions | Single-table Import | Multi-table Import
| Setup Guide |
+|:------|:--------|:--------|:--------|:--------|
+| MySQL | 5.6, 5.7, 8.0.x | [MySQL
Single-table](./continuous-load-mysql-single.md) | [MySQL
Multi-table](./continuous-load-mysql-multi.md) | [Amazon RDS
MySQL](./prerequisites/amazon-rds-mysql.md) · [Amazon Aurora
MySQL](./prerequisites/amazon-aurora-mysql.md) |
+| PostgreSQL | 14, 15, 16, 17 | [PostgreSQL
Single-table](./continuous-load-postgresql-single.md) | [PostgreSQL
Multi-table](./continuous-load-postgresql-multi.md) | [Amazon RDS
PostgreSQL](./prerequisites/amazon-rds-postgresql.md) · [Amazon Aurora
PostgreSQL](./prerequisites/amazon-aurora-postgresql.md) |
+| S3 | - | [S3 Continuous Load](./continuous-load-s3.md) | - | - |
:::tip
- **Single-table Import**: Uses CDC Stream TVF or S3 TVF to continuously load
data into a specific Doris table, supporting flexible column mapping and data
transformation.
@@ -106,3 +106,22 @@ DROP JOB WHERE jobName = <job_name>;
| Parameter | Default | Description |
| ------------ | ------- | ---------------------------------------------- |
| max_interval | 10s | Idle scheduling interval when no new data |
+
+## FAQ
+
+### MySQL connection error: Public Key Retrieval is not allowed
+
+**Cause:** The MySQL user uses SHA256 password authentication, which requires
TLS or other protocols to transmit the password.
+
+**Solution 1:** Add `allowPublicKeyRetrieval=true` to the JDBC URL:
+
+```
+jdbc:mysql://127.0.0.1:3306?allowPublicKeyRetrieval=true
+```
+
+**Solution 2:** Change the MySQL user's authentication method to
`mysql_native_password`:
+
+```sql
+ALTER USER 'username'@'%' IDENTIFIED WITH mysql_native_password BY 'password';
+FLUSH PRIVILEGES;
+```
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
index 92ee5d38f43..83355b10e03 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-multi.md
@@ -19,16 +19,6 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc), Doris supports
3. LOAD privilege is required. If the downstream table does not exist, CREATE
privilege is also required.
4. During automatic table creation, if the target table already exists, it
will be skipped, and users can customize tables according to different
scenarios.
-## Prerequisites
-
-Enable logical replication on PostgreSQL by adding the following to
postgresql.conf:
-
-```ini
-wal_level=logical
-```
-
-If you are using a cloud service, see the [Setup
Guide](./continuous-load-overview.md).
-
## Quick Start
### Creating an Import Job
@@ -40,7 +30,7 @@ CREATE JOB test_postgres_job
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -67,7 +57,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| Parameter | Default | Description
|
| -------------- | ------- |
------------------------------------------------------------ |
| jdbc_url | - | PostgreSQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
index 9bde12b44a4..0e6e14f3bab 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/continuous-load-postgresql-single.md
@@ -17,17 +17,7 @@ By integrating [Flink
CDC](https://github.com/apache/flink-cdc) reading capabili
1. Supports exactly-once semantics.
2. Currently only primary key tables are supported for synchronization.
3. LOAD privilege is required.
-3. Logical replication must be enabled on the PostgreSQL side. If you are
using a cloud service, see the [Setup Guide](./continuous-load-overview.md).
-
-## Prerequisites
-
-Enable logical replication on PostgreSQL by adding the following to
postgresql.conf:
-
-```ini
-wal_level=logical
-```
-
-If you are using a cloud service, refer to the corresponding prerequisites
guide.
+3. Logical replication must be enabled on the PostgreSQL side. See the [Setup
Guide](./continuous-load-overview.md).
## Quick Start
@@ -43,7 +33,7 @@ INSERT INTO db1.tbl1
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -68,7 +58,7 @@ For more common operations (pause, resume, delete, check
Task, etc.), see [Conti
| -------------- | ------- |
------------------------------------------------------------ |
| type | - | Data source type, set to `postgres`
|
| jdbc_url | - | PostgreSQL JDBC connection string
|
-| driver_url | - | JDBC driver jar path
|
+| driver_url | - | JDBC driver jar path. Supports file name, local
absolute path, and HTTP URL. See [JDBC Catalog
Overview](../../../lakehouse/catalogs/jdbc-catalog-overview.md) for details. |
| driver_class | - | JDBC driver class name
|
| user | - | Database username
|
| password | - | Database password
|
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
index 9d7cf60ed20..0f0e65e9294 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-mysql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon Aurora
MySQL, you need to ensure that the Aurora cluster has Binlog enabled and
properly configured. This guide walks you through all prerequisite
configuration steps.
+Doris continuous load supports Amazon Aurora MySQL 5.6, 5.7, and 8.0.x. Before
synchronizing data, you need to ensure that the Aurora cluster has Binlog
enabled and properly configured. This guide walks you through all prerequisite
configuration steps.
## Step 1: Check Current Configuration
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
index 6773b56861a..230cc7e4d58 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-aurora-postgresql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon Aurora
PostgreSQL, you need to ensure that the Aurora cluster has logical replication
enabled. This guide walks you through all prerequisite configuration steps.
+Doris continuous load supports Amazon Aurora PostgreSQL-Compatible Edition 14
and above. Before synchronizing data, you need to ensure that the Aurora
cluster has logical replication enabled. This guide walks you through all
prerequisite configuration steps.
## Step 1: Check Current Configuration
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
index 81045552f09..94c87f2d814 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-mysql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon RDS MySQL,
you need to ensure that the RDS instance has Binlog enabled and properly
configured. This guide walks you through all prerequisite configuration steps.
+Doris continuous load supports Amazon RDS MySQL 5.6, 5.7, and 8.0.x. Before
synchronizing data, you need to ensure that the RDS instance has Binlog enabled
and properly configured. This guide walks you through all prerequisite
configuration steps.
## Step 1: Check Current Configuration
diff --git
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
index d8c0b85a645..de60483ea86 100644
---
a/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
+++
b/versioned_docs/version-4.x/data-operate/import/streaming-job/prerequisites/amazon-rds-postgresql.md
@@ -8,7 +8,7 @@
## Overview
-Before using Doris continuous load to synchronize data from Amazon RDS
PostgreSQL, you need to ensure that the RDS instance has logical replication
enabled. This guide walks you through all prerequisite configuration steps.
+Doris continuous load supports Amazon RDS PostgreSQL 14 and above. Before
synchronizing data, you need to ensure that the RDS instance has logical
replication enabled. This guide walks you through all prerequisite
configuration steps.
## Step 1: Check Current Configuration
diff --git
a/versioned_docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
b/versioned_docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
index 4197015cfc1..687281d0a6a 100644
---
a/versioned_docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
+++
b/versioned_docs/version-4.x/sql-manual/sql-functions/table-valued-functions/cdc-stream.md
@@ -72,7 +72,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -92,7 +92,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -113,7 +113,7 @@ cdc_stream(
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -134,7 +134,7 @@ cdc_stream(
FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
diff --git
a/versioned_docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
b/versioned_docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
index 5211b2c634d..eaf91dd3f15 100644
---
a/versioned_docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
+++
b/versioned_docs/version-4.x/sql-manual/sql-statements/job/CREATE-STREAMING-JOB.md
@@ -148,7 +148,7 @@ The user executing this SQL command must have at least the
following privileges:
SELECT * FROM cdc_stream(
"type" = "mysql",
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -167,7 +167,7 @@ The user executing this SQL command must have at least the
following privileges:
SELECT * FROM cdc_stream(
"type" = "postgres",
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
@@ -186,7 +186,7 @@ The user executing this SQL command must have at least the
following privileges:
ON STREAMING
FROM MYSQL (
"jdbc_url" = "jdbc:mysql://127.0.0.1:3306",
- "driver_url" = "mysql-connector-j-8.0.31.jar",
+ "driver_url" = "mysql-connector-java-8.0.25.jar",
"driver_class" = "com.mysql.cj.jdbc.Driver",
"user" = "root",
"password" = "123456",
@@ -206,7 +206,7 @@ The user executing this SQL command must have at least the
following privileges:
ON STREAMING
FROM POSTGRES (
"jdbc_url" = "jdbc:postgresql://127.0.0.1:5432/postgres",
- "driver_url" = "postgresql-42.5.0.jar",
+ "driver_url" = "postgresql-42.5.1.jar",
"driver_class" = "org.postgresql.Driver",
"user" = "postgres",
"password" = "postgres",
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]