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

Reply via email to