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

Offer an out-of-the-box Set serializer

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.11.0
    • Fix Version/s: None
    • Labels:
      None

      Description

      Currently, Set types are serialized by Kryo by default, since Flink does not come with an own SetSerializer (only one for maps). While the MapSerializer can be easily adapted to cover sets instead, I think, this should be available by default to get the maximum performance out of Flink (kryo is slow!)

       

      When this is added, however, we need to provide a migration path for old state (or not use the new SetSerializer by default but offer to opt-in). This may need further investigation as to whether it is possible to migrate from kryo automatically and whether we can check potential changes to the encapsulated entry class.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              NicoK Nico Kruber
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: