This is an automated email from the ASF dual-hosted git repository. reswqa pushed a commit to branch v4.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
commit d2e1a5e06ecfd721cf470eb99678219c9703bc42 Author: beliefer <[email protected]> AuthorDate: Wed May 21 15:41:49 2025 +0800 [hotfix] Fix typo in ElasticsearchEmitter (cherry picked from commit f19a4716aaff363520421dc901dcf79565c29bc4) --- .../apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 950f862..670eb3a 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.apache.flink.api.connector.sink2.SinkWriter; 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. * * <p>This is used by sinks to prepare elements for sending them to Elasticsearch. *
