是否可以在ApacheFlink1.2.0中运行ElasticSearchVersion5.x?我无法将flink升级到1.3,因为我需要1.2.0版本来运行kafka。
根据这个链接中的说法:https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/elasticsearch.html
flink-connector-elasticsearch5\ U 2.10(自1.2.0(elasticsearch版本)5.x起支持
这个连接器应该可以工作(因为我的flink版本是1.2.0),但是当我运行它时它就不工作了。
我需要安装elasticsearch 2.x还是有其他方法可以让它工作?
谢谢。
1条答案
按热度按时间b1zrtrql1#
文档不正确,并且已经更新以反映这样一个事实:对elasticsearch 5.x的支持是在flink 1.2之后添加到flink中的,也就是说,它目前在flink 1.3-snapshot中。