From ac89ac59e7f7b4c355a4bb84f52f407f1d0b0faa Mon Sep 17 00:00:00 2001 From: carlosdelest Date: Mon, 30 Oct 2023 17:47:52 +0100 Subject: [PATCH] Fix or operation --- .../java/org/elasticsearch/action/bulk/TransportBulkAction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java b/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java index 44af17e954d53..88854aba1746b 100644 --- a/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java +++ b/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java @@ -777,7 +777,7 @@ private boolean preprocessBulkRequest(Task task, BulkRequest bulkRequest, String for (DocWriteRequest docWriteRequest : bulkRequest.requests) { IndexRequest indexRequest = getIndexWriteRequest(docWriteRequest); if (indexRequest != null) { - needsProcessing |= preprocessor.needsProcessing(docWriteRequest, indexRequest, metadata); + needsProcessing = needsProcessing || preprocessor.needsProcessing(docWriteRequest, indexRequest, metadata); } if (docWriteRequest instanceof IndexRequest ir) {