JingsongLi commented on code in PR #1564: URL: https://github.com/apache/incubator-paimon/pull/1564#discussion_r1264829013
########## docs/content/how-to/cdc-ingestion.md: ########## @@ -304,8 +302,9 @@ To use this feature through `flink run`, run the following shell command. Only tables with primary keys will be synchronized. -For each Kafka topic's table to be synchronized, if the corresponding Paimon table does not exist, this action will automatically create the table. -Its schema will be derived from all specified Kafka topic's tables,it gets the earliest non-DDL data parsing schema from topic. If the Paimon table already exists, its schema will be compared against the schema of all specified Kafka topic's tables. +For each Kafka topic's table to be synchronized, if the corresponding Paimon table does not exist, this action will automatically +create the table, and its schema will be derived from all specified Kafka topic's tables. If the Paimon table already exists +and its schema is different from that parsed from Kafka record, this action will try to preform schema evolution. Review Comment: should we document this is a unified sink? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
