[BEAM-1688] Getting listener timeout after waiting for [10000] ms from ElasticsearchIO

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Affects Version/s: 0.5.0
• Fix Version/s: 2.2.0
• Component/s: io-java-elasticsearch
• Environment: Linux, ElasticSearch 5.2.1
• Assignee: Etienne Chauchot
• Reporter: Sathish Jayaraman
• Created: 10/Mar/17 19:41
• Updated: 24/Jul/20 20:14
• Resolved: 15/Sep/17 10:00

Description

I am trying to test a simple Apache Beam code with source as Elasticsearch. I modified Beam's MinimalWordCount example to include source as Elasticsearch instead of TextIO.

When I run the code, I get below error,
An exception occured while executing the Java class. null: InvocationTargetException: java.io.IOException: listener timeout after waiting for [10000] ms

I debugged ElasticsearchIO.java and could see everything works fine, the Elasicsearch client is built & data from index is being retrieved by the code. But ParDo function after read transform does not get executed at all. The Elasticsearch client keeps waiting and finally gets a timeout error.

Any idea about the issue?

Have raised issue here too http://stackoverflow.com/questions/42720857/getting-listener-timeout-after-waiting-for-10000-ms-from-elasticsearchio

Issue Links

• is related to: BEAM-1637 Create Elasticsearch IO compatible with ES 5.x