[FLINK-8836] Duplicating a KryoSerializer does not duplicate registered default serializers

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.4.3, 1.5.0, 1.6.0
• Component/s: API / Type Serialization System
• Assignee: Stefan Richter
• Reporter: Tzu-Li (Gordon) Tai
• Created: 02/Mar/18 11:25
• Updated: 02/Oct/19 17:46
• Resolved: 25/May/18 03:42

Description

The duplicate() method of the KryoSerializer is as following:

public KryoSerializer<T> duplicate() {
    return new KryoSerializer<>(this);
}

protected KryoSerializer(KryoSerializer<T> toCopy) {
    defaultSerializers = toCopy.defaultSerializers;
    defaultSerializerClasses = toCopy.defaultSerializerClasses;

    kryoRegistrations = toCopy.kryoRegistrations;

    ...
}

Shortly put, when duplicating a KryoSerializer, the defaultSerializers serializer instances are directly provided to the new KryoSerializer instance.
This causes the fact that those default serializers are shared across two different KryoSerializer instances, and therefore not a correct duplicate.

Issue Links

• is duplicated by: FLINK-10160 Index out of bound when serializing operator state
• links to: GitHub Pull Request #5880