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 ef49b14db..1f3e86f4d 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java @@ -1173,6 +1173,10 @@ class RequestFactory { request.routing(query.getRoute()); } + if (query.getScrollTime() != null) { + request.scroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis())); + } + request.source(sourceBuilder); return request; } @@ -1248,6 +1252,10 @@ class RequestFactory { searchRequestBuilder.setRouting(query.getRoute()); } + if (query.getScrollTime() != null) { + searchRequestBuilder.setScroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis())); + } + return searchRequestBuilder; }