Fix or operation

carlosdelest · Oct 30, 2023 · ac89ac5 · ac89ac5
1 parent 99def84
commit ac89ac5
Showing 1 changed file with 1 addition and 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
@@ -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) {