[FLINK-28428] Example in the Elasticsearch doc of fault tolerance section is missing

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.15.1
• Fix Version/s: 1.20.0
• Component/s: Connectors / ElasticSearch, Documentation
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Luning Wang
• Created: 06/Jul/22 12:18
• Updated: 11/Mar/24 12:44

Description

The example in English doc 

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000); // checkpoint every 5000 msecs

 

The example in Chinese doc

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))); 

IMO, the example in Chinese doc is correct.

Issue Links

• links to: GitHub Pull Request #23