diff --git a/docs/en/extending-doris/flink-doris-connector.md b/docs/en/extending-doris/flink-doris-connector.md index b83aefda06..dcba028e7c 100644 --- a/docs/en/extending-doris/flink-doris-connector.md +++ b/docs/en/extending-doris/flink-doris-connector.md @@ -47,6 +47,18 @@ sh build.sh After successful compilation, the file `doris-flink-1.0.0-SNAPSHOT.jar` will be generated in the `output/` directory. Copy this file to `ClassPath` in `Flink` to use `Flink-Doris-Connector`. For example, `Flink` running in `Local` mode, put this file in the `jars/` folder. `Flink` running in `Yarn` cluster mode, put this file in the pre-deployment package. +**Remarks:** + +1. Doris FE should be configured to enable http v2 in the configuration +2. Scala version currently only supports 2.12.x version + +conf/fe.conf + +``` +enable_http_server_v2 = true +``` + + ## How to use The purpose of this step is to register the Doris data source on Flink. This step is operated on Flink. diff --git a/docs/zh-CN/extending-doris/flink-doris-connector.md b/docs/zh-CN/extending-doris/flink-doris-connector.md index 20ed015570..5cebf1a771 100644 --- a/docs/zh-CN/extending-doris/flink-doris-connector.md +++ b/docs/zh-CN/extending-doris/flink-doris-connector.md @@ -45,7 +45,20 @@ Flink Doris Connector 可以支持通过 Flink 读取 Doris 中存储的数据 sh build.sh ``` -编译成功后,会在 `output/` 目录下生成文件 `doris-flink-1.0.0-SNAPSHOT.jar`。将此文件复制到 `Flink` 的 `ClassPath` 中即可使用 `Flink-Doris-Connector`。例如,`Local` 模式运行的 `Flink`,将此文件放入 `jars/` 文件夹下。`Yarn`集群模式运行的`Flink`,则将此文件放入预部署包中。 +编译成功后,会在 `output/` 目录下生成文件 `doris-flink-1.0.0-SNAPSHOT.jar`。将此文件复制到 `Flink` 的 `ClassPath` 中即可使用 `Flink-Doris-Connector`。例如,`Local` 模式运行的 `Flink`,将此文件放入 `jars/` 文件夹下。`Yarn`集群模式运行的`Flink`,则将此文件放入预部署包中。: + +**备注:** + +1. doris FE 要在配置中配置启用http v2 +2. Scala版本目前只支持2.12.x版本 + +conf/fe.conf + +``` +enable_http_server_v2 = true +``` + + ## 使用示例 此步骤的目的是在Flink上注册Doris数据源。