Gyula Fora created FLINK-2713:
---------------------------------
Summary: 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
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)
