Great, thank you! Hopefully, this pushes the PR forward. Thanks, Fabian
2018-01-25 22:30 GMT+01:00 Christophe Jolif <cjo...@gmail.com>: > 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;)L >>> org/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.nab >>> ble.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 >>> >> >> > >
