diff --git a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java index 18a2f6206..8d9db44a6 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java @@ -1029,6 +1029,10 @@ private SearchRequest prepareSearchRequest(Query query, @Nullable Class clazz sourceBuilder.runtimeMappings(runtimeMappings); } + if (query.getScrollTime() != null) { + request.scroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis())); + } + request.source(sourceBuilder); return request; @@ -1131,6 +1135,10 @@ private SearchRequestBuilder prepareSearchRequestBuilder(Query query, Client cli searchRequestBuilder.setRuntimeMappings(runtimeMappings); } + if (query.getScrollTime() != null) { + searchRequestBuilder.setScroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis())); + } + return searchRequestBuilder; }