Page History

...

Currently, if users use a self-defined serializer to process data, they have to make sure that the schema compatibility in the old serializer (maybe in Flink library) meets the need as users want. Or else they have to modify TypeSerializer Snapshot#resolveSchemaCompatibility TypeSerializerSnapshot#resolveSchemaCompatibility of the old serializer. There are no ways for users to clarify the compatiblity with the old serializer in the new serializer. It also makes schema evolution not scalable.

...