Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34037 FLIP-398: Improve Serialization Configuration And Usage In Flink
  3. FLINK-34239

Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

    XMLWordPrintableJSON

Details

    Description

      Problem

      Currently, org.apache.flink.table.catalog.DataTypeFactoryImpl#createSerializerExecutionConfig will create a deep-copy of the SerializerConfig and merge Table config into it. However, the deep copy is done by manully calling the getter and setter methods of SerializerConfig, and is prone to human errors, e.g. missing copying a newly added field in SerializerConfig.

      Proposal

      Introduce a deep copy method for SerializerConfig and replace the curr impl in org.apache.flink.table.catalog.DataTypeFactoryImpl#createSerializerExecutionConfig.

      Attachments

        Issue Links

          Activity

            People

              mallikarjuna Kumar Mallikarjuna
              Zhanghao Chen Zhanghao Chen
              Votes:
              1 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: