Flink SQL Opensearch

[Mathew Macdonald]

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