[jira] [Created] (FLINK-11772) InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-11772) InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore

Shang Yuanchun (Jira)
Tzu-Li (Gordon) Tai created FLINK-11772:
-------------------------------------------

             Summary: InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore
                 Key: FLINK-11772
                 URL: https://issues.apache.org/jira/browse/FLINK-11772
             Project: Flink
          Issue Type: Bug
          Components: DataStream API
            Reporter: Tzu-Li (Gordon) Tai
            Assignee: Tzu-Li (Gordon) Tai
             Fix For: 1.8.0


All of the changes done to managed state surrounding how we no longer Java-serialize serializers anymore and only write the serializer snapshot, as well as how serialization compatibility checks should go through the new {{TypeSerializerSnapshot}} / {{TypeSerializerSchemaCompatibility}} interfaces, was not reflected to timers.

This was mainly due to the fact that timers were not handled by state backends (and were therefore not managed state) in the past, and were handled in an isolated manner by the {{InternalTimerServiceSerializationProxy}}.

The {{InternalTimerServiceSerializationProxy}} therefore needs to be updated accordingly.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)