[
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)
