我使用的是flink 1.9.0和flink-connector-elasticsearch6\U 2.11,但它无法连接到es 7x。
我看着https://issues.apache.org/jira/browse/flink-13025 并在本地下载了snapshot-flink-connector-elasticsearch7_2.12-1.10-snapshot.jar,使用flink-connector-elasticsearch-base_2.11-1.9.1现在可以连接到es7。
这是否还在开发中,因此还没有发布到maven central?你知道发行日期吗?
2条答案
按热度按时间kzipqqlq1#
flink-connector-elasticsearch7弹性接头
对于flink elasticsearch连接器,我使用了下面提到的以下依赖项和版本。
Flink:1.10.0
ElasticSearch:7.6.2
flink-connector-elasticsearch7弹性接头
斯卡拉:2.12.11
sbt:1.2.8
java:11.0.4版
请找出我在这里提供的详细答案。
kt06eoxx2#
支持es7的更新的elasticsearch连接器是最近发布的flink 1.10的一部分。