mingmingruyue321 commented on PR #3912:
URL: https://github.com/apache/flink-cdc/pull/3912#issuecomment-3545738181
@yuxiqian I have a table that I want to delete and resynchronize with both
full and incremental data. The schema recorded by the Schema Manager will not
be automatically deleted when the table is deleted, skipping the new table
creation statement. What should I do
```
// For redundant schema change events (possibly coming from duplicate
emitted
// CreateTableEvents in snapshot stage), we just skip them.
if (!SchemaUtils.isSchemaChangeEventRedundant(currentUpstreamSchema,
originalEvent)) {
schemaManager.applyOriginalSchemaChange(originalEvent);
deducedSchemaChangeEvents.addAll(deduceEvolvedSchemaChanges(originalEvent));
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
