diff --git a/src/main/java/org/springframework/data/elasticsearch/repository/support/AbstractElasticsearchRepository.java b/src/main/java/org/springframework/data/elasticsearch/repository/support/AbstractElasticsearchRepository.java index 26caa8bdb..9df312dbf 100644 --- a/src/main/java/org/springframework/data/elasticsearch/repository/support/AbstractElasticsearchRepository.java +++ b/src/main/java/org/springframework/data/elasticsearch/repository/support/AbstractElasticsearchRepository.java @@ -299,11 +299,13 @@ public abstract class AbstractElasticsearchRepository implements Elastics idsQueryBuilder.addIds(stringIdRepresentation(id)); } } - if(idsQueryBuilder.ids().isEmpty()) { + + if (idsQueryBuilder.ids().isEmpty()) { return; } DeleteQuery deleteQuery = new DeleteQuery(); deleteQuery.setQuery(idsQueryBuilder); + operations.delete(deleteQuery, indexCoordinates); indexOperations.refresh(indexCoordinates); }