[jira] [Created] (FLINK-11773) KryoSerializerSnapshot would fail to deserialize if a type is missing

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-11773) KryoSerializerSnapshot would fail to deserialize if a type is missing

Shang Yuanchun (Jira)
Igal Shilman created FLINK-11773:
------------------------------------

             Summary: KryoSerializerSnapshot would fail to deserialize if a type is missing
                 Key: FLINK-11773
                 URL: https://issues.apache.org/jira/browse/FLINK-11773
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.8.0
            Reporter: Igal Shilman
            Assignee: Igal Shilman


KryoSerializerSnapshot would fail to read successfully if a previously registered Kryo type is not accessible by the restored job (either removed from the classpath, or failed to load for some other reason)

The source of the bug is an early return at [1] ,which would skip the consumption at [2] 
 
 [1] [https://github.com/apache/flink/blob/cf7b86de436c8714414f563e8637ceb36ea7aabe/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerSnapshotData.java#L310]

[2] https://github.com/apache/flink/blob/cf7b86de436c8714414f563e8637ceb36ea7aabe/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerSnapshotData.java#L314




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)