This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 392a977 [doc] Update documentation configuration parameter
`sink.batch.bytes` in flink-doris-connector (#8369)
392a977 is described below
commit 392a9774af584a230f041a756eca293a79b89460
Author: Jiangqiao Xu <[email protected]>
AuthorDate: Sun Mar 13 20:53:50 2022 +0800
[doc] Update documentation configuration parameter `sink.batch.bytes` in
flink-doris-connector (#8369)
---
docs/en/extending-doris/flink-doris-connector.md | 2 +-
docs/zh-CN/extending-doris/flink-doris-connector.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/en/extending-doris/flink-doris-connector.md
b/docs/en/extending-doris/flink-doris-connector.md
index c52ea50..823cdbc 100644
--- a/docs/en/extending-doris/flink-doris-connector.md
+++ b/docs/en/extending-doris/flink-doris-connector.md
@@ -302,7 +302,7 @@ outputFormat.close();
| sink.batch.interval | 10s | The flush
interval, after which the asynchronous thread will write the data in the cache
to BE. The default value is 10 second, and the time units are ms, s, min, h,
and d. Set to 0 to turn off periodic writing. |
| sink.properties.* | -- | The stream load parameters.<br />
<br /> eg:<br /> sink.properties.column_separator' = ','<br /> <br /> Setting
'sink.properties.escape_delimiters' = 'true' if you want to use a control char
as a separator, so that such as '\\x01' will translate to binary 0x01<br /><br
/> Support JSON format import, you need to enable both
'sink.properties.format' ='json' and 'sink.properties.strip_outer_array'
='true'|
| sink.enable-delete | true | Whether to enable deletion.
This option requires Doris table to enable batch delete function (0.15+ version
is enabled by default), and only supports Uniq model.|
-
+| sink.batch.bytes | 10485760 | Maximum bytes
of batch in a single write to BE. When the data size in batch exceeds this
threshold, cache data is written to BE. The default value is 10MB |
## Doris & Flink Column Type Mapping
diff --git a/docs/zh-CN/extending-doris/flink-doris-connector.md
b/docs/zh-CN/extending-doris/flink-doris-connector.md
index 7549fcb..fd3aca7 100644
--- a/docs/zh-CN/extending-doris/flink-doris-connector.md
+++ b/docs/zh-CN/extending-doris/flink-doris-connector.md
@@ -306,7 +306,7 @@ outputFormat.close();
| sink.batch.interval | 10s | flush 间隔时间，超过该时间后异步线程将
缓存中数据写入BE。 默认值为10秒，支持时间单位ms、s、min、h和d。设置为0表示关闭定期写入。 |
| sink.properties.* | -- | Stream load 的导入参数<br /><br
/>例如:<br />'sink.properties.column_separator' = ', '<br />定义列分隔符<br /><br
/>'sink.properties.escape_delimiters' = 'true'<br
/>特殊字符作为分隔符,'\\x01'会被转换为二进制的0x01<br /><br /> 'sink.properties.format' =
'json'<br />'sink.properties.strip_outer_array' = 'true' <br />JSON格式导入|
| sink.enable-delete | true |
是否启用删除。此选项需要Doris表开启批量删除功能(0.15+版本默认开启)，只支持Uniq模型。|
-
+| sink.batch.bytes | 10485760 | 单次写BE的最大数据量，当每个 batch
中记录的数据量超过该阈值时，会将缓存数据写入 BE。默认值为 10MB |
## Doris 和 Flink 列类型映射关系
| Doris Type | Flink Type |
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
