Re: ElasticsearchSink Exception

2017-02-27 Thread Aljoscha Krettek
+Tzu-Li (Gordon) Tai Do you have any idea what could be causing this? I'm asking because you recently worked on the Elasticsearch connectors, right? On Sun, 26 Feb 2017 at 04:26 Govindarajan Srinivasaraghavan < govindragh...@gmail.com> wrote: > Thanks Flavio. I tried with

Re: ElasticsearchSink Exception

2017-02-25 Thread Flavio Pompermaier
The exception you have (NoClassDefFoundError: org/elasticsearch/index/mapper/MapperParsingException) is usually caused by elasticsearch version conflict or a bad shading when creating the uber jar. Can you check if one of the 2 is causing the problem? On 25 Feb 2017 23:13, "Govindarajan

Re: ElasticsearchSink Exception

2017-02-25 Thread Govindarajan Srinivasaraghavan
Hi Flavio, I tried with both http port 9200 and tcp port 9300 and I see incoming connections in the elasticserach node. Also I see the below errors in taskmanager out logs. Below are the dependencies I have on my gradle project. Am I missing something? Exception in thread "elasticsearch[Madame

Re: ElasticsearchSink Exception

2017-02-25 Thread Flavio Pompermaier
Are you sure that in elasticsearch.yml you've enabled ES to listen to the http port 9300? On 25 Feb 2017 08:58, "Govindarajan Srinivasaraghavan" < govindragh...@gmail.com> wrote: Hi All, I'm getting the below exception when I start my flink job. I have verified the elastic search host and it

ElasticsearchSink Exception

2017-02-24 Thread Govindarajan Srinivasaraghavan
Hi All, I'm getting the below exception when I start my flink job. I have verified the elastic search host and it seems to be working well. I have also tried including the below dependecies to my project but nothing works. Need some help. Thanks. compile group: 'org.apache.lucene', name: