Можно запустить Elasticsearch 5.x с Flink 1.2.0?

Question

Возможно ли запустить версию elasticsearch версии 5.x в Apache Flink 1.2.0? Я не могу обновить свой Flink до 1.3, потому что мне нужна версия 1.2.0 для запуска kafka.

тем, что говорится в этой ссылке: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/elasticsearch.html

Flink-разъем-elasticsearch5_2.10 (Поддерживается, начиная с) 1.2.0 (Elasticsearch версия) 5.x

Этот разъем должен работать (так что моя версия Flink - 1.2.0), но когда я запускаю ее, она не работает.

Нужно ли устанавливать Elasticsearch 2.x или есть какой-то другой способ заставить его работать?

Спасибо.

Answer 1

Документация была неверна и была обновлена, чтобы отразить тот факт, что поддержка Elasticsearch 5.x была добавлена ​​в Flink после 1.2 - то есть в настоящее время она включена в Flink 1.3-SNAPSHOT.