Re: ElasticIO retry configuration exception

n getting a reproducible in a unit test. > > Thanks! > Wout > 
> > > From: Tim Robertson > Reply-To: "user@beam.apache.org" > Date: Thursday, 11 October 2018 at 20:25 > To: "user@beam.apache.org" > Subject: Re: ElasticIO retry configuration except

Re: ElasticIO retry configuration exception

To: "user@beam.apache.org" Subject: Re: ElasticIO retry configuration exception I took a super quick look at the code and I think Romain is correct. 1. On a retry scenario it calls handleRetry() 2. Within handleRetry() it gets the DefaultRetryPredicate and calls test(response) - this reads

Re: ElasticIO retry configuration exception

.12'*} >> >> >> >> However, the problem still persists when writing a document to elastic >> with the retryConfiguration set. >> >> I guess the problem lies at my elastic version, as JB implies? >> >> >> >> Anyway, thanks for the suggestion

Re: ElasticIO retry configuration exception

gt; > > Wout > > > > *From: *Romain Manni-Bucau > *Reply-To: *"user@beam.apache.org" > *Date: *Wednesday, 10 October 2018 at 16:53 > *To: *"user@beam.apache.org" > *Subject: *Re: ElasticIO retry configuration exception > > > > Hi Wout, &g

Re: ElasticIO retry configuration exception

for the suggestion. Wout From: Romain Manni-Bucau Reply-To: "user@beam.apache.org" Date: Wednesday, 10 October 2018 at 16:53 To: "user@beam.apache.org" Subject: Re: ElasticIO retry configuration exception Hi Wout, Maye check your classpath http client versions (against

Re: ElasticIO retry configuration exception

Hi Wout, Maye check your classpath http client versions (against https://github.com/apache/beam/blob/v2.7.0/sdks/java/io/elasticsearch/build.gradle for instance). Romain Manni-Bucau @rmannibucau | Blog | Old Blog

Re: ElasticIO retry configuration exception

Hey JB, Thanks for your fast reply. The elastic version we're using is 5.6.2. "version": { "number": "5.6.2", "build_hash": "57e20f3", "build_date": "2017-09-23T13:16:45.703Z", "build_snapshot": false, "lucene_version": "6.6.1" } Wout On

Re: ElasticIO retry configuration exception

Hi Wout, what's the elasticsearch version ? (just to try to reproduce) Thanks, Regards JB On 10/10/2018 15:31, Wout Scheepers wrote: > Hey all, > >   > > When using .withRetryConfiguration()for ElasticsearchIO, I get the > following stacktrace: > >   > > Caused by:

ElasticIO retry configuration exception

Hey all, When using .withRetryConfiguration()for ElasticsearchIO, I get the following stacktrace: Caused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: No content to map due to end-of-input at [Source: (org.apache.http.nio.entity.ContentInputStream); line: 1, column: 0]