Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12688

Make serializer lazy initialization thread safe in StateDescriptor

    XMLWordPrintableJSON

    Details

    • 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.

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                carp84 Yu Li
                Reporter:
                carp84 Yu Li
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 10m
                  10m