Apache Flink

Hi all, I am trying to write to an OpenSearch instance using the `flink-connector-opensearch`  connector. However, it fails with the following error: `java.lang.ClassNotFoundException: org.opensearch.common.Strings` . I am unsure what is causing it, because I have been loading the `.jar`  dependency to `${FLINK_HOME}/lib` . Can anyone help me out? :slightly_smiling_face:

Nevermind, I have solved it. Turns out the required connector is actually `flink-sql-connector-opensearch` for the table API.