Does Flink opensearch connector working with Opensearch 2.x? I was trying to build the lib locally by updating the

opensearch

version, and the compiling process failed. https://github.com/apache/flink-connector-opensearch/blob/main/flink-connector-opensearch/pom.xml#L39

I was able to build the opensearch connector on opensearch 2.7.0. I built a Uber JAR file for Pyfkink but basically it should work for others - https://github.com/jaehyeon-kim/flink-demos/blob/master/real-time-streaming-aws/package/lab4-pipeline/pom.xml#L84

Cool. Thanks. There were some breaking changes in the

Opensearch

2.11 release. As a result, additional changes are required for

opensearch-flink-connector

to use that version. I ended up doing that things are working for me.

Can you share it or raise dummy pr in the repo