# Transport client timeout error

**URL:** <https://discuss.elastic.co/t/transport-client-timeout-error/88390>\
**Category:** Elasticsearch\
**Created:** [June 6, 2017, 10:02am UTC](https://discuss.elastic.co/t/transport-client-timeout-error/88390 "2017-06-06T10:02:56Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![hassahma](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/hassahma/32/17696_2.png) [@hassahma](https://discuss.elastic.co/u/hassahma)\
**Post date:** [June 6, 2017, 10:02am UTC](https://discuss.elastic.co/t/transport-client-timeout-error/88390/1 "2017-06-06T10:02:57Z")

</div>

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?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 4, 2017, 10:03am UTC](https://discuss.elastic.co/t/transport-client-timeout-error/88390/2 "2017-07-04T10:03:09Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.