[ https://issues.apache.org/jira/browse/FLINK-26853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Roman Khachatryan closed FLINK-26853. ------------------------------------- Fix Version/s: 1.16.0 Resolution: Fixed Merged into master as 8df50536ef913b63620d896423c39cdd01941c55. > HeapStateBackend ignores metadata updates in certain cases > ---------------------------------------------------------- > > Key: FLINK-26853 > URL: https://issues.apache.org/jira/browse/FLINK-26853 > Project: Flink > Issue Type: Bug > Components: Runtime / State Backends > Affects Versions: 1.14.4, 1.15.0, 1.16.0 > Reporter: Roman Khachatryan > Assignee: Hangxiang Yu > Priority: Minor > Labels: pull-request-available > Fix For: 1.16.0 > > > On recovery, HeapRestoreOperation reads state handles one by one; > * each handle contains metadata at the beginning; > * the metadata is always read, but not actually used if a state with the > corresponding name was already registered > In a rare case of downscaling + multiple checkpoints with different metadata; > this might lead to data being deserialized incorrectly (always using the > initial metadata). > It also prevents incremental checkpoints with schema evolution. > On first access, however, the backend itself will update (merge) metadata; so > that it doesn't affect new state updates. -- This message was sent by Atlassian Jira (v8.20.10#820010)