You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/02/28 11:23:00 UTC
[jira] [Closed] (FLINK-11773) KryoSerializerSnapshot would fail to
deserialize if a type is missing
[ 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)