Il est possible d'exécuter un Elasticsearch 5.x avec Flink 1.2.0?

Question

Il est possible d'exécuter elasticsearch version 5.x dans Apache Flink 1.2.0? Je ne peux pas mettre à jour mon Flink vers 1.3 parce que j'ai besoin de la version 1.2.0 pour lancer kafka.

par ce qu'il est dit dans ce lien: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/elasticsearch.html

Flink-connecteur-elasticsearch5_2.10 (pris en charge depuis) ​​1.2.0 (version ElasticSearch) 5.x

Ce connecteur devrait fonctionner (depuis ma version Flink c'est 1.2.0), mais quand je l'exécute ça ne marche pas.

Dois-je installer Elasticsearch 2.x ou existe-t-il un autre moyen de le faire fonctionner?

Merci.

Answer 1

La documentation était incorrecte et a été mise à jour pour refléter le fait que le support pour Elasticsearch 5.x a été ajouté à Flink après 1.2 - c'est-à-dire qu'il est actuellement dans Flink 1.3-SNAPSHOT.