[FLINK-9372] [elasticsearch] Typo on Elasticsearch website link This closes #6018.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c6d5af0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c6d5af0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7c6d5af0 Branch: refs/heads/release-1.5 Commit: 7c6d5af09780cb51f94a778be0e0d4b559b4256e Parents: 8224a7b Author: Yadan.JS <[email protected]> Authored: Tue May 15 18:03:22 2018 -0400 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Tue May 22 16:54:11 2018 +0800 ---------------------------------------------------------------------- .../streaming/connectors/elasticsearch/ElasticsearchSink.java | 2 +- .../streaming/connectors/elasticsearch2/ElasticsearchSink.java | 2 +- .../streaming/connectors/elasticsearch5/ElasticsearchSink.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7c6d5af0/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java index 9dd8209..e8eccd9 100644 --- a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java +++ b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java @@ -44,7 +44,7 @@ import java.util.Map; * to come online. * * <p>The {@link Map} passed to the constructor is used to create the {@link Node} or {@link TransportClient}. The config - * keys can be found in the <a href="https://www.elastic.io";>Elasticsearch documentation</a>. An important setting is + * keys can be found in the <a href="https://www.elastic.co";>Elasticsearch documentation</a>. An important setting is * {@code cluster.name}, which should be set to the name of the cluster that the sink should emit to. * * <p>Internally, the sink will use a {@link BulkProcessor} to send {@link ActionRequest ActionRequests}. http://git-wip-us.apache.org/repos/asf/flink/blob/7c6d5af0/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java index a17b4d8..ffccacf 100644 --- a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java +++ b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java @@ -38,7 +38,7 @@ import java.util.Map; * The sink will fail if no cluster can be connected to using the provided transport addresses passed to the constructor. * * <p>The {@link Map} passed to the constructor is used to create the {@code TransportClient}. The config keys can be found - * in the <a href="https://www.elastic.io";>Elasticsearch documentation</a>. An important setting is {@code cluster.name}, + * in the <a href="https://www.elastic.co";>Elasticsearch documentation</a>. An important setting is {@code cluster.name}, * which should be set to the name of the cluster that the sink should emit to. * * <p>Internally, the sink will use a {@link BulkProcessor} to send {@link ActionRequest ActionRequests}. http://git-wip-us.apache.org/repos/asf/flink/blob/7c6d5af0/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java b/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java index 3307b2c..6c09337 100644 --- a/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java +++ b/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java @@ -39,7 +39,7 @@ import java.util.Map; * The sink will fail if no cluster can be connected to using the provided transport addresses passed to the constructor. * * <p>The {@link Map} passed to the constructor is used to create the {@code TransportClient}. The config keys can be found - * in the <a href="https://www.elastic.io";>Elasticsearch documentation</a>. An important setting is {@code cluster.name}, + * in the <a href="https://www.elastic.co";>Elasticsearch documentation</a>. An important setting is {@code cluster.name}, * which should be set to the name of the cluster that the sink should emit to. * * <p>Internally, the sink will use a {@link BulkProcessor} to send {@link ActionRequest ActionRequests}.
