| commit | 75c377308d3613d9810125de7753f771db0ecb14 | [log] [tgz] |
|---|---|---|
| author | Jie Wang <jie.wang@hulu.com> | Tue Dec 22 22:42:30 2020 +0800 |
| committer | MartijnVisser <martijn@2symbols.com> | Mon Apr 04 15:45:43 2022 +0200 |
| tree | e8e42d380e52721ece32dd259bf7fb3f52deb482 | |
| parent | 171d7f488be46dab887baf6f928ca8b636cd9743 [diff] |
[FLINK-20711][docs] Fix failure-handler parameter enumeration value typo in ES connector doc This closes #14467
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 @@ 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());