You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/02/27 20:35:00 UTC
[jira] [Updated] (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 ]
ASF GitHub Bot updated FLINK-11773:
-----------------------------------
Labels: pull-request-available (was: )
> 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
>
> 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)