(flink-connector-elasticsearch) branch main updated: [hotfix] Fix checkNotNull for Elasticsearch8AsyncSinkBuilder#setHeaders

[guoweijie]

This is an automated email from the ASF dual-hosted git repository.

reswqa 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 a09a31a  [hotfix] Fix checkNotNull for 
Elasticsearch8AsyncSinkBuilder#setHeaders
a09a31a is described below

commit a09a31a6c2c63fae519403248afe3440562db1fc
Author: reswqa <res...@163.com>
AuthorDate: Wed May 20 15:08:44 2026 +0800

    [hotfix] Fix checkNotNull for Elasticsearch8AsyncSinkBuilder#setHeaders
---
 .../connector/elasticsearch/sink/Elasticsearch8AsyncSinkBuilder.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncSinkBuilder.java
 
b/flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncSinkBuilder.java
index 2e8dc9a..cac2ac4 100644
--- 
a/flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncSinkBuilder.java
+++ 
b/flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncSinkBuilder.java
@@ -136,7 +136,7 @@ public class Elasticsearch8AsyncSinkBuilder<InputT>
      * @return {@code Elasticsearch8AsyncSinkBuilder}
      */
     public Elasticsearch8AsyncSinkBuilder<InputT> setHeaders(Header... 
headers) {
-        checkNotNull(hosts);
+        checkNotNull(headers);
         checkArgument(headers.length > 0, "Headers cannot be empty");
         this.headers = Arrays.asList(headers);
         return this;