You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/18 17:54:04 UTC
[jira] [Created] (FLINK-2707) Set state checkpointer before default
state for PartitionedStreamOperatorState
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)