[
https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-28428:
----------------------------
Fix Version/s: 1.19.0
(was: 1.18.0)
> 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
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.19.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)
