This is an automated email from the ASF dual-hosted git repository. kassiez pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris-website.git
The following commit(s) were added to refs/heads/master by this push: new dae407cb4e2 [ecosystem](flink) improve flink doc (#2298) dae407cb4e2 is described below commit dae407cb4e2d26dfbc16aea987d3b55b9adbed96 Author: wudi <w...@selectdb.com> AuthorDate: Wed Apr 23 20:16:34 2025 +0800 [ecosystem](flink) improve flink doc (#2298) ## Versions - [x] dev - [x] 3.0 - [x] 2.1 - [ ] 2.0 ## Languages - [x] Chinese - [x] English ## Docs Checklist - [ ] Checked by AI - [ ] Test Cases Built --- docs/ecosystem/flink-doris-connector.md | 16 ++++++++++++++++ .../current/ecosystem/flink-doris-connector.md | 22 +++++++++++++++++++--- .../version-2.1/ecosystem/flink-doris-connector.md | 20 ++++++++++++++++++-- .../version-3.0/ecosystem/flink-doris-connector.md | 20 ++++++++++++++++++-- .../version-2.1/ecosystem/flink-doris-connector.md | 16 ++++++++++++++++ .../version-3.0/ecosystem/flink-doris-connector.md | 16 ++++++++++++++++ 6 files changed, 103 insertions(+), 7 deletions(-) diff --git a/docs/ecosystem/flink-doris-connector.md b/docs/ecosystem/flink-doris-connector.md index 3ed37f5f540..2dd63884a65 100644 --- a/docs/ecosystem/flink-doris-connector.md +++ b/docs/ecosystem/flink-doris-connector.md @@ -64,6 +64,16 @@ You can download the corresponding version of the Flink Doris Connector Jar file To use it with Maven, simply add the following dependency to your Pom file: +```xml +<dependency> + <groupId>org.apache.doris</groupId> + <artifactId>flink-doris-connector-${flink.version}</artifactId> + <version>${connector.version}</version> +</dependency> +``` + +For example: + ```xml <dependency> <groupId>org.apache.doris</groupId> @@ -338,6 +348,12 @@ INSERT INTO student_sink SELECT * FROM student_source; When using the DataStream API to write data, different serialization methods can be used to serialize the upstream data before writing it to the Doris table. +:::info + +The Connector already contains the HttpClient4.5.13 version. If you reference HttpClient separately in your project, you need to ensure that the versions are consistent. + +::: + ##### Standard String Format When the upstream data is in CSV or JSON format, you can directly use the `SimpleStringSerializer` to serialize the data. diff --git a/i18n/zh-CN/docusaurus-plugin-content-docs/current/ecosystem/flink-doris-connector.md b/i18n/zh-CN/docusaurus-plugin-content-docs/current/ecosystem/flink-doris-connector.md index 7c2e806947d..0313408aeee 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/current/ecosystem/flink-doris-connector.md +++ b/i18n/zh-CN/docusaurus-plugin-content-docs/current/ecosystem/flink-doris-connector.md @@ -67,7 +67,17 @@ under the License. Maven 中使用的时候,可以直接在 Pom 文件中加入如下依赖 -```SQL +```xml +<dependency> + <groupId>org.apache.doris</groupId> + <artifactId>flink-doris-connector-${flink.version}</artifactId> + <version>${connector.version}</version> +</dependency> +``` + +例如: + +```xml <dependency> <groupId>org.apache.doris</groupId> <artifactId>flink-doris-connector-1.16</artifactId> @@ -339,7 +349,13 @@ INSERT INTO student_sink SELECT * FROM student_source; #### 使用 DataStream API 写入数据 -通过 DataStream api 写入的时候,可以使用不同的序列化方式对上游数据序列化后写入 Doris 表 +通过 DataStream api 写入的时候,可以使用不同的序列化方式对上游数据序列化后写入 Doris 表。 + +:::info + +Connector 内部已经包含 HttpClient4.5.13 版本,如果项目中有单独引用 HttpClient,需要确保版本一致。 + +::: ##### 普通 String 格式 @@ -581,7 +597,7 @@ Flink Doris Connector 中集成了[Flink CDC](https://nightlies.apache.org/flink :::info 注意 -1. 使用整库同步时需要在 `$FLINK_HOME/lib` 目录下添加对应的 Flink CDC 依赖 (Fat Jar),比如 **`flink-sql-connector-mysql-cdc-${version}.jar`**,**`flink-sql-connector-oracle-cdc-${version}.jar`**,FlinkCDC 从 3.1 版本与之前版本不兼容,下载地址分别为为[FlinkCDC3.x](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/),[FlinkCDC 2.x](https://repo.maven.apache.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/)。 +1. 使用整库同步时需要在 `$FLINK_HOME/lib` 目录下添加对应的 Flink CDC 依赖 (**Fat Jar**),比如 **`flink-sql-connector-mysql-cdc-${version}.jar`**,**`flink-sql-connector-oracle-cdc-${version}.jar`**,FlinkCDC 从 3.1 版本与之前版本不兼容,下载地址分别为为[FlinkCDC3.x](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/),[FlinkCDC 2.x](https://repo.maven.apache.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/)。 2. Connector 24.0.0 之后依赖的 Flink CDC 版本需要在 3.1 以上,下载地址见[这里](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/),FlinkCDC 如果需使用 Flink CDC 同步 MySQL 和 Oracle,还需要在 `$FLINK_HOME/lib` 下增加相关的 JDBC 驱动。 ::: diff --git a/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.1/ecosystem/flink-doris-connector.md b/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.1/ecosystem/flink-doris-connector.md index 7c2e806947d..744cdd77d19 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.1/ecosystem/flink-doris-connector.md +++ b/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.1/ecosystem/flink-doris-connector.md @@ -67,7 +67,17 @@ under the License. Maven 中使用的时候,可以直接在 Pom 文件中加入如下依赖 -```SQL +```xml +<dependency> + <groupId>org.apache.doris</groupId> + <artifactId>flink-doris-connector-${flink.version}</artifactId> + <version>${connector.version}</version> +</dependency> +``` + +例如: + +```xml <dependency> <groupId>org.apache.doris</groupId> <artifactId>flink-doris-connector-1.16</artifactId> @@ -339,7 +349,13 @@ INSERT INTO student_sink SELECT * FROM student_source; #### 使用 DataStream API 写入数据 -通过 DataStream api 写入的时候,可以使用不同的序列化方式对上游数据序列化后写入 Doris 表 +通过 DataStream api 写入的时候,可以使用不同的序列化方式对上游数据序列化后写入 Doris 表。 + +:::info + +Connector 内部已经包含 HttpClient4.5.13 版本,如果项目中有单独引用 HttpClient,需要确保版本一致。 + +::: ##### 普通 String 格式 diff --git a/i18n/zh-CN/docusaurus-plugin-content-docs/version-3.0/ecosystem/flink-doris-connector.md b/i18n/zh-CN/docusaurus-plugin-content-docs/version-3.0/ecosystem/flink-doris-connector.md index ebd79b091e8..0663eb00612 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/version-3.0/ecosystem/flink-doris-connector.md +++ b/i18n/zh-CN/docusaurus-plugin-content-docs/version-3.0/ecosystem/flink-doris-connector.md @@ -67,7 +67,17 @@ under the License. Maven 中使用的时候,可以直接在 Pom 文件中加入如下依赖 -```SQL +```xml +<dependency> + <groupId>org.apache.doris</groupId> + <artifactId>flink-doris-connector-${flink.version}</artifactId> + <version>${connector.version}</version> +</dependency> +``` + +例如: + +```xml <dependency> <groupId>org.apache.doris</groupId> <artifactId>flink-doris-connector-1.16</artifactId> @@ -339,7 +349,13 @@ INSERT INTO student_sink SELECT * FROM student_source; #### 使用 DataStream API 写入数据 -通过 DataStream api 写入的时候,可以使用不同的序列化方式对上游数据序列化后写入 Doris 表 +通过 DataStream api 写入的时候,可以使用不同的序列化方式对上游数据序列化后写入 Doris 表。 + +:::info + +Connector 内部已经包含 HttpClient4.5.13 版本,如果项目中有单独引用 HttpClient,需要确保版本一致。 + +::: ##### 普通 String 格式 diff --git a/versioned_docs/version-2.1/ecosystem/flink-doris-connector.md b/versioned_docs/version-2.1/ecosystem/flink-doris-connector.md index 98112b21774..c85a10defbe 100644 --- a/versioned_docs/version-2.1/ecosystem/flink-doris-connector.md +++ b/versioned_docs/version-2.1/ecosystem/flink-doris-connector.md @@ -64,6 +64,16 @@ You can download the corresponding version of the Flink Doris Connector Jar file To use it with Maven, simply add the following dependency to your Pom file: +```xml +<dependency> + <groupId>org.apache.doris</groupId> + <artifactId>flink-doris-connector-${flink.version}</artifactId> + <version>${connector.version}</version> +</dependency> +``` + +For example: + ```xml <dependency> <groupId>org.apache.doris</groupId> @@ -338,6 +348,12 @@ INSERT INTO student_sink SELECT * FROM student_source; When using the DataStream API to write data, different serialization methods can be used to serialize the upstream data before writing it to the Doris table. +:::info + +The Connector already contains the HttpClient4.5.13 version. If you reference HttpClient separately in your project, you need to ensure that the versions are consistent. + +::: + ##### Standard String Format When the upstream data is in CSV or JSON format, you can directly use the `SimpleStringSerializer` to serialize the data. diff --git a/versioned_docs/version-3.0/ecosystem/flink-doris-connector.md b/versioned_docs/version-3.0/ecosystem/flink-doris-connector.md index 98112b21774..c85a10defbe 100644 --- a/versioned_docs/version-3.0/ecosystem/flink-doris-connector.md +++ b/versioned_docs/version-3.0/ecosystem/flink-doris-connector.md @@ -64,6 +64,16 @@ You can download the corresponding version of the Flink Doris Connector Jar file To use it with Maven, simply add the following dependency to your Pom file: +```xml +<dependency> + <groupId>org.apache.doris</groupId> + <artifactId>flink-doris-connector-${flink.version}</artifactId> + <version>${connector.version}</version> +</dependency> +``` + +For example: + ```xml <dependency> <groupId>org.apache.doris</groupId> @@ -338,6 +348,12 @@ INSERT INTO student_sink SELECT * FROM student_source; When using the DataStream API to write data, different serialization methods can be used to serialize the upstream data before writing it to the Doris table. +:::info + +The Connector already contains the HttpClient4.5.13 version. If you reference HttpClient separately in your project, you need to ensure that the versions are consistent. + +::: + ##### Standard String Format When the upstream data is in CSV or JSON format, you can directly use the `SimpleStringSerializer` to serialize the data. --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org