Respect useReflectApi parameter (#29518)

apache · Nov 27, 2023 · 8830fab · 8830fab
1 parent 2f4c902
commit 8830fab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...a/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java b/...a/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java
@@ -214,7 +214,7 @@ public static <T> AvroCoder<T> of(Class<T> clazz) {
   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);