Hi devs
Currently, only single table is supported in Paimon sink connector and the
schema is unchanged duration the insertion. It's fine in Flink SQL API. The
problems occur in CDC data synchronization usage.
In CDC source data synchronization, the data and the schema are supposed to
be synchronize
Hi jingsong,
Thanks for you quick reply.
As far as I concern, for Paimon community perspective:
1. It's better reuse the same logic for both SQL and datastream
connector API;
2. datastream API should support multiple table insertion;
3. datastream API should take schema evolution int
