Skip to content

Commit

Permalink
Automatically convert flink CDC Version
Browse files Browse the repository at this point in the history
  • Loading branch information
911432 authored Oct 8, 2024
1 parent 4b13c49 commit f71c7be
Show file tree
Hide file tree
Showing 31 changed files with 60 additions and 49 deletions.
4 changes: 2 additions & 2 deletions docs/content.zh/docs/connectors/flink-sources/db2-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ using a build automation tool (such as Maven or SBT) and SQL Client with SQL JAR

### SQL Client JAR

Download [flink-sql-connector-db2-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.0/flink-sql-connector-db2-cdc-3.1.0.jar) and
Download [flink-sql-connector-db2-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/{{ flinkCDCVersion }}/flink-sql-connector-db2-cdc-{{ flinkCDCVersion }}.jar) and
put it under `<FLINK_HOME>/lib/`.

**Note:** Refer to
Expand Down Expand Up @@ -354,7 +354,7 @@ public class Db2SourceExample {
}
```

The DB2 CDC incremental connector (after 3.1.0) can be used as the following shows:
The DB2 CDC incremental connector (after {{ flinkCDCVersion }}) can be used as the following shows:
```java
import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ MongoDB CDC 连接器允许从 MongoDB 读取快照数据和增量数据。 本

```下载链接仅适用于稳定版本。```

下载 [flink-sql-connector-mongodb-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.0/flink-sql-connector-mongodb-cdc-3.1.0.jar), 把它放在 `<FLINK_HOME>/lib/`.
下载 [flink-sql-connector-mongodb-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/{{ flinkCDCVersion }}/flink-sql-connector-mongodb-cdc-{{ flinkCDCVersion }}.jar), 把它放在 `<FLINK_HOME>/lib/`.

**注意:** 参考 [flink-sql-connector-mongodb-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-mongodb-cdc), 当前已发布的版本将在 Maven 中央仓库中提供。

Expand Down
2 changes: 1 addition & 1 deletion docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ MySQL CDC 连接器允许从 MySQL 数据库读取快照数据和增量数据。

```下载链接仅在已发布版本可用,请在文档网站左下角选择浏览已发布的版本。```

下载 [flink-sql-connector-mysql-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar)`<FLINK_HOME>/lib/` 目录下。
下载 [flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/{{ flinkCDCVersion }}/flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar) 到 `<FLINK_HOME>/lib/` 目录下。

**注意:** 参考 [flink-sql-connector-mysql-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-mysql-cdc) 当前已发布的所有版本都可以在 Maven 中央仓库获取。

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ OceanBase CDC 源端读取方案:

```下载链接仅在已发布版本可用,请在文档网站左下角选择浏览已发布的版本。```

下载[flink-sql-connector-oceanbase-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.0/flink-sql-connector-oceanbase-cdc-3.1.0.jar)`<FLINK_HOME>/lib/` 目录下。
下载[flink-sql-connector-oceanbase-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/{{ flinkCDCVersion }}/flink-sql-connector-oceanbase-cdc-{{ flinkCDCVersion }}.jar) 到 `<FLINK_HOME>/lib/` 目录下。

**注意:** 参考 [flink-sql-connector-oceanbase-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-oceanbase-cdc) 当前已发布的所有版本都可以在 Maven 中央仓库获取。

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ In order to setup the Oracle CDC connector, the following table provides depende

**Download link is available only for stable releases.**

Download [flink-sql-connector-oracle-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.0/flink-sql-connector-oracle-cdc-3.1.0.jar) and put it under `<FLINK_HOME>/lib/`.
Download [flink-sql-connector-oracle-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/{{ flinkCDCVersion }}/flink-sql-connector-oracle-cdc-{{ flinkCDCVersion }}.jar) and put it under `<FLINK_HOME>/lib/`.

**Note:** Refer to [flink-sql-connector-oracle-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-oracle-cdc), more released versions will be available in the Maven central warehouse.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ In order to setup the Postgres CDC connector, the following table provides depen

```Download link is available only for stable releases.```

Download [flink-sql-connector-postgres-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.0/flink-sql-connector-postgres-cdc-3.1.0.jar) and put it under `<FLINK_HOME>/lib/`.
Download [flink-sql-connector-postgres-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/{{ flinkCDCVersion }}/flink-sql-connector-postgres-cdc-{{ flinkCDCVersion }}.jar) and put it under `<FLINK_HOME>/lib/`.

**Note:** Refer to [flink-sql-connector-postgres-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-postgres-cdc), more released versions will be available in the Maven central warehouse.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ In order to setup the SQLServer CDC connector, the following table provides depe

```Download link is available only for stable releases.```

Download [flink-sql-connector-sqlserver-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.0/flink-sql-connector-sqlserver-cdc-3.1.0.jar) and put it under `<FLINK_HOME>/lib/`.
Download [flink-sql-connector-sqlserver-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/{{ flinkCDCVersion }}/flink-sql-connector-sqlserver-cdc-{{ flinkCDCVersion }}.jar) and put it under `<FLINK_HOME>/lib/`.

