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)