[
https://issues.apache.org/jira/browse/FLINK-6802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-6802:
------------------------------------------
Assignee: Tzu-Li (Gordon) Tai
> PojoSerializer does not create ConvertDeserializer for removed/added fields
> ---------------------------------------------------------------------------
>
> Key: FLINK-6802
> URL: https://issues.apache.org/jira/browse/FLINK-6802
> Project: Flink
> Issue Type: Improvement
> Components: Type Serialization System
> Affects Versions: 1.3.0, 1.4.0
> Reporter: Till Rohrmann
> Assignee: Tzu-Li (Gordon) Tai
>
> When calling {{PojoSerializer#ensureCompatibility}}, the PojoSerializer
> checks for compatibility. Currently, the method only construct a
> ConvertDeserializer if the number of old and new pojo fields is exactly the
> same. However, given the {{TypeSerializerConfigurationSnapshots}} and the
> current set of fields, it should also be possible to construct a
> ConvertDeserializer if new fields were added or old fields removed from the
> Pojo. I think that we should add this functionality.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
