LuNing Wang created FLINK-28428:
-----------------------------------
Summary: Example in the Elasticsearch doc of fault tolerance
section is missing
Key: FLINK-28428
URL: https://issues.apache.org/jira/browse/FLINK-28428
Project: Flink
Issue Type: Improvement
Components: Connectors / ElasticSearch, Documentation
Affects Versions: 1.15.1
Reporter: LuNing Wang
Fix For: 1.16.0
The example in English doc
{code:java}
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000); // checkpoint every 5000 msecs{code}
The example in Chinese doc
{code:java}
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000); // 每 5000 毫秒执行一次 checkpoint
Elasticsearch6SinkBuilder sinkBuilder = new Elasticsearch6SinkBuilder<String>()
.setDeliveryGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
.setHosts(new HttpHost("127.0.0.1", 9200, "http"))
.setEmitter(
(element, context, indexer) ->
indexer.add(createIndexRequest(element))); {code}
IMO, the example in Chinese doc is correct.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
