[jira] [Assigned] (FLINK-2713) Custom StateCheckpointers should be included in the snapshots

["Gyula Fora (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gyula Fora reassigned FLINK-2713:
---------------------------------

    Assignee: Gyula Fora

> Custom StateCheckpointers should be included in the snapshots
> -------------------------------------------------------------
>
>                 Key: FLINK-2713
>                 URL: https://issues.apache.org/jira/browse/FLINK-2713
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Gyula Fora
>            Assignee: Gyula Fora
>
> Currently the restoreInitialState call fails when the user uses a custom StateCheckpointer to create the snapshot, because the state is restored before the StateCheckpointer is set for the StreamOperatorState. (because the restoreInitialState() call precedes the open() call)
> To avoid this issue, the custom StateCheckpointer instance should be stored within the snapshot and should be set in the StreamOperatorState before calling restoreState(..).
> To reduce the overhead induced by this we can do 2 optimizations:
>  - We only include custom StateCheckpointers (the default java serializer one is always available)
>  - We only serialize the checkpointer once and store the byte array in the snapshot



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)