This is an automated email from the ASF dual-hosted git repository.
yuxiqian 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 7963beafe [FLINK-40514][docs] Add missing Doris pipeline connector
options (#4561)
7963beafe is described below
commit 7963beafecb6893618be131815daab3c355a9f88
Author: suntectec <[email protected]>
AuthorDate: Mon Sep 28 15:12:35 2026 +0800
[FLINK-40514][docs] Add missing Doris pipeline connector options (#4561)
---
.../docs/connectors/pipeline-connectors/doris.md | 48 ++++++++++++++++++--
.../docs/connectors/pipeline-connectors/doris.md | 51 +++++++++++++++++++---
2 files changed, 91 insertions(+), 8 deletions(-)
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/doris.md
b/docs/content.zh/docs/connectors/pipeline-connectors/doris.md
index c6aa86121..09fec1b6b 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/doris.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/doris.md
@@ -116,14 +116,14 @@ pipeline:
<td>auto-redirect</td>
<td>optional</td>
<td style="word-wrap: break-word;">false</td>
- <td>String</td>
+ <td>Boolean</td>
<td> 是否通过FE重定向写入，直连BE写入 </td>
</tr>
<tr>
<td>charset-encoding</td>
<td>optional</td>
- <td style="word-wrap: break-word;">false</td>
- <td>Boolean</td>
+ <td style="word-wrap: break-word;">UTF-8</td>
+ <td>String</td>
<td> Doris Http客户端字符集编码，默认UTF-8 </td>
</tr>
<tr>
@@ -183,6 +183,48 @@ pipeline:
<td>Boolean</td>
<td>在CDC场景中，当上游的主键与下游的主键不一致时，需要将 update-before
数据作为已删除数据传递给下游，否则数据将无法被删除。默认设置为忽略，即执行 upsert 语义 </td>
</tr>
+ <tr>
+ <td>sink.enable-2pc</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">false</td>
+ <td>Boolean</td>
+ <td>是否在导入数据时启用两阶段提交（2PC）</td>
+ </tr>
+ <tr>
+ <td>sink.check-interval</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">10000</td>
+ <td>Integer</td>
+ <td>导入过程中检查异常的间隔（毫秒）</td>
+ </tr>
+ <tr>
+ <td>sink.buffer-size</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">1048576(1MB)</td>
+ <td>Integer</td>
+ <td>Stream Load 缓存数据的缓冲区大小（字节）</td>
+ </tr>
+ <tr>
+ <td>sink.buffer-count</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">3</td>
+ <td>Integer</td>
+ <td>Stream Load 缓存数据的缓冲区数量</td>
+ </tr>
+ <tr>
+ <td>sink.label-prefix</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>Stream Load 的唯一 label 前缀</td>
+ </tr>
+ <tr>
+ <td>sink.use-cache</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">false</td>
+ <td>Boolean</td>
+ <td>是否为断点续传使用缓冲区缓存</td>
+ </tr>
<tr>
<td>sink.properties.</td>
<td>optional</td>
diff --git a/docs/content/docs/connectors/pipeline-connectors/doris.md
b/docs/content/docs/connectors/pipeline-connectors/doris.md
index 7b3df7e5f..1bd465975 100644
--- a/docs/content/docs/connectors/pipeline-connectors/doris.md
+++ b/docs/content/docs/connectors/pipeline-connectors/doris.md
@@ -116,14 +116,14 @@ pipeline:
<td>auto-redirect</td>
<td>optional</td>
<td style="word-wrap: break-word;">false</td>
- <td>String</td>
+ <td>Boolean</td>
<td> Whether to write through FE redirection and directly connect to BE
to write </td>
</tr>
<tr>
<td>charset-encoding</td>
<td>optional</td>
- <td style="word-wrap: break-word;">false</td>
- <td>Boolean</td>
+ <td style="word-wrap: break-word;">UTF-8</td>
+ <td>String</td>
<td> Charset encoding for doris http client, default UTF-8 </td>
</tr>
<tr>
@@ -181,8 +181,49 @@ pipeline:
<td>optional</td>
<td style="word-wrap: break-word;">true</td>
<td>Boolean</td>
- <td>In the CDC scenario, when the primary key of the upstream is
inconsistent with that of the downstream, the update-before data needs to be
passed to the downstream as deleted data, otherwise the data cannot be
deleted.\n"
- + "The default is to ignore, that is,
perform upsert semantics.</td>
+ <td>In the CDC scenario, when the primary key of the upstream is
inconsistent with that of the downstream, the update-before data needs to be
passed to the downstream as deleted data, otherwise the data cannot be deleted.
The default is to ignore, that is, perform upsert semantics.</td>
+ </tr>
+ <tr>
+ <td>sink.enable-2pc</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">false</td>
+ <td>Boolean</td>
+ <td>Enable 2PC while loading</td>
+ </tr>
+ <tr>
+ <td>sink.check-interval</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">10000</td>
+ <td>Integer</td>
+ <td>Check exception with the interval (in milliseconds) while
loading</td>
+ </tr>
+ <tr>
+ <td>sink.buffer-size</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">1048576(1MB)</td>
+ <td>Integer</td>
+ <td>The buffer size (in bytes) to cache data for stream load</td>
+ </tr>
+ <tr>
+ <td>sink.buffer-count</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">3</td>
+ <td>Integer</td>
+ <td>The buffer count to cache data for stream load</td>
+ </tr>
+ <tr>
+ <td>sink.label-prefix</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>The unique label prefix used for stream load</td>
+ </tr>
+ <tr>
+ <td>sink.use-cache</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">false</td>
+ <td>Boolean</td>
+ <td>Whether to use buffer cache for breakpoint resume</td>
</tr>
<tr>
<td>sink.properties.</td>
