[jira] [Updated] (BEAM-1688) Getting listener timeout after waiting for [10000] ms from ElasticsearchIO

["Ismaël Mejía (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ismaël Mejía updated BEAM-1688:
-------------------------------
    Component/s:     (was: z-do-not-use-sdk-java-extensions)
                 io-java-elasticsearch

> 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: io-java-elasticsearch
>    Affects Versions: 0.5.0
>         Environment: Linux,  ElasticSearch 5.2.1
>            Reporter: Sathish Jayaraman
>            Assignee: Etienne Chauchot
>            Priority: Minor
>             Fix For: 2.2.0
>
>
> 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
(v7.6.3#76005)