Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11772

InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore

    XMLWordPrintableJSON

Details

    Description

      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.

      Attachments

        Issue Links

          Activity

            People

              tzulitai Tzu-Li (Gordon) Tai
              tzulitai Tzu-Li (Gordon) Tai
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m