flink-cdc
flink-cdc copied to clipboard
[FLINK-35415][base] Fix compatibility with Flink 1.19
This closes FLINK-35316, FLINK-35415.
- Adds E2e testcases on recent Flink versions including 1.19
- Fixes CDC compatibility issue with 1.19 (due to breaking changes in @Internal classes)
This is a temporary workaround to avoid breaking compatibility with Flink 1.19. Proposal about upgrading Flink base (FLINK-35385) could be implemented later.
@lvyanquan PTAL
Thanks for @lvyanquan's review, I've split out commits based on FLINK ticket.
Pushed another commit to resolve CI issue, could @leonardBang please re-trigger the CI? Thanks!
Done, seems I messed up the commit history during last rebase... Fixed it.