Reputation: 105
I was using Flink 1.9.0 with flink-connector-elasticsearch6_2.11, but this cannot connect to ES 7x.
I looked at https://issues.apache.org/jira/browse/FLINK-13025 and downloaded the snapshot - flink-connector-elasticsearch7_2.12-1.10-SNAPSHOT.jar - locally and with flink-connector-elasticsearch-base_2.11-1.9.1 can now connect to ES7.
Is this still in dev and hence not released to maven central yet? Any idea regarding the release date?
Upvotes: 1
Views: 1071
Reputation: 3182
flink-connector-elasticsearch7
For Flink Elasticsearch Connector I have used the following dependencies and versions mentioned below.
Please find a detailed answer which I have provided here.
Upvotes: 1
Reputation: 43717
An updated Elasticsearch connector that supports ES7 is part of Flink 1.10, which was recently released.
Upvotes: 2