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

Remove ExecutionConfig field from PojoSerializer

Agile BoardRank to TopRank to BottomAttach filesAttach ScreenshotBulk Copy AttachmentsBulk Move AttachmentsAdd voteVotersWatch issueWatchersCreate sub-taskConvert to sub-taskLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      The PojoSerializers stores an instance of ExecutionConfig as internal field, even though that the only information it may ever need are the registered kryo serializers.

      This has a few drawbacks:

      • It blocks the evolution of ExecutionConfig as serializers where stored in a state. Therefore any change to ExecutionConfig must be backwards compatible in respect to java serialization
      • It probably already introduced a bug, as upon restore the Snapshot actually recreates the serializer with an empty ExecutionConfig (see org.apache.flink.api.java.typeutils.runtime.PojoSerializerSnapshot#restoreSerializer)

      I suggest to remove the field completely and adjust corresponding usages.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            dwysakowicz Dawid Wysakowicz

            Dates

              Created:
              Updated:

              Slack

                Issue deployment