[flink] branch master updated: [FLINK-20711][docs] Fix failure-handler parameter enumeration value typo in ES connector doc

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new fd448ef  [FLINK-20711][docs] Fix failure-handler parameter enumeration 
value typo in ES connector doc
fd448ef is described below

commit fd448ef1e175d01bcc2e8867372fb0721c53f4cf
Author: Jie Wang <jie.w...@hulu.com>
AuthorDate: Tue Dec 22 22:42:30 2020 +0800

    [FLINK-20711][docs] Fix failure-handler parameter enumeration value typo in 
ES connector doc
    
    This closes #14467
---
 docs/dev/table/connectors/elasticsearch.md                              | 2 +-
 docs/dev/table/connectors/elasticsearch.zh.md                           | 2 +-
 .../streaming/connectors/elasticsearch/table/ElasticsearchOptions.java  | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/docs/dev/table/connectors/elasticsearch.md 
b/docs/dev/table/connectors/elasticsearch.md
index c7cabaf..07eb115 100644
--- a/docs/dev/table/connectors/elasticsearch.md
+++ b/docs/dev/table/connectors/elasticsearch.md
@@ -147,7 +147,7 @@ Connector Options
       <ul>
         <li><code>fail</code>: throws an exception if a request fails and thus 
causes a job failure.</li>
         <li><code>ignore</code>: ignores failures and drops the request.</li>
-        <li><code>retry_rejected</code>: re-adds requests that have failed due 
to queue capacity saturation.</li>
+        <li><code>retry-rejected</code>: re-adds requests that have failed due 
to queue capacity saturation.</li>
         <li>custom class name: for failure handling with a 
ActionRequestFailureHandler subclass.</li>
       </ul>
       </td>
diff --git a/docs/dev/table/connectors/elasticsearch.zh.md 
b/docs/dev/table/connectors/elasticsearch.zh.md
index 37bc50c..a91264f 100644
--- a/docs/dev/table/connectors/elasticsearch.zh.md
+++ b/docs/dev/table/connectors/elasticsearch.zh.md
@@ -147,7 +147,7 @@ Connector Options
       <ul>
         <li><code>fail</code>: throws an exception if a request fails and thus 
causes a job failure.</li>
         <li><code>ignore</code>: ignores failures and drops the request.</li>
-        <li><code>retry_rejected</code>: re-adds requests that have failed due 
to queue capacity saturation.</li>
+        <li><code>retry-rejected</code>: re-adds requests that have failed due 
to queue capacity saturation.</li>
         <li>custom class name: for failure handling with a 
ActionRequestFailureHandler subclass.</li>
       </ul>
       </td>
diff --git 
a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java
 
b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java
index 7f437f9..c40b94c 100644
--- 
a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java
+++ 
b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java
@@ -89,7 +89,7 @@ public class ElasticsearchOptions {
                                             text(
                                                     "\"ignore\" (ignores 
failures and drops the request),"),
                                             text(
-                                                    "\"retry_rejected\" 
(re-adds requests that have failed due to queue capacity saturation),"),
+                                                    "\"retry-rejected\" 
(re-adds requests that have failed due to queue capacity saturation),"),
                                             text(
                                                     "\"class name\" for 
failure handling with a ActionRequestFailureHandler subclass"))
                                     .build());