(beam) branch master updated: Respect useReflectApi parameter (#29518)

[yhu]

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

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 8830fab1c49 Respect useReflectApi parameter (#29518)
8830fab1c49 is described below

commit 8830fab1c4980b1b83d60a65fd3a571d2a30f86f
Author: Michel Davit <mic...@davit.fr>
AuthorDate: Mon Nov 27 17:29:15 2023 +0100

    Respect useReflectApi parameter (#29518)
---
 .../main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java
 
b/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java
index 621076e0e14..826f209283f 100644
--- 
a/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java
+++ 
b/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java
@@ -214,7 +214,7 @@ public class AvroCoder<T> extends CustomCoder<T> {
   public static <T> AvroCoder<T> of(Class<T> type, boolean useReflectApi) {
     if (GenericRecord.class.equals(type)) {
       throw new IllegalArgumentException("AvroCoder for GenericRecord requires 
a schema");
-    } else if (SpecificRecord.class.isAssignableFrom(type) && useReflectApi) {
+    } else if (SpecificRecord.class.isAssignableFrom(type) && !useReflectApi) {
       return specific(type);
     } else {
       return reflect(type);