You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/10/07 17:57:16 UTC

[flink] branch master updated: [FLINK-13524][es][docs] Fix typo

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

chesnay 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 2e3e27b  [FLINK-13524][es][docs] Fix typo
2e3e27b is described below

commit 2e3e27b14be22083c159fea788355698a0338864
Author: Alberto Romero <al...@humn.ai>
AuthorDate: Mon Oct 7 18:56:52 2019 +0100

    [FLINK-13524][es][docs] Fix typo
---
 docs/dev/connectors/elasticsearch.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/dev/connectors/elasticsearch.md b/docs/dev/connectors/elasticsearch.md
index c306bdb..45b0419 100644
--- a/docs/dev/connectors/elasticsearch.md
+++ b/docs/dev/connectors/elasticsearch.md
@@ -247,7 +247,7 @@ val httpHosts = new java.util.ArrayList[HttpHost]
 httpHosts.add(new HttpHost("127.0.0.1", 9200, "http"))
 httpHosts.add(new HttpHost("10.2.3.1", 9200, "http"))
 
-val esSinkBuilder = new ElasticsearchSink.Builer[String](
+val esSinkBuilder = new ElasticsearchSink.Builder[String](
   httpHosts,
   new ElasticsearchSinkFunction[String] {
     def createIndexRequest(element: String): IndexRequest = {