diff --git a/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java b/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java index 950f8627..670eb3a0 100644 --- a/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java +++ b/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java @@ -25,7 +25,7 @@ import org.elasticsearch.action.ActionRequest; /** - * Creates none or multiple {@link ActionRequest ActionRequests} from the incoming elements. + * Creates one or multiple {@link ActionRequest ActionRequests} from the incoming elements. * *
This is used by sinks to prepare elements for sending them to Elasticsearch. *