Gyula Fora created FLINK-2707:
---------------------------------
Summary: Set state checkpointer before default state for
PartitionedStreamOperatorState
Key: FLINK-2707
URL: https://issues.apache.org/jira/browse/FLINK-2707
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Gyula Fora
Assignee: Gyula Fora
Currently the default state is set before the passed StateCheckpointer instance
for operator states.
What currently happens because of this is that the default value is serialized
with Java serialization and then deserialized on the opstate.value() call using
the StateCheckpointer most likely causing a failure.
This can be trivially fixed by swaping the order of the 2 calls.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
