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

AvroSerializerSnapshot causes state migration even though the old and the new schemas are compatible

    XMLWordPrintableJSON

Details

    Description

      The problematic code is located here. Returning COMPATIBLE_AFTER_MIGRATION seems completely unnecessary and causes issues during schema evolution. The COMPATIBLE_AS_IS status should be returned instead. Even the comment right above the shared snippet suggests that:

                          // The new serializer would be able to read data persisted with *this*
                          // serializer, therefore no migration
                          // is required.
      

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              izeigerman Iaroslav Zeigerman
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: