This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/support/nifi-1.x by this push:
     new 75341cc5fa NIFI-12376: Fix logic error with bitwise operator in 
AvroReader
75341cc5fa is described below

commit 75341cc5face0d48d22baaf4bd9398a9fd114f2c
Author: Matt Burgess <mattyb...@apache.org>
AuthorDate: Wed Nov 15 15:21:30 2023 -0500

    NIFI-12376: Fix logic error with bitwise operator in AvroReader
    
    Signed-off-by: Pierre Villard <pierre.villard...@gmail.com>
    
    This closes #8034.
---
 .../src/main/java/org/apache/nifi/avro/AvroReader.java                  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroReader.java
 
b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroReader.java
index aae5b5961d..1ffa8669ed 100644
--- 
a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroReader.java
+++ 
b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroReader.java
@@ -103,7 +103,7 @@ public class AvroReader extends SchemaRegistryService 
implements RecordReaderFac
 
             final Schema avroSchema;
             try {
-                if (recordSchema.getSchemaFormat().isPresent() & 
recordSchema.getSchemaFormat().get().equals(AvroTypeUtil.AVRO_SCHEMA_FORMAT)) {
+                if (recordSchema.getSchemaFormat().isPresent() && 
recordSchema.getSchemaFormat().get().equals(AvroTypeUtil.AVRO_SCHEMA_FORMAT)) {
                     final Optional<String> textOption = 
recordSchema.getSchemaText();
                     if (textOption.isPresent()) {
                         avroSchema = 
compiledAvroSchemaCache.get(textOption.get());

Reply via email to