[FLINK-10839] Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.5.6, 1.6.3, 1.7.0
• Component/s: Type Serialization System
• Labels: pull-request-available
• Assignee: Stefan Richter
• Reporter: Stefan Richter
• Created: 09/Nov/18 11:53
• Updated: 12/Nov/18 17:13
• Resolved: 12/Nov/18 17:13

Description

The implementation of PojoSerializer.duplicate() currently ignores that subclassSerializerCache is a shared resource. We must always return a new instance of the serializer, even if all the nested field serializers are not stateful or else concurrency problems might occur if we have cached subclass serializers.