flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state
Date Wed, 03 May 2017 08:08:04 GMT

    [ https://issues.apache.org/jira/browse/FLINK-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15994449#comment-15994449
] 

ASF GitHub Bot commented on FLINK-6345:
---------------------------------------

Github user tzulitai commented on the issue:

    https://github.com/apache/flink/pull/3750
  
    @fanyon yes that's the general idea. The problem is that if we just replace the old `getSerializableListState`
with new access state methods, the new serializer and old serializer (which just uses plain
Java object serialization) will be incompatible.
    
    So, we actually need to have a new registered state that is migrated from the old one.
    
    However, we're planning to have the functionality to convert state serialization formats
in Flink 1.4, so now I'm actually not entirely sure if we want to do this "workaround migration
with 2 registered states" solution now. Please let me get back to you on this after I think
about it ..


> 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)

Mime
View raw message