Re: Exception using flink-connector-elasticsearch

Hi, Thanks Aljoscha, the libraries solved the problem. It worked perfectly!. On 12 January 2016 at 14:03, Aljoscha Krettek wrote: > Hi, > could you please try adding the lucene-core-4.10.4.jar file to your lib > folder of Flink. ( >

Exception using flink-connector-elasticsearch

Hi, We are using the sink for ElasticSearch and when we try to run our job we get the following exception: java.lang.ExceptionInInitializerError Caused by: java.lang.IllegalArgumentException: An SPI class of type org.apache.lucene.codecs.Codec with name 'Lucene410' does not exist. You need to

Re: Exception using flink-connector-elasticsearch

Hi Javier, it seems as if you either are missing the lucene-codecs jar in your classpath or that you have a wrong version (not 4.10.4). Could you check in your job jar whether it includes lucence-codecs? If so, could you run mvn dependency:tree in the root directory of your project. There you

Re: Exception using flink-connector-elasticsearch

Hi, could you please try adding the lucene-core-4.10.4.jar file to your lib folder of Flink. (https://repo1.maven.org/maven2/org/apache/lucene/lucene-core/4.10.4/) Elasticsearch uses dependency injection to resolve the classes and maven is not really aware of this. Also you could try adding