flink-cdc
flink-cdc copied to clipboard
[FLINK-35441][tests] Add migration test cases
This closes FLINK-35441.
Adding backwards compatible test with 3.0.0 and 3.1.0 version by serializing objects on lower versions and deserializing them on snapshot version.
-
SchemaManagertest runs on3.1.0only since commit https://github.com/apache/flink-cdc/commit/bcad5d9d11b9c37182510a43292e3019356173d1 and #3129 changesSchemaRegistryserialization fields and breaks backwards compatibility. -
SchemaRegistrytest runs on3.1.0only, since it storesSchemaManagerin its state. -
ChangeTableInfotest runs on3.1.0only since Transform feature does not exist in3.0.x.
Also noticed that there's no much classes using versioned serialization protocol, which couldn't guarantee backwards compatibility. Needs more discussion on how to refactor them.
I'm not sure if it's OK to perform migration tests like so, could @leonardBang @PatrickRen please provide some advices on this? Thanks!
Looks like we can close this PR as we've finish the tests in https://github.com/apache/flink-cdc/pull/3370 @yuxiqian