**Note:** Refer to [flink-sql-connector-sqlserver-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-sqlserver-cdc), more released versions will be available in the Maven central warehouse.

Expand Down
2 changes: 1 addition & 1 deletion docs/content.zh/docs/connectors/flink-sources/tidb-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ In order to setup the TiDB CDC connector, the following table provides dependenc

```Download link is available only for stable releases.```

Download [flink-sql-connector-tidb-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.0/flink-sql-connector-tidb-cdc-3.1.0.jar) and put it under `<FLINK_HOME>/lib/`.
Download [flink-sql-connector-tidb-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/{{ flinkCDCVersion }}/flink-sql-connector-tidb-cdc-{{ flinkCDCVersion }}.jar) and put it under `<FLINK_HOME>/lib/`.

**Note:** Refer to [flink-sql-connector-tidb-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-tidb-cdc), more released versions will be available in the Maven central warehouse.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ volumes:

**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译**

- [flink-sql-connector-mysql-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar)
- [flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/{{ flinkCDCVersion }}/flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar)
- [flink-shaded-hadoop-2-uber-2.7.5-10.0.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.7.5-10.0/flink-shaded-hadoop-2-uber-2.7.5-10.0.jar)
- [iceberg-flink-1.13-runtime-0.13.0-SNAPSHOT.jar](https://raw.githubusercontent.com/luoyuxia/flink-cdc-tutorial/main/flink-cdc-iceberg-demo/sql-client/lib/iceberg-flink-1.13-runtime-0.13.0-SNAPSHOT.jar)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -100,8 +100,8 @@ docker-compose up -d

**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译**
- [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
- [flink-sql-connector-mysql-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar)
- [flink-sql-connector-postgres-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.0/flink-sql-connector-postgres-cdc-3.1.0.jar)
- [flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/{{ flinkCDCVersion }}/flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar)
- [flink-sql-connector-postgres-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/{{ flinkCDCVersion }}/flink-sql-connector-postgres-cdc-{{ flinkCDCVersion }}.jar)

### 准备数据
#### 在 MySQL 数据库中准备数据
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ db.customers.insertMany([
```下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译```

- [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
- [flink-sql-connector-mongodb-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.0/flink-sql-connector-mongodb-cdc-3.1.0.jar)
- [flink-sql-connector-mongodb-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/{{ flinkCDCVersion }}/flink-sql-connector-mongodb-cdc-{{ flinkCDCVersion }}.jar)

4. 然后启动 Flink 集群,再启动 SQL CLI.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ VALUES (default, '2020-07-30 10:08:22', 'Jark', 50.50, 102, false),
```下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译```

- [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
- [flink-sql-connector-oceanbase-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.0/flink-sql-connector-oceanbase-cdc-3.1.0.jar)
- [flink-sql-connector-oceanbase-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/{{ flinkCDCVersion }}/flink-sql-connector-oceanbase-cdc-{{ flinkCDCVersion }}.jar)

### 在 Flink SQL CLI 中使用 Flink DDL 创建表

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ docker-compose down
*下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译*

- [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
- [flink-sql-connector-oracle-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.0/flink-sql-connector-oracle-cdc-3.1.0.jar)
- [flink-sql-connector-oracle-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/{{ flinkCDCVersion }}/flink-sql-connector-oracle-cdc-{{ flinkCDCVersion }}.jar)


**在 Oracle 数据库中准备数据**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ VALUES (default, '2020-07-30 10:08:22', 'Jark', 50.50, 102, false),
2. 下载下面列出的依赖包,并将它们放到目录 `flink-1.17.0/lib/` 下

```下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译```
- 用于订阅PolarDB-X Binlog: [flink-sql-connector-mysql-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar)
- 用于订阅PolarDB-X Binlog: [flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/{{ flinkCDCVersion }}/flink-sql-connector-mysql-cdc-{{ flinkCDCVersion }}.jar)
- 用于写入Elasticsearch: [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
3. 启动flink服务:
```shell
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ docker-compose down
```下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译```

- [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
- [flink-sql-connector-sqlserver-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.0/flink-sql-connector-sqlserver-cdc-3.1.0.jar)
- [flink-sql-connector-sqlserver-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/{{ flinkCDCVersion }}/flink-sql-connector-sqlserver-cdc-{{ flinkCDCVersion }}.jar)


**在 SqlServer 数据库中准备数据**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ docker-compose down
```下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地编译```

- [flink-sql-connector-elasticsearch7-3.0.1-1.17.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar)
- [flink-sql-connector-tidb-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.0/flink-sql-connector-tidb-cdc-3.1.0.jar)
- [flink-sql-connector-tidb-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/{{ flinkCDCVersion }}/flink-sql-connector-tidb-cdc-{{ flinkCDCVersion }}.jar)


**在 TiDB 数据库中准备数据**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ In order to setup the Vitess CDC connector, the following table provides depende

### SQL Client JAR

Download [flink-sql-connector-vitess-cdc-3.1.0.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-vitess-cdc/3.1.0/flink-sql-connector-vitess-cdc-3.1.0.jar) and put it under `<FLINK_HOME>/lib/`.
Download [flink-sql-connector-vitess-cdc-{{ flinkCDCVersion }}.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-vitess-cdc/{{ flinkCDCVersion }}/flink-sql-connector-vitess-cdc-{{ flinkCDCVersion }}.jar) and put it under `<FLINK_HOME>/lib/`.

**Note:** Refer to
[flink-sql-connector-vitess-cdc](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-vitess-cdc),
Expand Down
10 changes: 5 additions & 5 deletions docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
Original file line number Diff line number Diff line change
Expand Up @@ -180,15 +180,15 @@ MacOS 由于内部实现容器的方式不同,在部署时宿主机直接修
{{< img src="/fig/mysql-doris-tutorial/doris-create-table.png" alt="Doris create table" >}}

## 通过 Flink CDC CLI 提交任务
1. 下载下面列出的二进制压缩包,并解压得到目录 `flink-cdc-3.1.0`
[flink-cdc-3.1.0-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-3.1.0/flink-cdc-3.1.0-bin.tar.gz)
flink-cdc-3.1.0 下会包含 `bin``lib``log``conf` 四个目录。
1. 下载下面列出的二进制压缩包,并解压得到目录 `flink-cdc-{{ flinkCDCVersion }}`
[flink-cdc-{{ flinkCDCVersion }}-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-{{ flinkCDCVersion }}/flink-cdc-{{ flinkCDCVersion }}-bin.tar.gz)
flink-cdc-{{ flinkCDCVersion }} 下会包含 `bin``lib``log``conf` 四个目录。

2. 下载下面列出的 connector 包,并且移动到 `lib` 目录下;
**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地基于 master 或 release- 分支编译.**
**请注意,您需要将 jar 移动到 Flink CDC Home 的 lib 目录,而非 Flink Home 的 lib 目录下。**
- [MySQL pipeline connector 3.1.0](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.0/flink-cdc-pipeline-connector-mysql-3.1.0.jar)
- [Apache Doris pipeline connector 3.1.0](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.0/flink-cdc-pipeline-connector-doris-3.1.0.jar)
- [MySQL pipeline connector {{ flinkCDCVersion }}](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-mysql/{{ flinkCDCVersion }}/flink-cdc-pipeline-connector-mysql-{{ flinkCDCVersion }}.jar)
- [Apache Doris pipeline connector {{ flinkCDCVersion }}](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-doris/{{ flinkCDCVersion }}/flink-cdc-pipeline-connector-doris-{{ flinkCDCVersion }}.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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -141,15 +141,15 @@ under the License.
```

## 通过 Flink CDC CLI 提交任务
1. 下载下面列出的二进制压缩包,并解压得到目录 `flink-cdc-3.1.0`
[flink-cdc-3.1.0-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-3.1.0/flink-cdc-3.1.0-bin.tar.gz)
flink-cdc-3.1.0 下会包含 `bin``lib``log``conf` 四个目录。
1. 下载下面列出的二进制压缩包,并解压得到目录 `flink-cdc-{{ flinkCDCVersion }}`
[flink-cdc-{{ flinkCDCVersion }}-bin.tar.gz](https://www.apache.org/dyn/closer.lua/flink/flink-cdc-{{ flinkCDCVersion }}/flink-cdc-{{ flinkCDCVersion }}-bin.tar.gz)
flink-cdc-{{ flinkCDCVersion }} 下会包含 `bin``lib``log``conf` 四个目录。

2. 下载下面列出的 connector 包,并且移动到 lib 目录下;
**下载链接只对已发布的版本有效, SNAPSHOT 版本需要本地基于 master 或 release- 分支编译。**
**请注意,您需要将 jar 移动到 Flink CDC Home 的 lib 目录,而非 Flink Home 的 lib 目录下。**
- [MySQL pipeline connector 3.1.0](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.0/flink-cdc-pipeline-connector-mysql-3.1.0.jar)
- [StarRocks pipeline connector 3.1.0](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.0/flink-cdc-pipeline-connector-starrocks-3.1.0.jar)
- [MySQL pipeline connector {{ flinkCDCVersion }}](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-mysql/{{ flinkCDCVersion }}/flink-cdc-pipeline-connector-mysql-{{ flinkCDCVersion }}.jar)
- [StarRocks pipeline connector {{ flinkCDCVersion }}](https://search.maven.org/remotecontent?filepath=org/apache/flink/flink-cdc-pipeline-connector-starrocks/{{ flinkCDCVersion }}/flink-cdc-pipeline-connector-starrocks-{{ flinkCDCVersion }}.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)
Expand Down
Loading

0 comments on commit f71c7be

Please sign in to comment.