yux created FLINK-35243:
---------------------------
Summary: Carry pre-schema payload with SchemaChangeEvents
Key: FLINK-35243
URL: https://issues.apache.org/jira/browse/FLINK-35243
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: yux
Fix For: cdc-3.2.0
Currently, Flink CDC 3.x SchemaChangeEvent provides no information about the
previous schema state before applying changes.
Most pipeline sources can't provide PreSchema info (because it's not recorded
in the binlog / oplog / ...), but some pipeline sinks require it to perform
validation checks and apply schema change. This ticket suggests adding
framework-level support to filling pre-schema payload to any SchemaChangeEvent
that requires such info.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)