[ https://issues.apache.org/jira/browse/FLINK-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16343580#comment-16343580 ]
Stefan Richter commented on FLINK-8522: --------------------------------------- Option 1 looks good for me. > DefaultOperatorStateBackend writes data in checkpoint that is never read. > ------------------------------------------------------------------------- > > Key: FLINK-8522 > URL: https://issues.apache.org/jira/browse/FLINK-8522 > Project: Flink > Issue Type: Bug > Components: State Backends, Checkpointing > Affects Versions: 1.4.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Priority: Major > Fix For: 1.4.1 > > > In the DefaultOperatorStateBackend at line 283 we write in the checkpoint an > int declaring the number of the operator states that we include in the > checkpoint. > This number is never read when restoring and this can lead to confusion and > problems with backwards compatibility and/or extension of the types of state > we support (e.g. broadcast state). > There are two easy solutions, either remove the line and do not write the > size, or make sure that we also read this number when restoring and simply > ignore it. > I would go for the first one, i.e. remove the line. What do you think > [~richtesn] and [~tzulitai] ? -- This message was sent by Atlassian JIRA (v7.6.3#76005)