You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Sathish Jayaraman (JIRA)" <ji...@apache.org> on 2017/03/10 19:42:04 UTC
[jira] [Created] (BEAM-1688) Getting listener timeout after waiting
for [10000] ms from ElasticsearchIO
Sathish Jayaraman created BEAM-1688:
---------------------------------------
Summary: 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: Davor Bonaci
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)