Yue Ma created FLINK-37552:
------------------------------

             Summary: Made StateMetaInfo consistent for ForStKeyeStateBackend 
and ForStSyncKeyeStateBackend.
                 Key: FLINK-37552
                 URL: https://issues.apache.org/jira/browse/FLINK-37552
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / State Backends
    Affects Versions: 2.0.0
            Reporter: Yue Ma
             Fix For: 2.1.0


 Currently, if MapState or ListState is used, the StateMeta information saved 
by ForStKeyeStateBackend and ForStSyncKeyeStateBackend when making cp may be 
inconsistent, which may cause incompatible states. For example, when using 
MapState, ForStKeyeStateBackend will save the ValueSerializer information in 
StateMeta, but ForStSyncKeyeStateBackend will save the MapSerializer 
information. So we need to unify this place and perform a transformation when 
ForStKeyeStateBackend creates stateMeta



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to