Re: elastic-search connector for 1.3.1 not working for local environemnt

Hi, Thanks a lot for figuring this out! I opened a Jira issue: https://issues.apache.org/jira/browse/FLINK-7133 Best, Aljoscha > On 7. Jul 2017, at 10:53, Debski wrote: > > I've found out the source of the problem when I build flink locally

Re: elastic-search connector for 1.3.1 not working for local environemnt

I've found out the source of the problem when I build flink locally. elastic-search base depends on (by default) ES version 1.7.1 that depends on asm 4.1 and that version is shaded to elasticsearch-base-jar. I tried to set elasticsearch.version property in Maven to 5.1.2 (the same as elasticsearch5