[
https://issues.apache.org/jira/browse/BEAM-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906097#comment-15906097
]
Jean-Baptiste Onofré commented on BEAM-1688:
--------------------------------------------
Current {{ElasticsearchIO}} doesn't support Elasticsearch 5.x (it's
Elasticsearch 2.x only). We are working on a new IO to fully support
Elasticsearch 5 (see https://issues.apache.org/jira/browse/BEAM-1637).
> 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: Jean-Baptiste Onofré
> 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)
