foo

apache · Oct 12, 2024 · 87f8d33 · 87f8d33
1 parent a1bb67d
commit 87f8d33
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java
@@ -161,7 +161,7 @@ private static boolean matchConstructor(
     // Verify that constructor parameters match (name and type) the inferred schema.
     for (Parameter parameter : constructor.getParameters()) {
       FieldValueTypeInformation type = typeMap.get(parameter.getName());
-      if (type == null || type.getRawType() != parameter.getType()) {
+      if (type == null || type.getRawType() != parameter.getParameterizedType()) {
         valid = false;
         break;
       }
@@ -178,7 +178,7 @@ private static boolean matchConstructor(
       }
       name = name.substring(0, name.length() - 1);
       FieldValueTypeInformation type = typeMap.get(name);
-      if (type == null || type.getRawType() != parameter.getType()) {
+      if (type == null || type.getRawType() != parameter.getParameterizedType()) {
         return false;
       }
     }
@@ -322,7 +322,7 @@ public ByteCodeAppender appender(final Target implementationTarget) {
                   Duplication.SINGLE,
                   typeConversionsFactory
                       .createSetterConversions(readParameter)
-                      .convert(TypeDescriptor.of(parameter.getType())),
+                      .convert(TypeDescriptor.of(parameter.getParameterizedType())),
                   MethodInvocation.invoke(new ForLoadedMethod(setterMethod)),
                   Removal.SINGLE);
         }