diff --git a/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java b/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java index 26a602615..81091376e 100644 --- a/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java +++ b/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java @@ -95,9 +95,13 @@ public class SimpleElasticsearchRepository implements ElasticsearchRepository @Override public Iterable findAll(Sort sort) { + int itemCount = (int) this.count(); + if (itemCount == 0) { + return new PageImpl(Collections. emptyList()); + } SearchQuery query = new SearchQuery(); query.setElasticsearchQuery(matchAllQuery()); - query.setPageable(new PageRequest(0,Integer.MAX_VALUE, sort)); + query.setPageable(new PageRequest(0,itemCount, sort)); return elasticsearchOperations.queryForPage(query, getEntityClass()); }