[jira] [Created] (FLINK-12064) RocksDBKeyedStateBackend uses incorrect key serializer if reconfigure happens during restore

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12064) RocksDBKeyedStateBackend uses incorrect key serializer if reconfigure happens during restore

Shang Yuanchun (Jira)
Yu Li created FLINK-12064:
-----------------------------

             Summary: RocksDBKeyedStateBackend uses incorrect key serializer if reconfigure happens during restore
                 Key: FLINK-12064
                 URL: https://issues.apache.org/jira/browse/FLINK-12064
             Project: Flink
          Issue Type: Bug
            Reporter: Yu Li
            Assignee: Yu Li
             Fix For: 1.8.0


As titled, in current {{RocksDBKeyedStateBackend}} we use {{keySerializer}} rather than {{keySerializerProvider.currentSchemaSerializer()}}, which is incorrect. The issue is not revealed in existing UT since current cases didn't check snapshot after state schema migration.

This is a regression issue caused by the FLINK-10043 refactoring work.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)