Hi Fabian, FYI I rebased the branch and tested it and it worked OK on a sample.
-- Christophe On Mon, Jan 22, 2018 at 2:53 PM, Fabian Hueske <fhue...@gmail.com> wrote: > Hi Adrian, > > thanks for raising this issue again. > I agree, we should add support for newer ES versions. > I've added 1.5.0 as target release for FLINK-7386 and bumped the priority > up. > > In the meantime, you can try Flavio's approach (he responded to the mail > thread you linked) and fork and fix the connector. > You could also try the PR for FLINK-7386 [1] and comment on the pull > request whether it works for you or not. > > Best, Fabian > > [1] https://github.com/apache/flink/pull/4675 > > > 2018-01-22 13:54 GMT+01:00 Adrian Vasiliu <vasi...@fr.ibm.com>: > >> Hello, >> >> With a local run of Flink 1.4.0, ElasticsearchSink fails for me with a >> local run of Elasticsearch 5.6.4 and 5.2.1, while the same code (with >> adjusted versions of dependencies) works fine with Elasticsearch 2.x (tried >> 2.4.6). >> I get: >> java.lang.NoSuchMethodError: org.elasticsearch.action.bulk. >> BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;) >> Lorg/elasticsearch/action/bulk/BulkProcessor >> >> (env: Mac OSX 10.13.2, oracle jdk 1.8.0_112) >> >> Now, this looks similar to the issue referred in >> http://apache-flink-user-mailing-list-archive.2336050.n4. >> nabble.com/Elasticsearch-Sink-Error-td15246.html >> which points to >> "Flink Elasticsearch 5 connector is not compatible with Elasticsearch >> 5.2+ client" >> https://issues.apache.org/jira/browse/FLINK-7386 >> >> Side-remark: when trying with Elasticsearch 5.6.4 via a docker container, >> for some reason the error I get is different: "RuntimeException: Client is >> not connected to any Elasticsearch nodes!" (while Elasticsearch 2.4.6 works >> fine via docker too). >> >> FLINK-7386 <https://issues.apache.org/jira/browse/FLINK-7386> being >> pending since August 2017, would it mean that there is nowadays still no >> way to make Flink 1.4.0's sink work with Elasticsearch 5.2+? My use-case >> involves Compose for Elasticsearch 5.6.3, shared by different apps, and I >> can't really downgrade its Elasticsearch version. >> Or would there be signs it will be fixed in Flink 1.5.0? >> >> Any lights welcome. >> >> Thanks, >> Adrian >> >> >> Sauf indication contraire ci-dessus:/ Unless stated otherwise above: >> Compagnie IBM France >> Siège Social : 17 avenue de l'Europe >> <https://maps.google.com/?q=17+avenue+de+l'Europe&entry=gmail&source=g>, >> 92275 Bois-Colombes Cedex >> RCS Nanterre 552 118 465 >> Forme Sociale : S.A.S. >> Capital Social : 657.364.587 € >> SIREN/SIRET : 552 118 465 03644 - Code NAF 6202A >> > >
