Delete Elasticsearch document by ID with Scala using Java API

Question

I'm using Elastic Java API in Scala to delete a list of document, using their ID to delete them one at a time, no success for now. API works fine for other calls like SearchResponse.
My code looks like this :

var deleteResp : DeleteResponse = null

deleteResp = ElasticSearch.getClient()
      .prepareDelete(index, type, id)
      .get()

Same with :

deleteResp = ElasticSearch.getClient()
      .prepareDelete(index, type, id)
      .execute()
      .actionGet()

I also tried to catch Elastic response for debugging using this, but nothing shows up in stdout.

try{ \ previous code } 
catch {
    case e: Exception => {
    print("Failed deletion", e.getMessage)
    e.printStackTrace() }
}

Config :
- Scala 2.10.6
- Spark 1.6
- Elasticsearch 2.3.2

Thank you

Are you sure about your index, type and id? can you find the document with curl -XGET localhost:9200/index/type/id ? — Val
– Val, Commented Mar 29, 2018 at 8:16
Ok, and you're sure that your client is properly connected to your ES server? — Val
– Val, Commented Mar 29, 2018 at 8:32
Same for connectivity, deletion part is actually the last step of the code. Before that, in run multiple queries to get JSON responses and process them without trouble. — Alex Peter
– Alex Peter, Commented Mar 29, 2018 at 8:38
But what kind of response do you actually get in deleteResp ? — Val
– Val, Commented Mar 29, 2018 at 8:40
Thing is I don't know how to catch the response, the try/catch block does not return any stackTrace, and printing the deleteResp var gives org.elasticsearch.action.delete.DeleteResponse@5da55732 However when I directly send a DELETE command in Sense it's working fine. — Alex Peter
– Alex Peter, Commented Mar 29, 2018 at 9:03

Alex Peter · Accepted Answer · 2018-03-29 12:49:06Z

1

I guess it's a pretty specific case but given the poor info on Java API usage, someone may find this case relevant.

Thank to Val and precise debugging I found the cause : Be very careful on the string format passed to the prepareSearch().

My ID, coming from a List, contained brackets that messed things up, the delete request was successful but on a wrong ID.

For details, think about using all available methods on request objects and double check each formatting :

var deletedId = deleteResp.getId()
var deletedType = deleteResp.getType()
var deletedIndex = deleteResp.getIndex()
var deletedShard = deleteResp.getShardInfo()

answered Mar 29, 2018 at 12:49

Alex Peter

218 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Delete Elasticsearch document by ID with Scala using Java API

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related