diff --git a/hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java b/hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java index ef6ce13a3..96b1a1e83 100644 --- a/hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java +++ b/hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java @@ -223,7 +223,7 @@ public class HoodieAvroUtils { } public static Schema removeMetadataFields(Schema schema) { - return removeFields(schema, HoodieRecord.HOODIE_META_COLUMNS); + return removeFields(schema, HoodieRecord.HOODIE_META_COLUMNS_WITH_OPERATION); } public static Schema removeFields(Schema schema, List fieldsToRemove) {