Bump org.springframework.data:spring-data-elasticsearch (#507) (#523)

Bumps [org.springframework.data:spring-data-elasticsearch](https://github.com/spring-projects/spring-data-elasticsearch) from 5.5.1 to 5.5.2.
- [Release notes](https://github.com/spring-projects/spring-data-elasticsearch/releases)
- [Commits](spring-projects/spring-data-elasticsearch@5.5.1...5.5.2)

---
updated-dependencies:
- dependency-name: org.springframework.data:spring-data-elasticsearch
  dependency-version: 5.5.2
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Andriy Redko <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

Author: reta

settings.gradle.kts

@@ -16,10 +16,10 @@ dependencyResolutionManagement {
     }
 
     create("springLibs") {
-      version("spring", "6.2.8")
-      version("spring-boot", "3.5.3")
-      library("data-commons", "org.springframework.data:spring-data-commons:3.5.1")
-      library("data-elasticsearch", "org.springframework.data:spring-data-elasticsearch:5.5.1")
+      version("spring", "6.2.10")
+      version("spring-boot", "3.5.5")
+      library("data-commons", "org.springframework.data:spring-data-commons:3.5.3")
+      library("data-elasticsearch", "org.springframework.data:spring-data-elasticsearch:5.5.3")
       library("web", "org.springframework", "spring-web").versionRef("spring")
       library("webflux", "org.springframework", "spring-webflux").versionRef("spring")
       library("context", "org.springframework", "spring-context").versionRef("spring")
@@ -32,7 +32,7 @@ dependencyResolutionManagement {
       library("boot-test", "org.springframework.boot", "spring-boot-test").versionRef("spring-boot")
       library("boot-test-autoconfigure", "org.springframework.boot", "spring-boot-test-autoconfigure").versionRef("spring-boot")
       library("boot-testcontainers", "org.springframework.boot", "spring-boot-testcontainers").versionRef("spring-boot")
-      library("projectreactor", "io.projectreactor:reactor-test:3.7.7")
+      library("projectreactor", "io.projectreactor:reactor-test:3.7.9")
       plugin("spring-boot", "org.springframework.boot").versionRef("spring-boot")
     }
 

spring-data-opensearch/src/main/java/org/opensearch/data/client/orhlc/RequestFactory.java

@@ -841,13 +841,9 @@ private SearchRequest prepareSearchRequest(
             sourceBuilder.seqNoAndPrimaryTerm(true);
         }
 
-        if (query.getPageable().isPaged()) {
-            sourceBuilder.from((int) query.getPageable().getOffset());
-            sourceBuilder.size(query.getPageable().getPageSize());
-        } else {
-            sourceBuilder.from(0);
-            sourceBuilder.size(INDEX_MAX_RESULT_WINDOW);
-        }
+        sourceBuilder
+            .from((int) (query.getPageable().isPaged() ? query.getPageable().getOffset() : 0))
+            .size(query.getRequestSize());
 
         if (query.getSourceFilter() != null) {
             sourceBuilder.fetchSource(getFetchSourceContext(query));

spring-data-opensearch/src/main/java/org/opensearch/data/client/osc/RequestConverter.java

@@ -1328,11 +1328,8 @@ public MsearchRequest searchMsearchRequest(
                                     .timeout(timeStringMs(query.getTimeout())) //
                             ;
 
-                            if (query.getPageable().isPaged()) {
-                                bb //
-                                        .from((int) query.getPageable().getOffset()) //
-                                        .size(query.getPageable().getPageSize());
-                            }
+                            bb.from((int) (query.getPageable().isPaged() ? query.getPageable().getOffset() : 0))
+                                .size(query.getRequestSize());
 
                             if (!isEmpty(query.getFields())) {
                                 bb.fields(fb -> {
@@ -1483,13 +1480,9 @@ private <T> void prepareSearchRequest(Query query, @Nullable String routing, @Nu
             builder.seqNoPrimaryTerm(true);
         }
 
-        if (query.getPageable().isPaged()) {
-            builder //
-                    .from((int) query.getPageable().getOffset()) //
-                    .size(query.getPageable().getPageSize());
-        } else {
-            builder.from(0).size(INDEX_MAX_RESULT_WINDOW);
-        }
+        builder
+            .from((int) (query.getPageable().isPaged() ? query.getPageable().getOffset() : 0))
+            .size(query.getRequestSize());
 
         if (!isEmpty(query.getFields())) {
             var fieldAndFormats = query.getFields().stream().map(field -> FieldAndFormat.of(b -> b.field(field))).toList();