[
https://issues.apache.org/jira/browse/FLINK-11773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-11773.
---------------------------------------
Resolution: Fixed
Fix Version/s: 1.8.0
Merged.
1.8.0: 151cd8cf864e8fce73724c2bd3e7d188ff91c71a
1.9.0: 2a60cd7f865c5ef22452d34c673deba543200676
> 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
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.8.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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)
