flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6554) CompatibilityResult should contain a notCompatible() option
Date Thu, 11 May 2017 15:32:07 GMT
Chesnay Schepler created FLINK-6554:

             Summary: CompatibilityResult should contain a notCompatible() option
                 Key: FLINK-6554
                 URL: https://issues.apache.org/jira/browse/FLINK-6554
             Project: Flink
          Issue Type: Improvement
          Components: Type Serialization System
    Affects Versions: 1.3.0, 1.4.0
            Reporter: Chesnay Schepler
            Priority: Minor

The {CompatibilityResult} allows a {TypeSerializer} to specify whether it is compatible based
on the given {TypeSerializerConfigSnapshot}.

As it stands the only options are {compatible} and {requiresMigration}. We should allow serializers
to also notify the system of an incompatibility which should then fail the job.

This would for example be required when a serializer provides an upgrade path version1 ->
version2 -> version3, but not directly from version1 -> version3. Currently, the serializer
would either have to contain logic to upgrade from every single previous version or simply
throw an exception on it's own.

This message was sent by Atlassian JIRA

View raw message