liming30 opened a new issue, #4424: URL: https://github.com/apache/paimon/issues/4424
### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation In Flink jobs, the source and sink of paimon are both stateful. In our business scenarios, we may modify the parallelism, add sources, and replace source/sink tables, which can easily lead to problems where the state cannot be restored, such as `Cannot map checkpoint/savepoint state for operator xxx to the new program.` For example, the following two operations cannot be restored from the Savepoint: 1. `insert into table_A (select f1 from table_B)` -> `insert in table_A (select f1 from table_B union all select f1 from table_C)` 2. `insert into table_A select f1 from table_B` -> `insert into table_C select f1 from table_B` Therefore I want to set `uid` for source/sink operators to improve state compatibility when restoring from savepoint. ### Solution Set uid for source/sink operators. ### Anything else? _No response_ ### Are you willing to submit a PR? - [X] I'm willing to submit a PR! -- 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]
