Nico Kruber created FLINK-16729:
-----------------------------------

             Summary: Offer an out-of-the-box Set serializer
                 Key: FLINK-16729
                 URL: https://issues.apache.org/jira/browse/FLINK-16729
             Project: Flink
          Issue Type: New Feature
          Components: API / Type Serialization System
    Affects Versions: 1.10.0
            Reporter: Nico Kruber


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to