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)
