You can take a look to https://paimon.apache.org/docs/master/cdc-ingestion/overview/
The related codes will take care of schema evolution. On Mon, Feb 19, 2024 at 10:47 PM lec ssmi <[email protected]> wrote: > > hi: > If using Flink to write to the paimon, it is necessary to define the table > structure of the paimon when generating the pipeline. So if there is a change > in the table structure of the data source during the execution of the Flink > job, how can the table structure of Paimon be automatically synchronized? Do > we necessarily need to restart the Flink task?
