Skip to content

Commit

Permalink
[Doc]Modify the flink connector document's instructions on enabling h…
Browse files Browse the repository at this point in the history
…ttp v2 (#5883)

[doc]Modify the flink connector document's instructions on enabling http v2
  • Loading branch information
hf200012 authored May 26, 2021
1 parent 629e440 commit fc13892
Show file tree
Hide file tree
Showing 2 changed files with 26 additions and 1 deletion.
12 changes: 12 additions & 0 deletions docs/en/extending-doris/flink-doris-connector.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
15 changes: 14 additions & 1 deletion docs/zh-CN/extending-doris/flink-doris-connector.md
Original file line number Diff line number Diff line change
Expand Up @@ -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数据源。
Expand Down

0 comments on commit fc13892

Please sign in to comment.