Hello, 1.] Can someone please share a working example of how to read ValueState<POJO> and MapState<POJO> from a checkpoint and update it? I tried to assemble a working Java example but there are bit and pieces of info around.
2.] I am using Avro 1.7.7 with Flink for state entities since versions belong Avro 1.7.7 add a serialVersionUid and then I cannot replace the class with a new Avro schema seamlessly. If I update the Avro schema, and the Avro Maven plugin runs, a new class with a new serialVersionUid is created and that cannot be replaced in the state with the Java exception stating that local and state copies are different. Any example would be really appreciated. Thanks, Sandip
