[BEAM-12577] In stream mode, ElasticsearchIO transform becomes unavailable

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Affects Version/s: 2.29.0
• Component/s: io-java-elasticsearch
• Labels: GCP
• Environment: Dataflow GCP
• Assignee: Unassigned
• Reporter: Jonathan Gallon
• Created: 06/Jul/21 09:34
• Updated: 04/Jun/22 20:58

Description

If you use the ElasticSearchIO transform for a workflow in stream mode, and if something happens temporarily between the RestClient and the server, any future calls will result in a 

java.io.IOException: Connection reset by peer

As there is not reconnection system ou keepalive enable, the client seems not able to reconnect and the workflow cannot work anymore.