This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
The following commit(s) were added to refs/heads/main by this push:
new f19a471 [hotfix] Fix typo in ElasticsearchEmitter
f19a471 is described below
commit f19a4716aaff363520421dc901dcf79565c29bc4
Author: beliefer <[email protected]>
AuthorDate: Wed May 21 15:41:49 2025 +0800
[hotfix] Fix typo in ElasticsearchEmitter
---
.../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.
*
