[jira] [Created] (FLINK-5921) Adapt time mode indicator functions return custom data types

2017-02-25 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5921: Summary: Adapt time mode indicator functions return custom data types Key: FLINK-5921 URL: https://issues.apache.org/jira/browse/FLINK-5921 Project: Flink

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