[flink] branch master updated: [hotfix] [docs] Fix typo in Elasticsearch example

[twalthr]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new e91b2d5  [hotfix] [docs] Fix typo in Elasticsearch example
e91b2d5 is described below

commit e91b2d579085315e4f7b09f7a0c25886b5acc406
Author: Timo Walther <twal...@apache.org>
AuthorDate: Wed Aug 15 13:54:03 2018 +0200

    [hotfix] [docs] Fix typo in Elasticsearch example
---
 docs/dev/connectors/elasticsearch.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/dev/connectors/elasticsearch.md 
b/docs/dev/connectors/elasticsearch.md
index bafe391..927bb69 100644
--- a/docs/dev/connectors/elasticsearch.md
+++ b/docs/dev/connectors/elasticsearch.md
@@ -223,7 +223,7 @@ ElasticsearchSink.Builder<String> esSinkBuilder = new 
ElasticsearchSink.Builder<
 builder.setBulkFlushMaxActions(1);
 
 // provide a RestClientFactory for custom configuration on the internally 
created REST client
-builder.setRestClientBuilder(
+builder.setRestClientFactory(
   restClientBuilder -> {
     restClientBuilder.setDefaultHeaders(...)
     restClientBuilder.setMaxRetryTimeoutMillis(...)
@@ -360,7 +360,7 @@ val esSinkBuilder = new ElasticsearchSink.Builer[String](
 builder.setBulkFlushMaxActions(1)
 
 // provide a RestClientFactory for custom configuration on the internally 
created REST client
-builder.setRestClientBuilder(
+builder.setRestClientFactory(
   restClientBuilder -> {
     restClientBuilder.setDefaultHeaders(...)
     restClientBuilder.setMaxRetryTimeoutMillis(...)