Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5761#discussion_r188007998 --- Diff: flink-end-to-end-tests/flink-elasticsearch1-test/src/main/java/org/apache/flink/elasticsearch1/test/Elasticsearch1SinkExample.java --- @@ -37,20 +38,33 @@ import java.util.Map; /** - * This example shows how to use the Elasticsearch Sink. Before running it you must ensure that - * you have a cluster named "elasticsearch" running or change the cluster name in the config map. + * End to end test for Elasticsearch1Sink. + * + * <p>This example shows how to use the Elasticsearch1 Sink from an user endpoint. Before running it you + * must ensure that you have a cluster named "elasticsearch" running or change the cluster name in the config map. --- End diff -- Will delete.
---