[FLINK-2707] Set state checkpointer before default state for PartitionedStreamOperatorState

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Gyula Fora
• Reporter: Gyula Fora
• Created: 18/Sep/15 15:53
• Updated: 28/Feb/19 11:15
• Resolved: 18/Sep/15 17:22

Description

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.