50
50
import org .reactivestreams .Publisher ;
51
51
import org .slf4j .Logger ;
52
52
import org .slf4j .LoggerFactory ;
53
+ import org .springframework .data .domain .Pageable ;
53
54
import org .springframework .data .domain .Sort ;
54
55
import org .springframework .data .elasticsearch .client .reactive .ReactiveElasticsearchClient ;
55
56
import org .springframework .data .elasticsearch .core .EntityOperations .AdaptibleEntity ;
@@ -241,7 +242,7 @@ private Flux<SearchHit> doFind(Query query, ElasticsearchPersistentEntity<?> ent
241
242
242
243
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder ();
243
244
searchSourceBuilder .query (mappedQuery (query , entity ));
244
- searchSourceBuilder .version (entity .hasVersionProperty ()); // This has been true by default before
245
+ searchSourceBuilder .version (entity .hasVersionProperty ());
245
246
searchSourceBuilder .trackScores (query .getTrackScores ());
246
247
247
248
QueryBuilder postFilterQuery = mappedFilterQuery (query , entity );
@@ -263,15 +264,17 @@ private Flux<SearchHit> doFind(Query query, ElasticsearchPersistentEntity<?> ent
263
264
request .indicesOptions (query .getIndicesOptions ());
264
265
}
265
266
266
- if ( query .getPageable (). isPaged ()) {
267
+ Pageable pageable = query .getPageable ();
267
268
268
- long offset = query .getPageable ().getOffset ();
269
+ if (pageable .isPaged ()) {
270
+
271
+ long offset = pageable .getOffset ();
269
272
if (offset > Integer .MAX_VALUE ) {
270
273
throw new IllegalArgumentException (String .format ("Offset must not be more than %s" , Integer .MAX_VALUE ));
271
274
}
272
275
273
276
searchSourceBuilder .from ((int ) offset );
274
- searchSourceBuilder .size (query . getPageable () .getPageSize ());
277
+ searchSourceBuilder .size (pageable .getPageSize ());
275
278
276
279
request .source (searchSourceBuilder );
277
280
return doFind (prepareSearchRequest (request ));
0 commit comments