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 = {