dawidwys commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r223321240
########## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorBackendSerializationProxy.java ########## @@ -38,7 +40,16 @@ */ public class OperatorBackendSerializationProxy extends VersionedIOReadableWritable { - public static final int VERSION = 4; + public static final int VERSION = 5; + + private static final Map<Integer, Integer> META_INFO_SNAPSHOT_FORMAT_VERSION_MAPPER = new HashMap<>(); + static { + META_INFO_SNAPSHOT_FORMAT_VERSION_MAPPER.put(1, 1); + META_INFO_SNAPSHOT_FORMAT_VERSION_MAPPER.put(2, 2); + META_INFO_SNAPSHOT_FORMAT_VERSION_MAPPER.put(3, 3); + META_INFO_SNAPSHOT_FORMAT_VERSION_MAPPER.put(4, 5); Review comment: I found this mapping particularly hard to understand. I could not figure out any better way so far though. Anyway I think we should have it in mind to revisit this mapping. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services