You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/01/07 13:33:11 UTC
[flink] 05/05: [hotfix] [doc] Fix incorrect http port in
Elasticsearch 6.x Scala doc
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3d5b6b166202c423b1529316bb9a9a755628ae1a
Author: lamber-ken <22...@qq.com>
AuthorDate: Tue Dec 25 23:24:08 2018 +0800
[hotfix] [doc] Fix incorrect http port in Elasticsearch 6.x Scala doc
This closes #7361.
---
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 de24149..d0a159b 100644
--- a/docs/dev/connectors/elasticsearch.md
+++ b/docs/dev/connectors/elasticsearch.md
@@ -340,8 +340,8 @@ import java.util.List
val input: DataStream[String] = ...
val httpHosts = new java.util.ArrayList[HttpHost]
-httpHosts.add(new HttpHost("127.0.0.1", 9300, "http"))
-httpHosts.add(new HttpHost("10.2.3.1", 9300, "http"))
+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](
httpHosts,