You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2015/11/18 17:12:13 UTC
flink git commit: [doc] Fix JavaDoc of ElasticsearchSink
Repository: flink
Updated Branches:
refs/heads/master b1cf626d8 -> 1f45c8734
[doc] Fix JavaDoc of ElasticsearchSink
This closes #1367.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1f45c873
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1f45c873
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1f45c873
Branch: refs/heads/master
Commit: 1f45c87340e7da1f7896919434575e01e84c82a2
Parents: b1cf626
Author: Martin Liesenberg <ma...@gmail.com>
Authored: Tue Nov 17 13:47:20 2015 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Nov 18 17:11:51 2015 +0100
----------------------------------------------------------------------
.../streaming/connectors/elasticsearch/ElasticsearchSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/1f45c873/flink-streaming-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java
----------------------------------------------------------------------
diff --git a/flink-streaming-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java b/flink-streaming-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java
index 546ec8d..ac14ade 100644
--- a/flink-streaming-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java
+++ b/flink-streaming-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java
@@ -54,7 +54,7 @@ import static org.elasticsearch.node.NodeBuilder.nodeBuilder;
* When using the first constructor {@link #ElasticsearchSink(java.util.Map, IndexRequestBuilder)}
* the sink will create a local {@link Node} for communicating with the
* Elasticsearch cluster. When using the second constructor
- * {@link #ElasticsearchSink(java.util.Map, IndexRequestBuilder)} a {@link TransportClient} will
+ * {@link #ElasticsearchSink(java.util.Map, java.util.List, IndexRequestBuilder)} a {@link TransportClient} will
* be used instead.
*
* <p>