The problem is that BulkProcessorIndexer is located in
flink-connector-elasticsearch-base which is compiled against a very old
ES version. This old version is source code compatible but apparently
not binary compatible with newer Elasticsearch classes. By copying this
class you force to compile the class against ES 6 and don't use the old
class in the base module.
The fix will include to improve the API call bridge. As done here [1].
Regards,
Timo
[1] https://github.com/apache/flink/pull/6611
Am 31.08.18 um 09:06 schrieb Averell:
Hi Timo,
Thanks for your help. I don't get that error anymore after putting that file
into my project.
However, I don't understand how it could help. I have been using the Flink
binary built on my same laptop, then how could it be different between
having that java class in Flink project vs in my project?
If you have some spare time, please help explain.
I also would like to know the other way to fix that issue (that you
implemented in your branch).
Thanks a lot for your help.
Regards,
Averell
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
