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

PojoSerializerSnapshot is using incorrect ExecutionConfig when restoring serializer

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.17.0
    • None
    • None

    Description

      org.apache.flink.api.java.typeutils.runtime.PojoSerializerSnapshot#restoreSerializer is using freshly created new ExecutionConfig() execution config for the restored serializer, which overrides any configuration choices made by the user. Most likely this is a dormant bug, since restored serializer shouldn't be used for serializing any new data, and the ExecutionConfig is only used for subclasses serializations that haven't been cached. If this is indeed the case, I would propose to change it's value to null and safeguard accesses to that field with an IllegalStateException.

      Attachments

        Activity

          People

            Unassigned Unassigned
            pnowojski Piotr Nowojski
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: