[ https://issues.apache.org/jira/browse/FLINK-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345395#comment-16345395 ]
Kostas Kloudas commented on FLINK-8522: --------------------------------------- There is a commit for this here: [https://github.com/apache/flink/pull/5230] It is the first commit of that PR. > 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)