flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2707) Set state checkpointer before default state for PartitionedStreamOperatorState
Date Fri, 18 Sep 2015 15:54:04 GMT
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)

Mime
View raw message