-
Notifications
You must be signed in to change notification settings - Fork 1.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-35243][cdc] Supports more schema change event types & backfill pre-schema payload for sink #3296
base: master
Are you sure you want to change the base?
Conversation
7ed8f0a
to
e8ce8ed
Compare
@PatrickRen @ruanhang1993 PTAL |
f22c3a4
to
1e8ea73
Compare
DropTableEvent TruncateTableEvent can be closed. Sometimes, tables cannot be deleted synchronously. |
Hi @melin, thanks for your comments. It's a common use case to apply some "safe" schema change events (like This PR is still in early draft stage, so feel free to leave your comments if you have any other concerns. |
This PR closes FLINK-35243:
AlterColumnCommentEvent
,AlterTableCommentEvent
,DropTableEvent
,RenameTableEvent
, andTruncateTableEvent
in pipeline frameworkSchemaChangeEventWithPreSchema
interface, allowing SchemaRegistry backfilling schema before change payloadALTER TABLE ... MODIFY COLUMN
DDLThis requires #3339 being merged first.