Unsubscribe On Mon, Oct 6, 2025 at 2:45 AM Poorvank Bhatia <[email protected]> wrote:
> 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 >> >
