This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new b569d6499 FLINK-39288 [docs] Update pipeline connectors overview with
Flink version specific jar names (#4345)
b569d6499 is described below
commit b569d64995fbdaf6c053ed42c72118e2345f2d06
Author: Kunni <[email protected]>
AuthorDate: Fri Mar 27 14:12:10 2026 +0800
FLINK-39288 [docs] Update pipeline connectors overview with Flink version
specific jar names (#4345)
---
.../docs/connectors/flink-sources/overview.md | 22 +++++-----
.../docs/connectors/pipeline-connectors/oracle.md | 2 +-
.../connectors/pipeline-connectors/overview.md | 26 ++++++------
docs/content.zh/docs/get-started/introduction.md | 45 ++++++++++++++++++++-
.../{quickstart => quickstart-for-1.20}/_index.md | 2 +-
.../cdc-up-quickstart-guide.md | 0
.../mysql-to-doris.md | 2 -
.../mysql-to-kafka.md | 4 +-
.../mysql-to-starrocks.md | 2 -
.../postgres-to-fluss.md | 2 -
.../{quickstart => quickstart-for-2.2}/_index.md | 2 +-
.../mysql-to-doris.md | 20 ++++-----
.../mysql-to-kafka.md | 20 ++++-----
.../mysql-to-starrocks.md | 16 ++++----
.../postgres-to-fluss.md | 14 +++----
.../docs/connectors/flink-sources/overview.md | 22 +++++-----
.../docs/connectors/pipeline-connectors/oracle.md | 2 +-
.../connectors/pipeline-connectors/overview.md | 26 ++++++------
docs/content/docs/get-started/introduction.md | 45 ++++++++++++++++++++-
.../{quickstart => quickstart-for-1.20}/_index.md | 2 +-
.../cdc-up-quickstart-guide.md | 0
.../mysql-to-doris.md | 2 -
.../mysql-to-kafka.md | 4 +-
.../mysql-to-starrocks.md | 2 -
.../postgres-to-fluss.md | 2 -
.../docs/get-started/quickstart-for-2.2}/_index.md | 2 +-
.../mysql-to-doris.md | 26 ++++++------
.../mysql-to-kafka.md | 22 +++++-----
.../mysql-to-starrocks.md | 22 +++++-----
.../postgres-to-fluss.md | 16 ++++----
.../fig/mysql-Kafka-tutorial/flink-ui-flink22.png | Bin 0 -> 1556874 bytes
.../mysql-to-Kafka-flink22.png | Bin 0 -> 1473786 bytes
.../fig/mysql-doris-tutorial/flink-ui-flink22.png | Bin 0 -> 1556874 bytes
.../mysql-to-doris-flink22.png | Bin 0 -> 1473287 bytes
.../mysql-starrocks-tutorial/flink-ui-flink22.png | Bin 0 -> 1556874 bytes
.../mysql-to-starrocks-flink22.png | Bin 0 -> 1574092 bytes
36 files changed, 220 insertions(+), 154 deletions(-)
diff --git a/docs/content.zh/docs/connectors/flink-sources/overview.md
b/docs/content.zh/docs/connectors/flink-sources/overview.md
index c88f3470c..e9a783b74 100644
--- a/docs/content.zh/docs/connectors/flink-sources/overview.md
+++ b/docs/content.zh/docs/connectors/flink-sources/overview.md
@@ -35,17 +35,17 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/b
## Supported Connectors
-| Connector |
Database
|
Driver [...]
-|----------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|--------------------
[...]
-| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.1 [...]
-| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
<li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <li> [RDS
MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x <li> [PolarDB
MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x <li> [Aurora
MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x <li>
[MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 [...]
-| [oceanbase-cdc]({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) |
<li> [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x <li> [OceanBase
EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x
|
OceanBase Driver: 2 [...]
-| [oracle-cdc]({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) |
<li> [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21
|
Oracle Driver: 19.3 [...]
-| [postgres-cdc]({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) |
<li> [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14
| JDBC
Driver: 42.5.1 [...]
-| [sqlserver-cdc]({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) |
<li> [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017,
2019
| JDBC
Driver: 9.4.1. [...]
-| [tidb-cdc]({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) |
<li> [TiDB](https://www.pingcap.com/): 5.1.x, 5.2.x, 5.3.x, 5.4.x, 6.0.0
| JDBC
Driver: 8.0.27 [...]
-| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
<li> [Db2](https://www.ibm.com/products/db2): 11.5
| Db2
Driver: 11.5.0. [...]
-| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
<li> [Vitess](https://vitess.io/): 8.0.x, 9.0.x
| MySql
JDBC Driver: [...]
+| Connector |
Database
|
Driver [...]
+|----------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|--------------------
[...]
+| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.1 [...]
+| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
<li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <li> [RDS
MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x <li> [PolarDB
MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x <li> [Aurora
MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x <li>
[MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 [...]
+| [oceanbase-cdc]({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) |
<li> [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x <li> [OceanBase
EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x
|
OceanBase Driver: 2 [...]
+| [oracle-cdc]({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) |
<li> [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21
|
Oracle Driver: 19.3 [...]
+| [postgres-cdc]({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) |
<li> [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14
| JDBC
Driver: 42.5.1 [...]
+| [sqlserver-cdc]({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) |
<li> [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017,
2019
| JDBC
Driver: 9.4.1. [...]
+| [tidb-cdc]({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) |
<li> [TiDB](https://www.pingcap.com/): 5.1.x, 5.2.x, 5.3.x, 5.4.x, 6.0.0
| JDBC
Driver: 8.0.27 [...]
+| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
<li> [Db2](https://www.ibm.com/products/db2): 11.5
| Db2
Driver: 11.5.0. [...]
+| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
<li> [Vitess](https://vitess.io/): 8.0.x, 9.0.x
| MySQL
JDBC Driver: [...]
## Supported Flink Versions
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/oracle.md
b/docs/content.zh/docs/connectors/pipeline-connectors/oracle.md
index 7ae7e2020..3a19a88fa 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/oracle.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/oracle.md
@@ -1,5 +1,5 @@
---
-title: "ORACLE"
+title: "Oracle"
weight: 2
type: docs
aliases:
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
b/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
index 4bc5eda0a..c2319f9cc 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
@@ -32,19 +32,19 @@ Flink CDC 提供了可用于 YAML 作业的 Pipeline Source 和 Sink 连接器
| 连接器
| 类型 | 支持的外部系统
| 下载链接 [...]
|----------------------------------------------------------------------------------|--------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|------
[...]
-| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x,
3.x.x
| [3.6. [...]
-| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li> [Elasticsearch](https://www.elastic.co/elasticsearch):
6.x, 7.x, 8.x
| [3.6. [...]
-| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/): 1.6, 1.7,
1.8, 1.9, 1.10
[...]
-| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/): 0.7, 0.8, 0.9
[...]
-| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
| [3.6. [...]
-| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <li>
[RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x <li>
[PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x <li>
[Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x <li>
[MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | [3.6 [...]
-| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
| [3.6. [...]
-| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
| [3.6. [...]
-| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7, 0.8, 0.9,
1.0, 1.1, 1.2, 1.3
[...]
-| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
| [3.6. [...]
-| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li> [MaxCompute](https://www.aliyun.com/product/maxcompute)
| [3.6. [...]
-| [Oracle]({{< ref "docs/connectors/pipeline-connectors/oracle" >}})
| Source | <li> [Oracle](https://www.oracle.com/database/)
| [3.6. [...]
-| [Hudi]({{< ref "docs/connectors/pipeline-connectors/hudi" >}})
| Sink | <li> [Apache Hudi](https://hudi.apache.org/)
| [3.6. [...]
+| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x,
3.x.x
| Flink [...]
+| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li> [Elasticsearch](https://www.elastic.co/elasticsearch):
6.x, 7.x, 8.x
| Flink [...]
+| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/): 0.7, 0.8, 0.9
[...]
+| [Hudi]({{< ref "docs/connectors/pipeline-connectors/hudi" >}})
| Sink | <li> [Apache Hudi](https://hudi.apache.org/)
| Flink [...]
+| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/): 1.6, 1.7,
1.8, 1.9, 1.10
[...]
+| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
| Flink [...]
+| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li> [MaxCompute](https://www.aliyun.com/product/maxcompute)
| Flink [...]
+| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <li>
[RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x <li>
[PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x <li>
[Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x <li>
[MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | Flin [...]
+| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
| Flink [...]
+| [Oracle]({{< ref "docs/connectors/pipeline-connectors/oracle" >}})
| Source | <li> [Oracle](https://www.oracle.com/database/)
| Flink [...]
+| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7, 0.8, 0.9,
1.0, 1.1, 1.2, 1.3
[...]
+| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
| Flink [...]
+| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
| Flink [...]
## Supported Flink Versions
diff --git a/docs/content.zh/docs/get-started/introduction.md
b/docs/content.zh/docs/get-started/introduction.md
index e992569f7..50f2160a7 100644
--- a/docs/content.zh/docs/get-started/introduction.md
+++ b/docs/content.zh/docs/get-started/introduction.md
@@ -37,6 +37,44 @@ Flink CDC 深度集成并由 Apache Flink 驱动，提供以下核心功能：
* ✅ 整库同步
* ✅具备表结构变更自动同步的能力（Schema Evolution），
+## 环境要求
+
+Flink CDC 有以下环境要求：
+
+* **JDK**：JDK 11 或更高版本（Flink CDC 从 3.6.0 版本开始基于 JDK 11 构建）
+* **Apache Flink**：Flink 1.20.x 或 Flink 2.2.x
+
+{{< hint info >}}
+在运行 Flink CDC 之前，请确保已安装正确的 JDK 版本。您可以使用 `java -version` 命令验证 Java 版本。
+{{< /hint >}}
+
+## 支持的连接器
+
+Flink CDC 提供了丰富的连接器生态系统，用于与各种外部系统进行交互：
+
+| 连接器 | 类型
|
+|---------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| MySQL | [Source Connector]({{< ref
"docs/connectors/flink-sources/mysql-cdc" >}}) / [Pipeline Source
Connector]({{< ref "docs/connectors/pipeline-connectors/mysql" >}}) |
+| Oracle | [Source Connector]({{< ref
"docs/connectors/flink-sources/oracle-cdc" >}}) / [Pipeline Source
Connector]({{< ref "docs/connectors/pipeline-connectors/oracle" >}}) |
+| PostgreSQL | [Source Connector]({{< ref
"docs/connectors/flink-sources/postgres-cdc" >}}) / [Pipeline Source
Connector]({{< ref "docs/connectors/pipeline-connectors/postgres" >}}) |
+| Db2 | [Source Connector]({{< ref
"docs/connectors/flink-sources/db2-cdc" >}})
|
+| MongoDB | [Source Connector]({{< ref
"docs/connectors/flink-sources/mongodb-cdc" >}})
|
+| SQL Server | [Source Connector]({{< ref
"docs/connectors/flink-sources/sqlserver-cdc" >}})
|
+| TiDB | [Source Connector]({{< ref
"docs/connectors/flink-sources/tidb-cdc" >}})
|
+| Vitess | [Source Connector]({{< ref
"docs/connectors/flink-sources/vitess-cdc" >}})
|
+| Apache Doris | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/doris" >}})
|
+| Elasticsearch | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/elasticsearch" >}})
|
+| Fluss | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/fluss" >}})
|
+| Hudi | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/hudi" >}})
|
+| Iceberg | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/iceberg" >}})
|
+| Kafka | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/kafka" >}})
|
+| MaxCompute | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/maxcompute" >}})
|
+| OceanBase | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/oceanbase" >}})
|
+| Paimon | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/paimon" >}})
|
+| StarRocks | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/starrocks" >}})
|
+
+关于连接器下载链接，请访问 [Flink Source Connectors]({{< ref
"docs/connectors/flink-sources/overview#supported-connectors" >}}) 和 [Pipeline
Connectors]({{< ref
"docs/connectors/pipeline-connectors/overview#supported-connectors" >}}) 页面。
+
## 如何使用 Flink CDC
Flink CDC 提供了基于 `YAML` 格式的用户 API，更适合于数据集成场景。以下是一个 `YAML`
文件的示例，它定义了一个数据管道(Pipeline)，该Pipeline从 MySQL 捕获实时变更，并将它们同步到 Apache Doris：
@@ -77,8 +115,11 @@ pipeline:
查看快速入门指南，了解如何建立一个 Flink CDC Pipeline：
-- [MySQL to Apache Doris]({{< ref "docs/get-started/quickstart/mysql-to-doris"
>}})
-- [MySQL to StarRocks]({{< ref
"docs/get-started/quickstart/mysql-to-starrocks" >}})
+| 示例 | 版本 |
+|---------|---------|
+| MySQL to Apache Doris | [1.20.x]({{< ref
"docs/get-started/quickstart-for-1.20/mysql-to-doris" >}}) / [2.2.x]({{< ref
"docs/get-started/quickstart-for-2.2/mysql-to-doris" >}}) |
+| MySQL to StarRocks | [1.20.x]({{< ref
"docs/get-started/quickstart-for-1.20/mysql-to-starrocks" >}}) / [2.2.x]({{<
ref "docs/get-started/quickstart-for-2.2/mysql-to-starrocks" >}}) |
+| MySQL to Kafka | [1.20.x]({{< ref
"docs/get-started/quickstart-for-1.20/mysql-to-kafka" >}}) / [2.2.x]({{< ref
"docs/get-started/quickstart-for-2.2/mysql-to-kafka" >}}) |
### 理解核心概念
diff --git a/docs/content.zh/docs/get-started/quickstart/_index.md
b/docs/content.zh/docs/get-started/quickstart-for-1.20/_index.md
similarity index 95%
copy from docs/content.zh/docs/get-started/quickstart/_index.md
copy to docs/content.zh/docs/get-started/quickstart-for-1.20/_index.md
index ad1c09bab..c58303e41 100644
--- a/docs/content.zh/docs/get-started/quickstart/_index.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-1.20/_index.md
@@ -1,5 +1,5 @@
---
-title: "快速开始"
+title: "在 Flink 1.20 上快速开始"
bookCollapseSection: true
weight: 2
---
diff --git
a/docs/content.zh/docs/get-started/quickstart/cdc-up-quickstart-guide.md
b/docs/content.zh/docs/get-started/quickstart-for-1.20/cdc-up-quickstart-guide.md
similarity index 100%
rename from
docs/content.zh/docs/get-started/quickstart/cdc-up-quickstart-guide.md
rename to
docs/content.zh/docs/get-started/quickstart-for-1.20/cdc-up-quickstart-guide.md
diff --git a/docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
b/docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-doris.md
similarity index 99%
copy from docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
copy to docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-doris.md
index a57ded7bc..85e14d3dd 100644
--- a/docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-doris.md
@@ -2,8 +2,6 @@
title: "MySQL 同步到 Doris"
weight: 1
type: docs
-aliases:
-- /get-started/quickstart/mysql-to-doris
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md
b/docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-kafka.md
similarity index 99%
copy from docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md
copy to docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-kafka.md
index f8fdd7f61..5e678f67f 100644
--- a/docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-kafka.md
@@ -2,8 +2,6 @@
title: "MySQL 同步到 Kafka"
weight: 4
type: docs
-aliases:
-- /try-flink-cdc/pipeline-connectors/mysql-Kafka-pipeline-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -39,7 +37,7 @@ under the License.
```shell
tar -zxvf flink-1.20.3-bin-scala_2.12.tgz
- exprot FLINK_HOME=$(pwd)/flink-1.20.3
+ export FLINK_HOME=$(pwd)/flink-1.20.3
cd flink-1.20.3
```
diff --git a/docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
b/docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-starrocks.md
similarity index 99%
copy from docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
copy to
docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-starrocks.md
index f3bbcdb63..a3c51c0a0 100644
--- a/docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-1.20/mysql-to-starrocks.md
@@ -2,8 +2,6 @@
title: "MySQL 同步到 StarRocks"
weight: 2
type: docs
-aliases:
-- /try-flink-cdc/pipeline-connectors/mysql-starrocks-pipeline-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/get-started/quickstart/postgres-to-fluss.md
b/docs/content.zh/docs/get-started/quickstart-for-1.20/postgres-to-fluss.md
similarity index 99%
copy from docs/content.zh/docs/get-started/quickstart/postgres-to-fluss.md
copy to
docs/content.zh/docs/get-started/quickstart-for-1.20/postgres-to-fluss.md
index 7ffb7852f..d20583e01 100644
--- a/docs/content.zh/docs/get-started/quickstart/postgres-to-fluss.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-1.20/postgres-to-fluss.md
@@ -2,8 +2,6 @@
title: "Postgres 同步到 Fluss"
weight: 5
type: docs
-aliases:
-- /get-started/quickstart/postgres-to-fluss
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/get-started/quickstart/_index.md
b/docs/content.zh/docs/get-started/quickstart-for-2.2/_index.md
similarity index 95%
copy from docs/content.zh/docs/get-started/quickstart/_index.md
copy to docs/content.zh/docs/get-started/quickstart-for-2.2/_index.md
index ad1c09bab..da9a63733 100644
--- a/docs/content.zh/docs/get-started/quickstart/_index.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-2.2/_index.md
@@ -1,5 +1,5 @@
---
-title: "快速开始"
+title: "在 Flink 2.2 上快速开始"
bookCollapseSection: true
weight: 2
---
diff --git a/docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
b/docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-doris.md
similarity index 94%
rename from docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
rename to docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-doris.md
index a57ded7bc..8b0f4896d 100644
--- a/docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-doris.md
@@ -33,11 +33,11 @@ under the License.
准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。
### 准备 Flink Standalone 集群
-1. 下载 [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)，解压后得到
flink-1.20.3 目录。
- 使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.20.3 所在目录。
+1. 下载 [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz)，解压后得到
flink-2.2.0 目录。
+ 使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-2.2.0 所在目录。
```shell
- cd flink-1.20.3
+ cd flink-2.2.0
```
2. 通过在 conf/config.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
@@ -56,7 +56,7 @@ under the License.
启动成功的话，可以在 [http://localhost:8081/](http://localhost:8081/)访问到 Flink Web
UI，如下所示：
-{{< img src="/fig/mysql-doris-tutorial/flink-ui.png" alt="Flink UI" >}}
+{{< img src="/fig/mysql-doris-tutorial/flink-ui-flink22.png" alt="Flink UI" >}}
多次执行 `start-cluster.sh` 可以拉起多个 TaskManager。
@@ -189,8 +189,8 @@ MacOS 由于内部实现容器的方式不同，在部署时宿主机直接修
2. 下载下面列出的 connector 包，并且移动到 `lib` 目录下；
**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地基于 master 或 release- 分支编译.**
**请注意，您需要将 jar 移动到 Flink CDC Home 的 lib 目录，而非 Flink Home 的 lib 目录下。**
- - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version >}}.jar)
- - [Apache Doris pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/{{<
param Version >}}/flink-cdc-pipeline-connector-doris-{{< param Version >}}.jar)
+ - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version
>}}-2.2.jar)
+ - [Apache Doris pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/{{<
param Version >}}/flink-cdc-pipeline-connector-doris-{{< param Version
>}}-2.2.jar)
您还需要将下面的 Driver 包放在 Flink `lib` 目录下，或通过 `--jar` 参数将其传入 Flink CDC CLI，因为 CDC
Connectors 不再包含这些 Drivers：
- [MySQL Connector
Java](https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.27/mysql-connector-java-8.0.27.jar)
@@ -240,11 +240,11 @@ sink 添加 `table.create.properties.replication_num` 参数是由于
Docker 镜
Job ID: ae30f4580f1918bebf16752d4963dc54
Job Description: Sync MySQL Database to Doris
```
-在 Flink Web UI，可以看到一个名为 `Sync MySQL Database to Doris` 的任务正在运行。
+在 Flink Web UI，可以看到一个名为 `Sync MySQL Database to Doris` 的任务正在运行。
-{{< img src="/fig/mysql-doris-tutorial/mysql-to-doris.png"
alt="MySQL-to-Doris" >}}
+{{< img src="/fig/mysql-doris-tutorial/mysql-to-doris-flink22.png"
alt="MySQL-to-Doris" >}}
-打开 Doris 的 Web UI，可以看到数据表已经被创建出来，数据能成功写入。
+打开 Doris 的 Web UI，可以看到数据表已经被创建出来，数据能成功写入。
{{< img src="/fig/mysql-doris-tutorial/doris-display-data.png" alt="Doris
display data" >}}
@@ -340,7 +340,7 @@ Flink CDC 提供了将源表的表结构/数据路由到其他表名的配置，
```shell
docker-compose down
```
-在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
+在 Flink 所在目录 `flink-2.2.0` 下执行如下命令停止 Flink 集群：
```shell
./bin/stop-cluster.sh
diff --git a/docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md
b/docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-kafka.md
similarity index 96%
rename from docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md
rename to docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-kafka.md
index f8fdd7f61..2d396bdad 100644
--- a/docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-kafka.md
@@ -34,13 +34,13 @@ under the License.
准备一台已经安装了 Docker 的 Linux 或者 macOS 电脑。
### 准备 Flink Standalone 集群
-1. 下载 [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)，解压后得到
flink-1.20.3 目录。
- 使用下面的命令跳转至 Flink 目录下，并且设置 `FLINK_HOME` 为 flink-1.20.3 所在目录。
+1. 下载 [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz)，解压后得到
flink-2.2.0 目录。
+ 使用下面的命令跳转至 Flink 目录下，并且设置 `FLINK_HOME` 为 flink-2.2.0 所在目录。
```shell
- tar -zxvf flink-1.20.3-bin-scala_2.12.tgz
- exprot FLINK_HOME=$(pwd)/flink-1.20.3
- cd flink-1.20.3
+ tar -zxvf flink-2.2.0-bin-scala_2.12.tgz
+ export FLINK_HOME=$(pwd)/flink-2.2.0
+ cd flink-2.2.0
```
2. 在 `conf/config.yaml` 配置文件追加下列参数开启检查点，每隔 3 秒进行一次 checkpoint。
@@ -59,7 +59,7 @@ under the License.
启动成功后，即可在 [http://localhost:8081/](http://localhost:8081/) 访问到 Flink Web
UI，如下所示：
-{{< img src="/fig/mysql-Kafka-tutorial/flink-ui.png" alt="Flink UI" >}}
+{{< img src="/fig/mysql-Kafka-tutorial/flink-ui-flink22.png" alt="Flink UI" >}}
多次执行 `start-cluster.sh` 可以拉起多个 TaskManager。
@@ -176,8 +176,8 @@ under the License.
2. 下载下面列出的 connector 包，并且移动到 lib 目录下；
**请注意，您需要将 jar 移动到 Flink CDC Home 的 lib 目录，而非 Flink Home 的 lib 目录下。**
- - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version >}}.jar)
- - [Kafka pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/{{<
param Version >}}/flink-cdc-pipeline-connector-kafka-{{< param Version >}}.jar)
+ - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version
>}}-2.2.jar)
+ - [Kafka pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/{{<
param Version >}}/flink-cdc-pipeline-connector-kafka-{{< param Version
>}}-2.2.jar)
您还需要将下面的 Driver 包放在 Flink `lib` 目录下，或通过 `--jar` 参数将其传入 Flink CDC CLI，因为 CDC
Connectors 不再包含这些 Drivers：
- [MySQL Connector
Java](https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.27/mysql-connector-java-8.0.27.jar)
@@ -230,7 +230,7 @@ under the License.
在 Flink Web UI，可以看到一个名为 `Sync MySQL Database to Kafka` 的任务正在运行。
- {{< img src="/fig/mysql-Kafka-tutorial/mysql-to-Kafka.png"
alt="MySQL-to-Kafka" >}}
+ {{< img src="/fig/mysql-Kafka-tutorial/mysql-to-Kafka-flink22.png"
alt="MySQL-to-Kafka" >}}
您可以通过 Kafka 提供的命令行工具查看 Topic 中的消息，像这样：
@@ -623,7 +623,7 @@ pipeline:
docker compose down
```
-在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
+在 `FLINK_HOME` 目录下执行如下命令停止 Flink 集群：
```shell
./bin/stop-cluster.sh
diff --git a/docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
b/docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-starrocks.md
similarity index 94%
rename from docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
rename to
docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-starrocks.md
index f3bbcdb63..8b566512e 100644
--- a/docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-2.2/mysql-to-starrocks.md
@@ -33,11 +33,11 @@ under the License.
准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。
### 准备 Flink Standalone 集群
-1. 下载 [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)
，解压后得到 flink-1.20.3 目录。
- 使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.20.3 所在目录。
+1. 下载 [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz)
，解压后得到 flink-2.2.0 目录。
+ 使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-2.2.0 所在目录。
```shell
- cd flink-1.20.3
+ cd flink-2.2.0
```
2. 通过在 conf/config.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
@@ -56,7 +56,7 @@ under the License.
启动成功的话，可以在 [http://localhost:8081/](http://localhost:8081/) 访问到 Flink Web
UI，如下所示：
-{{< img src="/fig/mysql-starrocks-tutorial/flink-ui.png" alt="Flink UI" >}}
+{{< img src="/fig/mysql-starrocks-tutorial/flink-ui-flink22.png" alt="Flink
UI" >}}
多次执行 start-cluster.sh 可以拉起多个 TaskManager。
@@ -150,8 +150,8 @@ under the License.
2. 下载下面列出的 connector 包，并且移动到 lib 目录下；
**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地基于 master 或 release- 分支编译。**
**请注意，您需要将 jar 移动到 Flink CDC Home 的 lib 目录，而非 Flink Home 的 lib 目录下。**
- - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version >}}.jar)
- - [StarRocks pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/{{<
param Version >}}/flink-cdc-pipeline-connector-starrocks-{{< param Version
>}}.jar)
+ - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version
>}}-2.2.jar)
+ - [StarRocks pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/{{<
param Version >}}/flink-cdc-pipeline-connector-starrocks-{{< param Version
>}}-2.2.jar)
您还需要将下面的 Driver 包放在 Flink `lib` 目录下，或通过 `--jar` 参数将其传入 Flink CDC CLI，因为 CDC
Connectors 不再包含这些 Drivers：
- [MySQL Connector
Java](https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.27/mysql-connector-java-8.0.27.jar)
@@ -208,7 +208,7 @@ under the License.
在 Flink Web UI，可以看到一个名为 `Sync MySQL Database to StarRocks` 的任务正在运行。
-{{< img src="/fig/mysql-starrocks-tutorial/mysql-to-starrocks.png"
alt="MySQL-to-StarRocks" >}}
+{{< img src="/fig/mysql-starrocks-tutorial/mysql-to-starrocks-flink22.png"
alt="MySQL-to-StarRocks" >}}
通过数据库连接工具例如 Dbeaver 等连接到 jdbc:mysql://127.0.0.1:9030， 可以查看 StarRocks
中写入了三张表的数据。
@@ -308,7 +308,7 @@ Flink CDC 提供了将源表的表结构/数据路由到其他表名的配置，
docker-compose down
```
-在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
+在 Flink 所在目录 `flink-2.2.0` 下执行如下命令停止 Flink 集群：
```shell
./bin/stop-cluster.sh
diff --git a/docs/content.zh/docs/get-started/quickstart/postgres-to-fluss.md
b/docs/content.zh/docs/get-started/quickstart-for-2.2/postgres-to-fluss.md
similarity index 96%
rename from docs/content.zh/docs/get-started/quickstart/postgres-to-fluss.md
rename to
docs/content.zh/docs/get-started/quickstart-for-2.2/postgres-to-fluss.md
index 7ffb7852f..9fd3a998c 100644
--- a/docs/content.zh/docs/get-started/quickstart/postgres-to-fluss.md
+++ b/docs/content.zh/docs/get-started/quickstart-for-2.2/postgres-to-fluss.md
@@ -33,11 +33,11 @@ under the License.
准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。
### 准备 Flink Standalone 集群
-1. 下载 [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)，解压后得到
flink-1.20.3 目录。
- 使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.20.3 所在目录。
+1. 下载 [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz)，解压后得到
flink-2.2.0 目录。
+ 使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-2.2.0 所在目录。
```shell
- cd flink-1.20.3
+ cd flink-2.2.0
```
2. 通过在 conf/config.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
@@ -202,8 +202,8 @@ under the License.
2. 下载下面列出的 connector 包，并且移动到 `lib` 目录下；
**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地基于 master 或 release- 分支编译。**
**请注意，您需要将 jar 移动到 Flink CDC Home 的 lib 目录，而非 Flink Home 的 lib 目录下。**
- - [Postgres pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-postgres/{{<
param Version >}}/flink-cdc-pipeline-connector-postgres-{{< param Version
>}}.jar)
- - [Fluss pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/{{<
param Version >}}/flink-cdc-pipeline-connector-fluss-{{< param Version >}}.jar)
+ - [Postgres pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-postgres/{{<
param Version >}}/flink-cdc-pipeline-connector-postgres-{{< param Version
>}}-2.2.jar)
+ - [Fluss pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/{{<
param Version >}}/flink-cdc-pipeline-connector-fluss-{{< param Version
>}}-2.2.jar)
3. 编写任务配置 yaml 文件。
下面给出了一个整库同步的示例文件 `postgres-to-fluss.yaml`：
@@ -258,7 +258,7 @@ under the License.
### 在 Fluss 中查询数据
要查询已同步到 Fluss 的数据，需要配置 Flink SQL Client。
-1. 下载
[fluss-flink-1.20-0.9.0-incubating.jar](https://repo1.maven.org/maven2/org/apache/fluss/fluss-flink-1.20/0.9.0-incubating/fluss-flink-1.20-0.9.0-incubating.jar)
并放入 Flink 的 `lib` 目录。
+1. 下载
[fluss-flink-2.2-0.9.0-incubating.jar](https://repo1.maven.org/maven2/org/apache/fluss/fluss-flink-2.2/0.9.0-incubating/fluss-flink-2.2-0.9.0-incubating.jar)
并放入 Flink 的 `lib` 目录。
2. 启动 Flink SQL Client：
```shell
@@ -397,7 +397,7 @@ PostgreSQL 的表结构变更是**数据驱动**的 — DDL 变更不会立即
```shell
docker-compose down -v
```
-在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
+在 Flink 所在目录 `flink-2.2.0` 下执行如下命令停止 Flink 集群：
```shell
./bin/stop-cluster.sh
diff --git a/docs/content/docs/connectors/flink-sources/overview.md
b/docs/content/docs/connectors/flink-sources/overview.md
index e793cd7a3..cbf7bc40d 100644
--- a/docs/content/docs/connectors/flink-sources/overview.md
+++ b/docs/content/docs/connectors/flink-sources/overview.md
@@ -35,17 +35,17 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/b
## Supported Connectors
-| Connector |
Database
|
Driver [...]
-|----------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|--------------------
[...]
-| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.1 [...]
-| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
<li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <li> [RDS
MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x <li> [PolarDB
MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x <li> [Aurora
MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x <li>
[MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 [...]
-| [oceanbase-cdc]({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) |
<li> [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x <li> [OceanBase
EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x
|
OceanBase Driver: 2 [...]
-| [oracle-cdc]({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) |
<li> [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21
|
Oracle Driver: 19.3 [...]
-| [postgres-cdc]({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) |
<li> [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14
| JDBC
Driver: 42.5.1 [...]
-| [sqlserver-cdc]({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) |
<li> [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017,
2019
| JDBC
Driver: 9.4.1. [...]
-| [tidb-cdc]({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) |
<li> [TiDB](https://www.pingcap.com/): 5.1.x, 5.2.x, 5.3.x, 5.4.x, 6.0.0
| JDBC
Driver: 8.0.27 [...]
-| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
<li> [Db2](https://www.ibm.com/products/db2): 11.5
| Db2
Driver: 11.5.0. [...]
-| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
<li> [Vitess](https://vitess.io/): 8.0.x, 9.0.x
| MySql
JDBC Driver: [...]
+| Connector |
Database
|
Driver [...]
+|----------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|--------------------
[...]
+| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.1 [...]
+| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
<li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <li> [RDS
MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x <li> [PolarDB
MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x <li> [Aurora
MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x <li>
[MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 [...]
+| [oceanbase-cdc]({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) |
<li> [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x <li> [OceanBase
EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x
|
OceanBase Driver: 2 [...]
+| [oracle-cdc]({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) |
<li> [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21
|
Oracle Driver: 19.3 [...]
+| [postgres-cdc]({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) |
<li> [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14
| JDBC
Driver: 42.5.1 [...]
+| [sqlserver-cdc]({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) |
<li> [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017,
2019
| JDBC
Driver: 9.4.1. [...]
+| [tidb-cdc]({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) |
<li> [TiDB](https://www.pingcap.com/): 5.1.x, 5.2.x, 5.3.x, 5.4.x, 6.0.0
| JDBC
Driver: 8.0.27 [...]
+| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
<li> [Db2](https://www.ibm.com/products/db2): 11.5
| Db2
Driver: 11.5.0. [...]
+| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
<li> [Vitess](https://vitess.io/): 8.0.x, 9.0.x
| MySQL
JDBC Driver: [...]
## Supported Flink Versions
diff --git a/docs/content/docs/connectors/pipeline-connectors/oracle.md
b/docs/content/docs/connectors/pipeline-connectors/oracle.md
index 087a8bc03..5a791ae36 100644
--- a/docs/content/docs/connectors/pipeline-connectors/oracle.md
+++ b/docs/content/docs/connectors/pipeline-connectors/oracle.md
@@ -1,5 +1,5 @@
---
-title: "ORACLE"
+title: "Oracle"
weight: 2
type: docs
aliases:
diff --git a/docs/content/docs/connectors/pipeline-connectors/overview.md
b/docs/content/docs/connectors/pipeline-connectors/overview.md
index ee70aabd8..837ce4478 100644
--- a/docs/content/docs/connectors/pipeline-connectors/overview.md
+++ b/docs/content/docs/connectors/pipeline-connectors/overview.md
@@ -35,19 +35,19 @@ definition.
| Connector
| Supported Type | External System
[...]
|----------------------------------------------------------------------------------|----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
-| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x,
2.x.x, 3.x.x
[...]
-| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li>
[Elasticsearch](https://www.elastic.co/elasticsearch): 6.x, 7.x, 8.x
[...]
-| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/): 1.6,
1.7, 1.8, 1.9, 1.10
[...]
-| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/): 0.7, 0.8, 0.9
[...]
-| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
[...]
-| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x,
8.4+ <li> [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7,
8.0.x <li> [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7,
8.0.x <li> [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7,
8.0.x <li> [MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0. [...]
-| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
[...]
-| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
[...]
-| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7,
0.8, 0.9, 1.0, 1.1, 1.2, 1.3
[...]
-| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
[...]
-| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li>
[MaxCompute](https://www.aliyun.com/product/maxcompute)
[...]
-| [Oracle]({{< ref "docs/connectors/pipeline-connectors/oracle" >}})
| Source | <li> [Oracle](https://www.oracle.com/database/)
[...]
-| [Hudi]({{< ref "docs/connectors/pipeline-connectors/hudi" >}})
| Sink | <li> [Apache Hudi](https://hudi.apache.org/)
[...]
+| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x,
2.x.x, 3.x.x
[...]
+| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li>
[Elasticsearch](https://www.elastic.co/elasticsearch): 6.x, 7.x, 8.x
[...]
+| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/): 0.7, 0.8, 0.9
[...]
+| [Hudi]({{< ref "docs/connectors/pipeline-connectors/hudi" >}})
| Sink | <li> [Apache Hudi](https://hudi.apache.org/)
[...]
+| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/): 1.6,
1.7, 1.8, 1.9, 1.10
[...]
+| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
[...]
+| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li>
[MaxCompute](https://www.aliyun.com/product/maxcompute)
[...]
+| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x,
8.4+ <li> [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7,
8.0.x <li> [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7,
8.0.x <li> [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7,
8.0.x <li> [MariaDB](https://mariadb.org): 10.x <li> [PolarDB
X](https://github.com/ApsaraDB/galaxysql): 2.0. [...]
+| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
[...]
+| [Oracle]({{< ref "docs/connectors/pipeline-connectors/oracle" >}})
| Source | <li> [Oracle](https://www.oracle.com/database/)
[...]
+| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7,
0.8, 0.9, 1.0, 1.1, 1.2, 1.3
[...]
+| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
[...]
+| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
[...]
## Supported Flink Versions
diff --git a/docs/content/docs/get-started/introduction.md
b/docs/content/docs/get-started/introduction.md
index d0d4af7a8..48b6c790b 100644
--- a/docs/content/docs/get-started/introduction.md
+++ b/docs/content/docs/get-started/introduction.md
@@ -41,6 +41,44 @@ Deeply integrated with and powered by Apache Flink, Flink
CDC provides:
* ✅ Synchronization of entire databases
* ✅ Schema evolution capability
+## Requirements
+
+Flink CDC has the following requirements:
+
+* **JDK**: JDK 11 or later (Flink CDC is built on JDK 11 since 3.6.0)
+* **Apache Flink**: Flink 1.20.x or Flink 2.2.x
+
+{{< hint info >}}
+Make sure you have the correct JDK version installed before running Flink CDC.
You can verify your Java version with `java -version`.
+{{< /hint >}}
+
+## Supported Connectors
+
+Flink CDC provides a rich ecosystem of connectors to interact with various
external systems:
+
+| Connector | Type
|
+|---------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| MySQL | [Source Connector]({{< ref
"docs/connectors/flink-sources/mysql-cdc" >}}) / [Pipeline Source
Connector]({{< ref "docs/connectors/pipeline-connectors/mysql" >}}) |
+| Oracle | [Source Connector]({{< ref
"docs/connectors/flink-sources/oracle-cdc" >}}) / [Pipeline Source
Connector]({{< ref "docs/connectors/pipeline-connectors/oracle" >}}) |
+| PostgreSQL | [Source Connector]({{< ref
"docs/connectors/flink-sources/postgres-cdc" >}}) / [Pipeline Source
Connector]({{< ref "docs/connectors/pipeline-connectors/postgres" >}}) |
+| Db2 | [Source Connector]({{< ref
"docs/connectors/flink-sources/db2-cdc" >}})
|
+| MongoDB | [Source Connector]({{< ref
"docs/connectors/flink-sources/mongodb-cdc" >}})
|
+| SQL Server | [Source Connector]({{< ref
"docs/connectors/flink-sources/sqlserver-cdc" >}})
|
+| TiDB | [Source Connector]({{< ref
"docs/connectors/flink-sources/tidb-cdc" >}})
|
+| Vitess | [Source Connector]({{< ref
"docs/connectors/flink-sources/vitess-cdc" >}})
|
+| Apache Doris | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/doris" >}})
|
+| Elasticsearch | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/elasticsearch" >}})
|
+| Fluss | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/fluss" >}})
|
+| Hudi | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/hudi" >}})
|
+| Iceberg | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/iceberg" >}})
|
+| Kafka | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/kafka" >}})
|
+| MaxCompute | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/maxcompute" >}})
|
+| OceanBase | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/oceanbase" >}})
|
+| Paimon | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/paimon" >}})
|
+| StarRocks | [Pipeline Sink Connector]({{< ref
"docs/connectors/pipeline-connectors/starrocks" >}})
|
+
+For connector download links, please visit the [Flink Source Connectors]({{<
ref "docs/connectors/flink-sources/overview#supported-connectors" >}}) and
[Pipeline Connectors]({{< ref
"docs/connectors/pipeline-connectors/overview#supported-connectors" >}}) pages.
+
## How to Use Flink CDC
Flink CDC provides an YAML-formatted user API that more suitable for data
@@ -85,8 +123,11 @@ pipeline:
Check out the quickstart guide to learn how to establish a Flink CDC pipeline:
-- [MySQL to Apache Doris]({{< ref "docs/get-started/quickstart/mysql-to-doris"
>}})
-- [MySQL to StarRocks]({{< ref
"docs/get-started/quickstart/mysql-to-starrocks" >}})
+| Example | Version |
+|---------|---------|
+| MySQL to Apache Doris | [1.20.x]({{< ref
"docs/get-started/quickstart-for-1.20/mysql-to-doris" >}}) / [2.2.x]({{< ref
"docs/get-started/quickstart-for-2.2/mysql-to-doris" >}}) |
+| MySQL to StarRocks | [1.20.x]({{< ref
"docs/get-started/quickstart-for-1.20/mysql-to-starrocks" >}}) / [2.2.x]({{<
ref "docs/get-started/quickstart-for-2.2/mysql-to-starrocks" >}}) |
+| MySQL to Kafka | [1.20.x]({{< ref
"docs/get-started/quickstart-for-1.20/mysql-to-kafka" >}}) / [2.2.x]({{< ref
"docs/get-started/quickstart-for-2.2/mysql-to-kafka" >}}) |
### Understand Core Concepts
diff --git a/docs/content/docs/get-started/quickstart/_index.md
b/docs/content/docs/get-started/quickstart-for-1.20/_index.md
similarity index 95%
rename from docs/content/docs/get-started/quickstart/_index.md
rename to docs/content/docs/get-started/quickstart-for-1.20/_index.md
index 65da2954b..10474a12b 100644
--- a/docs/content/docs/get-started/quickstart/_index.md
+++ b/docs/content/docs/get-started/quickstart-for-1.20/_index.md
@@ -1,5 +1,5 @@
---
-title: "Quickstart"
+title: "Quickstart for Flink 1.20"
bookCollapseSection: true
weight: 2
---
diff --git
a/docs/content/docs/get-started/quickstart/cdc-up-quickstart-guide.md
b/docs/content/docs/get-started/quickstart-for-1.20/cdc-up-quickstart-guide.md
similarity index 100%
rename from docs/content/docs/get-started/quickstart/cdc-up-quickstart-guide.md
rename to
docs/content/docs/get-started/quickstart-for-1.20/cdc-up-quickstart-guide.md
diff --git a/docs/content/docs/get-started/quickstart/mysql-to-doris.md
b/docs/content/docs/get-started/quickstart-for-1.20/mysql-to-doris.md
similarity index 99%
copy from docs/content/docs/get-started/quickstart/mysql-to-doris.md
copy to docs/content/docs/get-started/quickstart-for-1.20/mysql-to-doris.md
index ba34cc81f..8d2a77e68 100644
--- a/docs/content/docs/get-started/quickstart/mysql-to-doris.md
+++ b/docs/content/docs/get-started/quickstart-for-1.20/mysql-to-doris.md
@@ -2,8 +2,6 @@
title: "MySQL to Doris"
weight: 1
type: docs
-aliases:
-- /get-started/quickstart/mysql-to-doris
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/get-started/quickstart/mysql-to-kafka.md
b/docs/content/docs/get-started/quickstart-for-1.20/mysql-to-kafka.md
similarity index 99%
copy from docs/content/docs/get-started/quickstart/mysql-to-kafka.md
copy to docs/content/docs/get-started/quickstart-for-1.20/mysql-to-kafka.md
index 08f8f6d79..f020e5341 100644
--- a/docs/content/docs/get-started/quickstart/mysql-to-kafka.md
+++ b/docs/content/docs/get-started/quickstart-for-1.20/mysql-to-kafka.md
@@ -2,8 +2,6 @@
title: "MySQL to Kafka"
weight: 4
type: docs
-aliases:
-- /try-flink-cdc/pipeline-connectors/mysql-Kafka-pipeline-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -41,7 +39,7 @@ You need a Linux or macOS computer with Docker installed
before starting.
```shell
tar -zxvf flink-1.20.3-bin-scala_2.12.tgz
- exprot FLINK_HOME=$(pwd)/flink-1.20.3
+ export FLINK_HOME=$(pwd)/flink-1.20.3
cd flink-1.20.3
```
diff --git a/docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
b/docs/content/docs/get-started/quickstart-for-1.20/mysql-to-starrocks.md
similarity index 99%
copy from docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
copy to docs/content/docs/get-started/quickstart-for-1.20/mysql-to-starrocks.md
index 3975796a6..703ef86be 100644
--- a/docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
+++ b/docs/content/docs/get-started/quickstart-for-1.20/mysql-to-starrocks.md
@@ -2,8 +2,6 @@
title: "MySQL to StarRocks"
weight: 2
type: docs
-aliases:
-- /try-flink-cdc/pipeline-connectors/mysql-starrocks-pipeline-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/get-started/quickstart/postgres-to-fluss.md
b/docs/content/docs/get-started/quickstart-for-1.20/postgres-to-fluss.md
similarity index 99%
copy from docs/content/docs/get-started/quickstart/postgres-to-fluss.md
copy to docs/content/docs/get-started/quickstart-for-1.20/postgres-to-fluss.md
index 36c66a0ff..abd465c27 100644
--- a/docs/content/docs/get-started/quickstart/postgres-to-fluss.md
+++ b/docs/content/docs/get-started/quickstart-for-1.20/postgres-to-fluss.md
@@ -2,8 +2,6 @@
title: "Postgres to Fluss"
weight: 5
type: docs
-aliases:
-- /get-started/quickstart/postgres-to-fluss
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/get-started/quickstart/_index.md
b/docs/content/docs/get-started/quickstart-for-2.2/_index.md
similarity index 95%
rename from docs/content.zh/docs/get-started/quickstart/_index.md
rename to docs/content/docs/get-started/quickstart-for-2.2/_index.md
index ad1c09bab..c38a56ae4 100644
--- a/docs/content.zh/docs/get-started/quickstart/_index.md
+++ b/docs/content/docs/get-started/quickstart-for-2.2/_index.md
@@ -1,5 +1,5 @@
---
-title: "快速开始"
+title: "Quickstart for Flink 2.2"
bookCollapseSection: true
weight: 2
---
diff --git a/docs/content/docs/get-started/quickstart/mysql-to-doris.md
b/docs/content/docs/get-started/quickstart-for-2.2/mysql-to-doris.md
similarity index 94%
rename from docs/content/docs/get-started/quickstart/mysql-to-doris.md
rename to docs/content/docs/get-started/quickstart-for-2.2/mysql-to-doris.md
index ba34cc81f..bf6546c61 100644
--- a/docs/content/docs/get-started/quickstart/mysql-to-doris.md
+++ b/docs/content/docs/get-started/quickstart-for-2.2/mysql-to-doris.md
@@ -35,11 +35,11 @@ without a single line of Java/Scala code or IDE
installation.
Prepare a Linux or MacOS computer with Docker installed.
### Prepare Flink Standalone cluster
-1. Download [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)
，unzip and get flink-1.20.3 directory.
- Use the following command to navigate to the Flink directory and set
FLINK_HOME to the directory where flink-1.20.3 is located.
+1. Download [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz)
，unzip and get flink-2.2.0 directory.
+ Use the following command to navigate to the Flink directory and set
FLINK_HOME to the directory where flink-2.2.0 is located.
```shell
- cd flink-1.20.3
+ cd flink-2.2.0
```
2. Enable checkpointing by appending the following parameters to the
conf/config.yaml configuration file to perform a checkpoint every 3 seconds.
@@ -58,7 +58,7 @@ Prepare a Linux or MacOS computer with Docker installed.
If successfully started, you can access the Flink Web UI at
[http://localhost:8081/](http://localhost:8081/), as shown below.
-{{< img src="/fig/mysql-doris-tutorial/flink-ui.png" alt="Flink UI" >}}
+{{< img src="/fig/mysql-doris-tutorial/flink-ui-flink22.png" alt="Flink UI" >}}
Executing `start-cluster.sh` multiple times can start multiple `TaskManager`s.
@@ -184,15 +184,15 @@ This command automatically starts all the containers
defined in the Docker Compo
{{< img src="/fig/mysql-doris-tutorial/doris-create-table.png" alt="Doris
create table" >}}
## Submit job with Flink CDC CLI
-1. Download the binary compressed packages listed below and extract them to
the directory `flink cdc-{{< param Version >}}'`：
+1. Download the binary compressed packages listed below and extract them to
the directory `flink-cdc-{{< param Version >}}`：
[flink-cdc-{{< param Version
>}}-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-{{< param
Version >}}/flink-cdc-{{< param Version >}}-bin.tar.gz)
- flink-cdc-{{< param Version >}} directory will contain four directory:
`bin`, `lib`, `log`, and `conf`.
+ `flink-cdc-{{< param Version >}}` directory will contain four directories:
`bin`, `lib`, `log`, and `conf`.
-2. Download the connector package listed below and move it to the `lib`
directory
+2. Download the connector package listed below and move it to the `lib`
directory
**Download links are available only for stable releases, SNAPSHOT
dependencies need to be built based on master or release branches by yourself.**
**Please note that you need to move the jar to the lib directory of Flink
CDC Home, not to the lib directory of Flink Home.**
- - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version >}}.jar)
- - [Apache Doris pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/{{<
param Version >}}/flink-cdc-pipeline-connector-doris-{{< param Version >}}.jar)
+ - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version
>}}-2.2.jar)
+ - [Apache Doris pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/{{<
param Version >}}/flink-cdc-pipeline-connector-doris-{{< param Version
>}}-2.2.jar)
You also need to place MySQL connector into Flink `lib` folder or pass it
with `--jar` argument, since they're no longer packaged with CDC connectors:
- [MySQL Connector
Java](https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.27/mysql-connector-java-8.0.27.jar)
@@ -242,11 +242,11 @@ After successful submission, the return information is as
follows：
Job ID: ae30f4580f1918bebf16752d4963dc54
Job Description: Sync MySQL Database to Doris
```
- We can find a job named `Sync MySQL Database to Doris` is running through
Flink Web UI.
+ We can find a job named `Sync MySQL Database to Doris` is running through
Flink Web UI.
-{{< img src="/fig/mysql-doris-tutorial/mysql-to-doris.png"
alt="MySQL-to-Doris" >}}
+{{< img src="/fig/mysql-doris-tutorial/mysql-to-doris-flink22.png"
alt="MySQL-to-Doris" >}}
-We can find that tables are created and inserted through Doris Web UI.
+We can find that tables are created and inserted through Doris Web UI.
{{< img src="/fig/mysql-doris-tutorial/doris-display-data.png" alt="Doris
display data" >}}
@@ -345,7 +345,7 @@ After finishing the tutorial, run the following command to
stop all containers i
```shell
docker-compose down
```
-Run the following command to stop the Flink cluster in the directory of Flink
`flink-1.20.3`:
+Run the following command to stop the Flink cluster in the directory of Flink
`flink-2.2.0`:
```shell
./bin/stop-cluster.sh
diff --git a/docs/content/docs/get-started/quickstart/mysql-to-kafka.md
b/docs/content/docs/get-started/quickstart-for-2.2/mysql-to-kafka.md
similarity index 95%
rename from docs/content/docs/get-started/quickstart/mysql-to-kafka.md
rename to docs/content/docs/get-started/quickstart-for-2.2/mysql-to-kafka.md
index 08f8f6d79..720656cd3 100644
--- a/docs/content/docs/get-started/quickstart/mysql-to-kafka.md
+++ b/docs/content/docs/get-started/quickstart-for-2.2/mysql-to-kafka.md
@@ -36,13 +36,13 @@ without a single line of Java/Scala code or IDE
installation.
You need a Linux or macOS computer with Docker installed before starting.
### Prepare Flink Standalone cluster
-1. Download [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz),
unzip it and enter `flink-1.20.3` directory.
- Use the following command to navigate to the Flink directory and set
`FLINK_HOME` to the directory where flink-1.20.3 is located.
+1. Download [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz),
unzip it and enter `flink-2.2.0` directory.
+ Use the following command to navigate to the Flink directory and set
`FLINK_HOME` to the directory where flink-2.2.0 is located.
```shell
- tar -zxvf flink-1.20.3-bin-scala_2.12.tgz
- exprot FLINK_HOME=$(pwd)/flink-1.20.3
- cd flink-1.20.3
+ tar -zxvf flink-2.2.0-bin-scala_2.12.tgz
+ export FLINK_HOME=$(pwd)/flink-2.2.0
+ cd flink-2.2.0
```
2. Enable checkpointing by appending the following parameters to the
`conf/config.yaml` configuration file to perform a checkpoint every 3 seconds.
@@ -61,7 +61,7 @@ You need a Linux or macOS computer with Docker installed
before starting.
After the cluster gets started, you can access the Flink Web UI at
[http://localhost:8081/](http://localhost:8081/).
-{{< img src="/fig/mysql-Kafka-tutorial/flink-ui.png" alt="Flink UI" >}}
+{{< img src="/fig/mysql-Kafka-tutorial/flink-ui-flink22.png" alt="Flink UI" >}}
Run `start-cluster.sh` multiple times to start more TaskManagers if necessary.
@@ -174,14 +174,14 @@ Run `docker ps` to check whether these containers are
running properly.
**Please note that the following download links are available only for stable
releases.
You need to build your own SNAPSHOT versions based on master or release
branches by yourself.**
-1. Download the binary compressed packages listed below and extract them to
the directory `flink cdc-{{< param Version >}}'`:
+1. Download the binary compressed packages listed below and extract them to
the directory `flink-cdc-{{< param Version >}}`:
[flink-cdc-{{< param Version
>}}-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-{{< param
Version >}}/flink-cdc-{{< param Version >}}-bin.tar.gz)
- flink-cdc-{{< param Version >}} directory will contain four directory:
`bin`, `lib`, `log`, and `conf`.
+ `flink-cdc-{{< param Version >}}` directory will contain four directories:
`bin`, `lib`, `log`, and `conf`.
2. Download the connector package listed below and move it to the `lib`
directory:
**Please note that you need to move the jar to the lib directory of Flink
CDC Home, not to the lib directory of Flink Home.**
- - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version >}}.jar)
- - [Kafka pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/{{<
param Version >}}/flink-cdc-pipeline-connector-kafka-{{< param Version >}}.jar)
+ - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version
>}}-2.2.jar)
+ - [Kafka pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/{{<
param Version >}}/flink-cdc-pipeline-connector-kafka-{{< param Version
>}}-2.2.jar)
You also need to place MySQL connector into Flink `lib` folder or pass it
with `--jar` argument, since they're no longer packaged with CDC connectors:
- [MySQL Connector
Java](https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.27/mysql-connector-java-8.0.27.jar)
@@ -230,7 +230,7 @@ You need to build your own SNAPSHOT versions based on
master or release branches
A job named `Sync MySQL Database to Kafka` could be seen running in the
Flink Web UI.
- {{< img src="/fig/mysql-Kafka-tutorial/mysql-to-Kafka.png"
alt="MySQL-to-Kafka" >}}
+ {{< img src="/fig/mysql-Kafka-tutorial/mysql-to-Kafka-flink22.png"
alt="MySQL-to-Kafka" >}}
We can subscribe the sink kafka topic to monitor messages sent to Kafka
with this command:
diff --git a/docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
b/docs/content/docs/get-started/quickstart-for-2.2/mysql-to-starrocks.md
similarity index 93%
rename from docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
rename to docs/content/docs/get-started/quickstart-for-2.2/mysql-to-starrocks.md
index 3975796a6..7ed6802fe 100644
--- a/docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
+++ b/docs/content/docs/get-started/quickstart-for-2.2/mysql-to-starrocks.md
@@ -35,11 +35,11 @@ without a single line of Java/Scala code or IDE
installation.
Prepare a Linux or MacOS computer with Docker installed.
### Prepare Flink Standalone cluster
-1. Download [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)
，unzip and get flink-1.20.3 directory.
- Use the following command to navigate to the Flink directory and set
FLINK_HOME to the directory where flink-1.20.3 is located.
+1. Download [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz)
，unzip and get flink-2.2.0 directory.
+ Use the following command to navigate to the Flink directory and set
FLINK_HOME to the directory where flink-2.2.0 is located.
```shell
- cd flink-1.20.3
+ cd flink-2.2.0
```
2. Enable checkpointing by appending the following parameters to the
conf/config.yaml configuration file to perform a checkpoint every 3 seconds.
@@ -58,7 +58,7 @@ Prepare a Linux or MacOS computer with Docker installed.
If successfully started, you can access the Flink Web UI at
[http://localhost:8081/](http://localhost:8081/), as shown below.
-{{< img src="/fig/mysql-starrocks-tutorial/flink-ui.png" alt="Flink UI" >}}
+{{< img src="/fig/mysql-starrocks-tutorial/flink-ui-flink22.png" alt="Flink
UI" >}}
Executing `start-cluster.sh` multiple times can start multiple `TaskManager`s.
@@ -146,15 +146,15 @@ This command automatically starts all the containers
defined in the Docker Compo
```
## Submit job with Flink CDC CLI
-1. Download the binary compressed packages listed below and extract them to
the directory `flink cdc-{{< param Version >}}'`：
+1. Download the binary compressed packages listed below and extract them to
the directory `flink-cdc-{{< param Version >}}`：
[flink-cdc-{{< param Version
>}}-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-{{< param
Version >}}/flink-cdc-{{< param Version >}}-bin.tar.gz)
- flink-cdc-{{< param Version >}} directory will contain four directory:
`bin`, `lib`, `log`, and `conf`.
+ `flink-cdc-{{< param Version >}}` directory will contain four directories:
`bin`, `lib`, `log`, and `conf`.
-2. Download the connector package listed below and move it to the `lib`
directory
+2. Download the connector package listed below and move it to the `lib`
directory
**Download links are available only for stable releases, SNAPSHOT
dependencies need to be built based on master or release branches by yourself.**
**Please note that you need to move the jar to the lib directory of Flink
CDC Home, not to the lib directory of Flink Home.**
- - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version >}}.jar)
- - [StarRocks pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/{{<
param Version >}}/flink-cdc-pipeline-connector-starrocks-{{< param Version
>}}.jar)
+ - [MySQL pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/{{<
param Version >}}/flink-cdc-pipeline-connector-mysql-{{< param Version
>}}-2.2.jar)
+ - [StarRocks pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/{{<
param Version >}}/flink-cdc-pipeline-connector-starrocks-{{< param Version
>}}-2.2.jar)
You also need to place MySQL connector into Flink `lib` folder or pass it
with `--jar` argument, since they're no longer packaged with CDC connectors:
- [MySQL Connector
Java](https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.27/mysql-connector-java-8.0.27.jar)
@@ -211,7 +211,7 @@ After successful submission, the return information is as
follows：
We can find a job named `Sync MySQL Database to StarRocks` is running through
Flink Web UI.
-{{< img src="/fig/mysql-starrocks-tutorial/mysql-to-starrocks.png"
alt="MySQL-to-StarRocks" >}}
+{{< img src="/fig/mysql-starrocks-tutorial/mysql-to-starrocks-flink22.png"
alt="MySQL-to-StarRocks" >}}
Connect to jdbc through database connection tools such as Dbeaver using
`mysql://127.0.0.1:9030`. You can view the data written to three tables in
StarRocks.
@@ -312,7 +312,7 @@ After finishing the tutorial, run the following command to
stop all containers i
docker-compose down
```
-Run the following command to stop the Flink cluster in the directory of Flink
`flink-1.20.1`:
+Run the following command to stop the Flink cluster in the directory of Flink
`flink-2.2.0`:
```shell
./bin/stop-cluster.sh
diff --git a/docs/content/docs/get-started/quickstart/postgres-to-fluss.md
b/docs/content/docs/get-started/quickstart-for-2.2/postgres-to-fluss.md
similarity index 96%
rename from docs/content/docs/get-started/quickstart/postgres-to-fluss.md
rename to docs/content/docs/get-started/quickstart-for-2.2/postgres-to-fluss.md
index 36c66a0ff..7f5718061 100644
--- a/docs/content/docs/get-started/quickstart/postgres-to-fluss.md
+++ b/docs/content/docs/get-started/quickstart-for-2.2/postgres-to-fluss.md
@@ -35,11 +35,11 @@ without a single line of Java/Scala code or IDE
installation.
Prepare a Linux or MacOS computer with Docker installed.
### Prepare Flink Standalone cluster
-1. Download [Flink
1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz),
unzip and get flink-1.20.3 directory.
- Use the following command to navigate to the Flink directory and set
FLINK_HOME to the directory where flink-1.20.3 is located.
+1. Download [Flink
2.2.0](https://archive.apache.org/dist/flink/flink-2.2.0/flink-2.2.0-bin-scala_2.12.tgz),
unzip and get flink-2.2.0 directory.
+ Use the following command to navigate to the Flink directory and set
FLINK_HOME to the directory where flink-2.2.0 is located.
```shell
- cd flink-1.20.3
+ cd flink-2.2.0
```
2. Enable checkpointing by appending the following parameters to the
conf/config.yaml configuration file to perform a checkpoint every 3 seconds.
@@ -201,11 +201,11 @@ This command automatically starts all the containers
defined in the Docker Compo
[flink-cdc-{{< param Version
>}}-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-{{< param
Version >}}/flink-cdc-{{< param Version >}}-bin.tar.gz)
flink-cdc-{{< param Version >}} directory will contain four directories:
`bin`, `lib`, `log`, and `conf`.
-2. Download the connector packages listed below and move them to the `lib`
directory
+2. Download the connector packages listed below and move them to the `lib`
directory
**Download links are available only for stable releases, SNAPSHOT
dependencies need to be built based on master or release branches by yourself.**
**Please note that you need to move the jar to the lib directory of Flink
CDC Home, not to the lib directory of Flink Home.**
- - [Postgres pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-postgres/{{<
param Version >}}/flink-cdc-pipeline-connector-postgres-{{< param Version
>}}.jar)
- - [Fluss pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/{{<
param Version >}}/flink-cdc-pipeline-connector-fluss-{{< param Version >}}.jar)
+ - [Postgres pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-postgres/{{<
param Version >}}/flink-cdc-pipeline-connector-postgres-{{< param Version
>}}-2.2.jar)
+ - [Fluss pipeline connector {{< param Version
>}}](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/{{<
param Version >}}/flink-cdc-pipeline-connector-fluss-{{< param Version
>}}-2.2.jar)
3. Write task configuration yaml file.
Here is an example file for synchronizing the entire database
`postgres-to-fluss.yaml`：
@@ -260,7 +260,7 @@ This command automatically starts all the containers
defined in the Docker Compo
### Query data in Fluss
To query the synchronized data in Fluss, you need to set up the Flink SQL
Client.
-1. Download
[fluss-flink-1.20-0.9.0-incubating.jar](https://repo1.maven.org/maven2/org/apache/fluss/fluss-flink-1.20/0.9.0-incubating/fluss-flink-1.20-0.9.0-incubating.jar)
and place it in the Flink `lib` directory.
+1. Download
[fluss-flink-2.2-0.9.0-incubating.jar](https://repo1.maven.org/maven2/org/apache/fluss/fluss-flink-2.2/0.9.0-incubating/fluss-flink-2.2-0.9.0-incubating.jar)
and place it in the Flink `lib` directory.
2. Start the Flink SQL Client:
```shell
@@ -399,7 +399,7 @@ After finishing the tutorial, run the following command to
stop all containers i
```shell
docker-compose down -v
```
-Run the following command to stop the Flink cluster in the directory of Flink
`flink-1.20.3`:
+Run the following command to stop the Flink cluster in the directory of Flink
`flink-2.2.0`:
```shell
./bin/stop-cluster.sh
diff --git a/docs/static/fig/mysql-Kafka-tutorial/flink-ui-flink22.png
b/docs/static/fig/mysql-Kafka-tutorial/flink-ui-flink22.png
new file mode 100644
index 000000000..6abb60736
Binary files /dev/null and
b/docs/static/fig/mysql-Kafka-tutorial/flink-ui-flink22.png differ
diff --git a/docs/static/fig/mysql-Kafka-tutorial/mysql-to-Kafka-flink22.png
b/docs/static/fig/mysql-Kafka-tutorial/mysql-to-Kafka-flink22.png
new file mode 100644
index 000000000..71f97b3ac
Binary files /dev/null and
b/docs/static/fig/mysql-Kafka-tutorial/mysql-to-Kafka-flink22.png differ
diff --git a/docs/static/fig/mysql-doris-tutorial/flink-ui-flink22.png
b/docs/static/fig/mysql-doris-tutorial/flink-ui-flink22.png
new file mode 100644
index 000000000..6abb60736
Binary files /dev/null and
b/docs/static/fig/mysql-doris-tutorial/flink-ui-flink22.png differ
diff --git a/docs/static/fig/mysql-doris-tutorial/mysql-to-doris-flink22.png
b/docs/static/fig/mysql-doris-tutorial/mysql-to-doris-flink22.png
new file mode 100644
index 000000000..ebce9af30
Binary files /dev/null and
b/docs/static/fig/mysql-doris-tutorial/mysql-to-doris-flink22.png differ
diff --git a/docs/static/fig/mysql-starrocks-tutorial/flink-ui-flink22.png
b/docs/static/fig/mysql-starrocks-tutorial/flink-ui-flink22.png
new file mode 100644
index 000000000..6abb60736
Binary files /dev/null and
b/docs/static/fig/mysql-starrocks-tutorial/flink-ui-flink22.png differ
diff --git
a/docs/static/fig/mysql-starrocks-tutorial/mysql-to-starrocks-flink22.png
b/docs/static/fig/mysql-starrocks-tutorial/mysql-to-starrocks-flink22.png
new file mode 100644
index 000000000..44efa88dd
Binary files /dev/null and
b/docs/static/fig/mysql-starrocks-tutorial/mysql-to-starrocks-flink22.png differ
