Flink 1.2.0 可以 运行 一个 Elasticsearch 5.x 吗?

It is possible to run an Elasticsearch 5.x with Flink 1.2.0?

可以在 Apache Flink 1.2.0 中 运行 elasticsearch 版本 5.x 吗? 我无法将我的 Flink 升级到 1.3,因为我需要 1.2.0 版本到 运行 kafka。

根据link中的说法:https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/elasticsearch.html

flink-connector-elasticsearch5_2.10(支持自)1.2.0(Elasticsearch 版本)5.x

这个连接器应该可以工作(因为我的 Flink 版本是 1.2.0),但是当我 运行 它不工作。

我需要安装 Elasticsearch 2.x 还是有其他方法可以让它工作?

谢谢。

文档不正确,并且已更新以反映对 Elasticsearch 5.x 的支持在 1.2 之后添加到 Flink 中的事实——即,它目前在 Flink 1.3-SNAPSHOT 中。