[FLINK-12688] Make serializer lazy initialization thread safe in StateDescriptor

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.6.4, 1.7.2, 1.8.0
• Fix Version/s: 1.7.3, 1.8.1, 1.9.0
• Component/s: API / DataStream, API / Type Serialization System
• Labels: pull-request-available
• Release Note: Access to the state serializer field in {{StateDescriptor}} is now modified to private access. Subclasses should use the {{StateDescriptor#getSerializer()}} method as the only means to obtain the wrapped state serializer.
• Assignee: Yu Li
• Reporter: Yu Li
• Created: 31/May/19 04:47
• Updated: 03/Sep/19 12:52
• Resolved: 02/Jun/19 05:47

Description

As per discussed in FLINK-11987, this JIRA aims at resolving the issue of StateDescriptor#initializeSerializerUnlessSet under race condition. More specified, we will assure no NPE thrown as well as the singleton of serializer when invoking initializeSerializerUnlessSet in parallel.

Issue Links

• blocks: FLINK-11987 Kafka producer occasionally throws NullpointerException
• duplicates: FLINK-13612 StateDescriptor Loading Error NPE at FlinkKafkaProducer011 with High Concurrency Initialization
• links to: GitHub Pull Request #8570