yanghuai created FLINK-35257:
--------------------------------
Summary: optimize the handling of schema.change.behavior as
EXCEPTION
Key: FLINK-35257
URL: https://issues.apache.org/jira/browse/FLINK-35257
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: yanghuai
cdc job will throw exception when schema.change.behavior is exception，The data
between the last checkpoint and the current DDL will not be refreshed to the
sink, making it difficult for the task to recover this part of the data.
if the sink will flush all data and then throw an exception. This way, the task
only needs to recover from the DDL position on the source to ensure data
consistency.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
