[ https://issues.apache.org/jira/browse/BEAM-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Etienne Chauchot reassigned BEAM-1688: -------------------------------------- Assignee: Etienne Chauchot (was: Jean-Baptiste Onofré) > Getting listener timeout after waiting for [10000] ms from ElasticsearchIO > -------------------------------------------------------------------------- > > Key: BEAM-1688 > URL: https://issues.apache.org/jira/browse/BEAM-1688 > Project: Beam > Issue Type: Bug > Components: sdk-java-extensions > Affects Versions: 0.5.0 > Environment: Linux, ElasticSearch 5.2.1 > Reporter: Sathish Jayaraman > Assignee: Etienne Chauchot > Priority: Minor > > 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 -- This message was sent by Atlassian JIRA (v6.3.15#6346)