[ https://issues.apache.org/jira/browse/FLINK-36398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
JunboWang updated FLINK-36398: ------------------------------ Description: Sometimes users do not want to use Flink CDC to automatically create tables. Users want to set the attributes of each table individually. For example, when Paimon is used as a sink, the number of bucket partitions is set according to the table size. Could we provide a tool for Schema mapping to generate DDL statements for the Sink table? Schema conversion between different data sources is not an easy task. (was: Sometimes users do not want to use Flink CDC to automatically create tables. Users want to set the attributes of each table individually. For example, when Paimon is used as a sink, the number of bucket partitions is set according to the table size. Could we provide a tool for Schema mapping to generate DDL statements for the Sink table?) > Provide tools for users to obtain Schema mapping > ------------------------------------------------ > > Key: FLINK-36398 > URL: https://issues.apache.org/jira/browse/FLINK-36398 > Project: Flink > Issue Type: Improvement > Components: Flink CDC > Affects Versions: cdc-3.2.0 > Reporter: JunboWang > Priority: Minor > > Sometimes users do not want to use Flink CDC to automatically create tables. > Users want to set the attributes of each table individually. For example, > when Paimon is used as a sink, the number of bucket partitions is set > according to the table size. Could we provide a tool for Schema mapping to > generate DDL statements for the Sink table? Schema conversion between > different data sources is not an easy task. -- This message was sent by Atlassian Jira (v8.20.10#820010)