From 31365fb7222ca6f8cc4c25555052c8281ae04627 Mon Sep 17 00:00:00 2001 From: Peter-Josef Meisch Date: Tue, 27 Jun 2023 22:26:10 +0200 Subject: [PATCH] Fix IndicesBoost error. Original Pull Request #2606 Closes #2598 (cherry picked from commit d9fd722bb6af81068fb9b723b77c60efddbf06d3) --- .../client/elc/RequestConverter.java | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/src/main/java/org/springframework/data/elasticsearch/client/elc/RequestConverter.java b/src/main/java/org/springframework/data/elasticsearch/client/elc/RequestConverter.java index 8f926b29e..fcf9c31e2 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/elc/RequestConverter.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/elc/RequestConverter.java @@ -1146,11 +1146,9 @@ class RequestConverter { } if (!isEmpty(query.getIndicesBoost())) { - Map boosts = new LinkedHashMap<>(); - query.getIndicesBoost() - .forEach(indexBoost -> boosts.put(indexBoost.getIndexName(), (double) indexBoost.getBoost())); - // noinspection unchecked - bb.indicesBoost(boosts); + bb.indicesBoost(query.getIndicesBoost().stream() + .map(indexBoost -> Map.of(indexBoost.getIndexName(), Double.valueOf(indexBoost.getBoost()))) + .collect(Collectors.toList())); } if (query instanceof NativeQuery) { @@ -1301,11 +1299,9 @@ class RequestConverter { } if (!isEmpty(query.getIndicesBoost())) { - Map boosts = new LinkedHashMap<>(); - query.getIndicesBoost() - .forEach(indexBoost -> boosts.put(indexBoost.getIndexName(), (double) indexBoost.getBoost())); - // noinspection unchecked - builder.indicesBoost(boosts); + builder.indicesBoost(query.getIndicesBoost().stream() + .map(indexBoost -> Map.of(indexBoost.getIndexName(), Double.valueOf(indexBoost.getBoost()))) + .collect(Collectors.toList())); } }