[
https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35172:
--------------------------
Description:
The current implementation of the [kafka pipeline data sink connector
|https://github.com/apache/flink-cdc/pull/2938]does not write ddl statements to
the topic because the original dddl statements are missing. ddl cannot be
generated backwards using a Schema Change Event.
was:The current implementation of the kafka pipeline data sink connector does
not write ddl statements to the topic because the original dddl statements are
missing. ddl cannot be generated backwards using a Schema Change Event.
> DDL statement is added to the Schema Change Event
> -------------------------------------------------
>
> Key: FLINK-35172
> URL: https://issues.apache.org/jira/browse/FLINK-35172
> Project: Flink
> Issue Type: New Feature
> Components: Flink CDC
> Reporter: melin
> Priority: Major
>
> The current implementation of the [kafka pipeline data sink connector
> |https://github.com/apache/flink-cdc/pull/2938]does not write ddl statements
> to the topic because the original dddl statements are missing. ddl cannot be
> generated backwards using a Schema Change Event.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
