From 7a7d41bdbd081e59bb40a193e81ec13aec386b06 Mon Sep 17 00:00:00 2001 From: beliefer Date: Wed, 21 May 2025 15:41:49 +0800 Subject: [PATCH] [hotfix] Fix typo in ElasticsearchEmitter --- .../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 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. *