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

["LuNing Wang (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563197#comment-17563197 ] 

LuNing Wang commented on FLINK-28428:
-------------------------------------

I will fix this.

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