1

我将 Flink 1.9.0 与 flink-connector-elasticsearch6_2.11 一起使用,但这无法连接到 ES 7x。

我查看了https://issues.apache.org/jira/browse/FLINK-13025并下载了快照 - flink-connector-elasticsearch7_2.12-1.10-SNAPSHOT.jar - 本地和flink-connector-elasticsearch-base_2。 11-1.9.1现在可以连接到 ES7。

这是否仍在开发中,因此尚未发布到 Maven 中心?关于发布日期的任何想法?

4

2 回答 2

2

支持 ES7 的更新后的 Elasticsearch 连接器是最近发布的 Flink 1.10 的一部分。

于 2019-12-20T08:11:47.297 回答
1

flink-connector-elasticsearch7

对于 Flink Elasticsearch Connector,我使用了下面提到的以下依赖项和版本。

  • 弗林克:1.10.0
  • 弹性搜索:7.6.2
  • flink-connector-elasticsearch7
  • 斯卡拉:2.12.11
  • SBT:1.2.8
  • 爪哇:11.0.4

请找到我在 此处提供的详细答案。

于 2020-05-06T19:05:17.677 回答