Hi Mathew, Are you using it locally? I am not sure but it looks like the *allow-insecure* option configures SSL to trust all certificates but looks like it doesn't disable hostname verification <https://github.com/apache/flink-connector-opensearch/blob/main/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java#L89>, that might cause the OpenSearch client to access uninitialized SSL.
Can you try and use *http://localhost:9200 <http://localhost:9200>* instead of *https://localhost:9200 <https://localhost:9200>* and remove the allow-insecure option. On Fri, Oct 3, 2025 at 10:32 PM Mathew Macdonald <[email protected]> wrote: > Hi all, > > Running Flink 1.18.0 and running the compatible Opensearch Connector > causes the following error: > > Caused by: java.lang.NullPointerException > at > org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.arrayToParsableString(Setting.java:2373) > > Creating a simple sink index and inserting a row causes the above. It > suggests a setting is not being provided. Sink table below: > > CREATE TABLE myUserTable ( > user_id STRING, > user_name STRING, > uv BIGINT, > pv BIGINT, > PRIMARY KEY (user_id) NOT ENFORCED > ) WITH ( > 'connector' = 'opensearch', > 'hosts' = 'https://localhost:9200', > 'username' = 'admin', > 'password' = 'admin', > 'allow-insecure' = 'true', > 'index' = 'users' > ); > > Any advice? Been stuck on this for the past 2 days. Thanks in advance. > > Kind Regards, > Mathew >
