You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Wout Scheepers (JIRA)" <ji...@apache.org> on 2018/11/06 13:36:00 UTC
[jira] [Created] (BEAM-5988) ElasticsearchIO listener timeout
Wout Scheepers created BEAM-5988:
------------------------------------
Summary: ElasticsearchIO listener timeout
Key: BEAM-5988
URL: https://issues.apache.org/jira/browse/BEAM-5988
Project: Beam
Issue Type: Bug
Components: io-java-elasticsearch
Reporter: Wout Scheepers
Assignee: Wout Scheepers
Still getting a listener timeout when trying to insert a large amount of documents.
```
java.io.IOException: listener timeout after waiting for [30000] ms
at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:660)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:219)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:191)
at org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO$Write$WriteFn.flushBatch(ElasticsearchIO.java:1226)
at org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO$Write$WriteFn.finishBundle(ElasticsearchIO.java:1200)
```
The listener timeouts are not handled in the underlying ES RestClient.
A possible solution would be to catch these exceptions and include them in the retry handling mechanism
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)