Hello, Is there a working example of a TypeSerializer for a Java type stored in the State?
My requirement is that I should be able to store the Java POJO entity in the MapState. The state is backed by RocksDBBackend. If I update the entity with a new member variable, I am unable to deserialise the state into the new entity. I checked this link. https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/types_serialization.html <https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/types_serialization.html> It does mention that the POJO type is special based on the rules. Does that mean that I can add or remove member variables for the POJO? I have been unable to get it to work. Thanks, Sandeep