[
https://issues.apache.org/jira/browse/FLINK-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15994389#comment-15994389
]
ASF GitHub Bot commented on FLINK-6345:
---------------------------------------
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
> Migrate from Java serialization for ContinuousFileReaderOperator's state
> ------------------------------------------------------------------------
>
> Key: FLINK-6345
> URL: https://issues.apache.org/jira/browse/FLINK-6345
> Project: Flink
> Issue Type: Sub-task
> Components: Streaming Connectors
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: mingleizhang
>
> See umbrella JIRA FLINK-6343 for details. This subtask tracks the migration
> for {{ContinuousFileReaderOperator}}.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
