[ https://issues.apache.org/jira/browse/HUDI-7436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
lei w updated HUDI-7436: ------------------------ Description: In HoodieMergeHelper#composeSchemaEvolutionTransformer we use this condition +sameCols.size() != colNamesFromWriteSchema.size() || SchemaCompatibility.checkReaderWriterCompatibility(newWriterSchema, writeSchemaFromFile).getType() == org.apache.avro.SchemaCompatibility.SchemaCompatibilityType.COMPATIBLE + to determine whether we need to rewrite record. The second condition may need to be negated. was: In HoodieMergeHelper#composeSchemaEvolutionTransformer we use this condition +sameCols.size() != colNamesFromWriteSchema.size() || SchemaCompatibility.checkReaderWriterCompatibility(newWriterSchema, writeSchemaFromFile).getType() == org.apache.avro.SchemaCompatibility.SchemaCompatibilityType.COMPATIBLE +to determine whether we need to rewrite record. The second condition may need to be negated. > Not need to reWriteRecord when method > SchemaCompatibility.checkReaderWriterCompatibility return > SchemaCompatibilityType.COMPATIBLE > ---------------------------------------------------------------------------------------------------------------------------------- > > Key: HUDI-7436 > URL: https://issues.apache.org/jira/browse/HUDI-7436 > Project: Apache Hudi > Issue Type: Bug > Reporter: lei w > Priority: Major > > In HoodieMergeHelper#composeSchemaEvolutionTransformer we use this condition > +sameCols.size() != colNamesFromWriteSchema.size() || > SchemaCompatibility.checkReaderWriterCompatibility(newWriterSchema, > writeSchemaFromFile).getType() == > org.apache.avro.SchemaCompatibility.SchemaCompatibilityType.COMPATIBLE + to > determine whether we need to rewrite record. The second condition may need > to be negated. -- This message was sent by Atlassian Jira (v8.20.10#820010)