You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/04/25 11:52:33 UTC
[flink-connector-elasticsearch] 10/21: [FLINK-25141][docs] Add es sink parallelism option
This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
commit 22e938bdce224645ea07072827a6ff086a8159ad
Author: Ada Wong <rs...@foxmail.com>
AuthorDate: Thu Jan 6 19:36:14 2022 +0800
[FLINK-25141][docs] Add es sink parallelism option
---
docs/content.zh/docs/connectors/table/elasticsearch.md | 7 +++++++
docs/content/docs/connectors/table/elasticsearch.md | 7 +++++++
2 files changed, 14 insertions(+)
diff --git a/docs/content.zh/docs/connectors/table/elasticsearch.md b/docs/content.zh/docs/connectors/table/elasticsearch.md
index 061ca27..b04a922 100644
--- a/docs/content.zh/docs/connectors/table/elasticsearch.md
+++ b/docs/content.zh/docs/connectors/table/elasticsearch.md
@@ -203,6 +203,13 @@ CREATE TABLE myUserTable (
<td>Duration</td>
<td>每次回退尝试之间的延迟。对于 <code>CONSTANT</code> 回退策略，该值是每次重试之间的延迟。对于 <code>EXPONENTIAL</code> 回退策略，该值是初始的延迟。</td>
</tr>
+ <tr>
+ <td><h5>sink.parallelism</h5></td>
+ <td>可选</td>
+ <td style="word-wrap: break-word;">（无）</td>
+ <td>Integer</td>
+ <td>定义 Elasticsearch sink 算子的并行度。默认情况下，并行度由框架定义为与上游串联的算子相同。</td>
+ </tr>
<tr>
<td><h5>connection.max-retry-timeout</h5></td>
<td>可选</td>
diff --git a/docs/content/docs/connectors/table/elasticsearch.md b/docs/content/docs/connectors/table/elasticsearch.md
index 0879f41..22f0b60 100644
--- a/docs/content/docs/connectors/table/elasticsearch.md
+++ b/docs/content/docs/connectors/table/elasticsearch.md
@@ -190,6 +190,13 @@ Connector Options
<td>Duration</td>
<td>Delay between each backoff attempt. For <code>CONSTANT</code> backoff, this is simply the delay between each retry. For <code>EXPONENTIAL</code> backoff, this is the initial base delay.</td>
</tr>
+ <tr>
+ <td><h5>sink.parallelism</h5></td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>Integer</td>
+ <td>Defines the parallelism of the Elasticsearch sink operator. By default, the parallelism is determined by the framework using the same parallelism of the upstream chained operator.</td>
+ </tr>
<tr>
<td><h5>connection.path-prefix</h5></td>
<td>optional</td>