beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sathish Jayaraman (JIRA)" <>
Subject [jira] [Created] (BEAM-1688) Getting listener timeout after waiting for [10000] ms from ElasticsearchIO
Date Fri, 10 Mar 2017 19:42:04 GMT
Sathish Jayaraman created BEAM-1688:

             Summary: Getting listener timeout after waiting for [10000] ms from ElasticsearchIO
                 Key: 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:
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