Java RestClient and response.getStatusLine().getStatusCode()

Elastic Stack Elasticsearch
1

I use the org.elasticsearch.client.RestClient to bulk index documents, such as:

response = client.performRequest("POST", "some_endpoint/some_type/_bulk", Collections.emptyMap(), entity);

Then I check if the request was successful:

if (response.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
    throw new RuntimeException("something went wrong when indexing");
}

My observation is that even if the response status code is indeed HttpStatus.SC_OK, I am not guaranteed to have the documents in Elasticsearch at some point in time.

I use multiple clients in parallel, wrapped in Java Callables, this works usually great for millions of documents.

But sometimes a client will throw a java.net.SocketTimeoutException (probably because Elasticsearch cannot handle too many requests at a time). When such an exception is thrown, some documents uploaded in another Callable will not end up in Elasticsearch, even though their upload was finished and the status was HttpStatus.SC_OK.

It is very concerning to me that it seems I cannot reply on this status code as guarantee that at some point the documents will be indexed.

Has anybody had similar observations or some ideas what might help in my use case?

2

Hey,

if you are using bulk requests, you have to check for single items inside of the bulk response to make sure that each document got indexed - just checking that response status code is not sufficient.

--Alex

3

Alex,

Yes, this is what I am now doing now also. After a bulk request to POST documents, I am doing an Ids Query https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-ids-query.html#query-dsl-ids-query
with the Java Rest client to check if these documents are in fact accessible.

I noticed that even though I set the "refresh_interval" : "-1" before a bulk update, these documents in fact showed up with an Ids Query and are accessible.

Is this refresh_interval setting in Elasticsearch only a recommendation for the underlying index/commit engine and not a hard setting? (I am on 5.1.1)

4

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.