apache
[FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job
paimon cdc schema evolution failure when restart job
Minimal reproduce step：
- stop flink-cdc-mysql-to-paimon pipeline job
- alter mysql table schema, such as add column
- start pipeline job
- the newly added column was not synchronized to the paimon table
Thanks @MOBIN-F for the contribution, could you add description for the PR ?
This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs.
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "Published by a pub.dev verified publisher"){kind=small}
This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encouraged to continue work on this pull request.
This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encouraged to continue work on this pull request.
Hi @MOBIN-F. I think that this can be closed as it was solved in https://github.com/apache/flink-cdc/pull/4081. I believe that modifying the data to adapt to the downstream table structure is a safer solution compared to modifying the downstream table structure through the task to accommodate the data. What do you think?
Hi @MOBIN-F. I think that this can be closed as it was solved in #4081. I believe that modifying the data to adapt to the downstream table structure is a safer solution compared to modifying the downstream table structure through the task to accommodate the data. What do you think?
agree~