Re: ElasticsearchSink Exception

2017-02-28 Thread Tzu-Li (Gordon) Tai
Good to know it’s working! Thanks for the update :-) On March 1, 2017 at 6:03:44 AM, Govindarajan Srinivasaraghavan (govindragh...@gmail.com) wrote: Hi Gordon/Flavio, Found out the issue was because of elastic search version mismatch. Another person upgraded ES version to 5.x but I was using

Re: ElasticsearchSink Exception

2017-02-28 Thread Govindarajan Srinivasaraghavan
Hi Gordon/Flavio, Found out the issue was because of elastic search version mismatch. Another person upgraded ES version to 5.x but I was using 2.x. After changing the version it worked. Thanks for the help. On Mon, Feb 27, 2017 at 6:12 AM, Tzu-Li (Gordon) Tai wrote: > Hi! > > Like wha Flavio s

Re: ElasticsearchSink Exception

2017-02-27 Thread Tzu-Li (Gordon) Tai
Hi! Like wha Flavio suggested, at a first glance this looks like a problem with building the uber jar. I haven’t bumped into the problem while testing out the connector on cluster submitted test jobs before, but I can try to test this quickly to make sure. Could you tell me what your installed

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 Srinivasar

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 Me

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 see

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: 'lucene-