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)