Kaynağa Gözat

优化滚动查询

zhouhao 3 yıl önce
ebeveyn
işleme
e29672b66f

+ 2 - 1
jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/service/reactive/ReactiveElasticSearchService.java

@@ -225,7 +225,8 @@ public class ReactiveElasticSearchService implements ElasticSearchService {
             .collectList()
             .filter(CollectionUtils::isNotEmpty)
             .flatMapMany(metadataList -> this
-                .createSearchRequest(queryParam, metadataList)
+                .createSearchRequest(queryParam.clone().noPaging(), metadataList)
+                .doOnNext(search -> search.source().size(queryParam.getPageSize()))
                 .flatMapMany(restClient::scroll)
                 .map(searchHit -> Tuples.of(metadataList, searchHit))
             );