paimon
paimon copied to clipboard
[cdc] fix paimon cdc job restart failed when schema changed
Purpose
Restarting the flink-paimon-cdc job schemaCompatible failed when the column change/add between the stop and restart of the flink-paimon-cdc job
- In cdc-postgresql, for the newly added fields, because debezium-postgresql has no DDL events, the newly added fields can only be parsed from the records, and char and varchar fields are both STRING types in debezium-postgresql, so both char and varchar are converted to STRING in cdc-postgresql.
Tests
API and Format
Documentation
can you help review this pr? tks @JingsongLi
CC @yuzelin
Hello, can you solve the conflicts ?
Hello, can you solve the conflicts ?
done,please help to review this PR, thanks. @yuzelin