beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jean-Baptiste Onofré (JIRA) <>
Subject [jira] [Commented] (BEAM-1688) Getting listener timeout after waiting for [10000] ms from ElasticsearchIO
Date Sat, 11 Mar 2017 05:46:04 GMT


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

> Getting listener timeout after waiting for [10000] ms from ElasticsearchIO
> --------------------------------------------------------------------------
>                 Key: BEAM-1688
>                 URL:
>             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: listener timeout after waiting for [10000] ms
> I debugged 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

This message was sent by Atlassian JIRA

View raw message