Re: ElasticSearch Connector for version 6.x and scala 2.11

Actually, Flink's netty dependency (4.0.27) is shaded away into the "org.apache.flink.shaded.netty4.io.netty" package now (since version 1.4) and should thus not clash anymore. However, other netty versions may come into play from the job itself or from the integration of Hadoop's classpath (if

Re: ElasticSearch Connector for version 6.x and scala 2.11

Hi A workmate of mine tried to migrate the existing flink connector to ElasticSearch 6 but we had problems with netty dependencies that clashed (Flink uses 4.0.27 and ES is on 4.1). You can change the flink-connector-elasticsearch5 connector to ES 5.6.4, but then you have to do some adaptions to

Re: ElasticSearch Connector for version 6.x and scala 2.11

Hi Rahul, Flink does not provide a connector for ElasticSearch 6 yet. There is this JIRA issue to track the development progress [1]. Best, Fabian [1] https://issues.apache.org/jira/browse/FLINK-8101 2017-12-01 7:22 GMT+01:00 Rahul Raj : > Hi All, > > Is there a Flink

ElasticSearch Connector for version 6.x and scala 2.11

Hi All, Is there a Flink Elastic search connector for version 6.0 and scala 2.11? I couldn't find it listed here https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/elasticsearch.html . Regards, Rahul Raj