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 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-core', version: '5.5.0'
compile group: 'org.elasticsearch', name: 'elasticsearch', version: '2.3.5'
*Sink Code:*
List<InetSocketAddress> transportAddresses = new ArrayList<>();
transportAddresses.add(new
InetSocketAddress(InetAddress.getByName(*hostName*), 9300));
output.addSink(new ElasticsearchSink<>(config, transportAddresses, new
ElasticsearchSinkFunction<Object>() {
}
*Exception:*
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:386)
at org.apache.flink.streaming.runtime.tasks.StreamTask.
invoke(StreamTask.java:262)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655)
at java.lang.Thread.run(Thread.java:745)
