Github user fanyon commented on the issue:
https://github.com/apache/flink/pull/3750
@tzulitai If I understand correctly, the issue want to use high performance
serialization instead of java serialization in State. For the diffrence of
serialization, there will be multiple version of data.
For compatibility with older versions of data, do you mean that we should
try to read data in `initializeState` with older way, and write the result data
in `snapshotState` with new way. So in this issue, we need to do the following
things:
1. Create a custom serialization for the element in the ListState
2. In `initializeState`, use older method to read data. If exception
caused, use newer method to read the data.
3. In `snapshotState`, use the newer method to write the data.
Have I understood correctly? @tzulitai
cc @zhangminglei
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
