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

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

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)