flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: Flink cluster : Client is not connected to any Elasticsearch nodes!
Date Tue, 06 Jun 2017 16:39:48 GMT
Hi Dhinesh,

Could it be that you didn’t configure the network binding address of the ES installation
You need to make sure it isn’t binded to, which I think in some Elasticsearch
versions is the default binding.

Also, just a reminder if you haven’t done so, please make sure that the ES dependencies
is properly bundled for cluster execution. See [1] for details on this.


[1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/linking.html

On 6 June 2017 at 12:01:54 AM, dhinesh raja (dhinesh.raja@bizruntime.com) wrote:

Dear Team,

I am running flink streaming job with Elasticsearch connector2. I am able to run in my eclipse
but when I run in flink local cluster I got this error. could you please help me in this?I
have attached my code. I am using flink 1.2.0 and elastic search 2.x

java.lang.RuntimeException: Client is not connected to any Elasticsearch nodes!
        at org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.open(ElasticsearchSink.java:172)
        at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
        at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:112)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:375)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:251)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:665)
        at java.lang.Thread.run(Thread.java:748)

Thanks & Regards

Dhinesh Raja. M

View raw message