Fix refresh policy in UpdateQuery.

sothawo · sothawo · commit 572cc7ffea82 · 2023-09-13T21:49:19.000+02:00
Original Pull Request #2696 Closes #2692 (cherry picked from commit 2d0aee0)
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
@@ -999,7 +999,7 @@ public DeleteByQueryRequest documentDeleteByQueryRequest(Query query, @Nullable
 					.docAsUpsert(query.getDocAsUpsert()) //
 					.ifSeqNo(query.getIfSeqNo() != null ? Long.valueOf(query.getIfSeqNo()) : null) //
 					.ifPrimaryTerm(query.getIfPrimaryTerm() != null ? Long.valueOf(query.getIfPrimaryTerm()) : null) //
-					.refresh(refresh(refreshPolicy)) //
+					.refresh(query.getRefreshPolicy() != null ? refresh(query.getRefreshPolicy()) : refresh(refreshPolicy)) //
 					.retryOnConflict(query.getRetryOnConflict()) //
 			;
 

Original file line number	Diff line number	Diff line change
`@@ -999,7 +999,7 @@ public DeleteByQueryRequest documentDeleteByQueryRequest(Query query, @Nullable`
`999`	`999`	`.docAsUpsert(query.getDocAsUpsert()) //`
`1000`	`1000`	`.ifSeqNo(query.getIfSeqNo() != null ? Long.valueOf(query.getIfSeqNo()) : null) //`
`1001`	`1001`	`.ifPrimaryTerm(query.getIfPrimaryTerm() != null ? Long.valueOf(query.getIfPrimaryTerm()) : null) //`
`1002`		`- .refresh(refresh(refreshPolicy)) //`
	`1002`	`+ .refresh(query.getRefreshPolicy() != null ? refresh(query.getRefreshPolicy()) : refresh(refreshPolicy)) //`
`1003`	`1003`	`.retryOnConflict(query.getRetryOnConflict()) //`
`1004`	`1004`	`;`
`1005`	`1005`