Kostas Kloudas created FLINK-8522:
-------------------------------------
Summary: 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
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)