![]() However in current production we can not update the libraries because of DMZ restrictions, We are using spring data elasticsearch 4.1. Scroll = archScrollContinue(scrollId, 1000, SampleEntity.class) SampleEntities.addAll(scroll.getSearchHits()) assertError(throwable -> 'The mapper function returned a null value.'.equals(throwable. You can reproduce that with following chunk of code: Observable.just(1). I am aware of this spring documentation where this was the suggested solution SearchScrollHits scroll = archScrollStart(1000, searchQuery, SampleEntity.class, index) In particularly your case, you have a mapper function, that returns a null value, which the exception clearly states. ![]() NativeSearchQueryBuilder().withQuery(boolQueryBuilders).withPageable(PageRequest.of(0,1)) However we do not want to use scroll as this is exhausting Max scroll connections as this API is very heavily used. Is requesting ES for 10000 records which was way too much for a term query so we have fixed in query builder by using Pageable, We have a spring webflux application which is querying Elasticsearch using ReactiveElasticsearchTemplate like this final inline fun getSearchMonoList(
0 Comments
Leave a Reply. |