Hi, I am using elasticsearch 2.4 with flink. My code randomly throws connection errors to elasticsearch when using transport client, however sometimes i see no errors:
ConnectTransportException[[Hub][127.0.0.1:9300] connect_timeout[30s]]; nested: SocketException[Connection reset by peer];
at org.elasticsearch.transport.netty.NettyTransport.connectToChannels(NettyTransport.java:1005)
at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:920)
at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:893)
at org.elasticsearch.transport.TransportService.connectToNode(TransportService.java:260)
at org.elasticsearch.client.transport.TransportClientNodesService$NodeSampler.validateNewNodes(TransportClientNodesService.java:316)
at org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler.doSample(TransportClientNodesService.java:388)
at org.elasticsearch.client.transport.TransportClientNodesService$NodeSampler.sample(TransportClientNodesService.java:300)
at org.elasticsearch.client.transport.TransportClientNodesService.addTransportAddresses(TransportClientNodesService.java:181)
at org.elasticsearch.client.transport.TransportClient.addTransportAddress(TransportClient.java:236)
at org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.open(ElasticsearchSink.java:166)
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)
Any clues?