flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-6799) PojoSerializer does not check field types when being deserialized
Date Thu, 01 Jun 2017 13:50:04 GMT

     [ https://issues.apache.org/jira/browse/FLINK-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Tzu-Li (Gordon) Tai updated FLINK-6799:
    Affects Version/s: 1.1.5

> PojoSerializer does not check field types when being deserialized
> -----------------------------------------------------------------
>                 Key: FLINK-6799
>                 URL: https://issues.apache.org/jira/browse/FLINK-6799
>             Project: Flink
>          Issue Type: Bug
>          Components: Type Serialization System
>    Affects Versions: 1.3.0, 1.1.5, 1.2.1, 1.4.0
>            Reporter: Till Rohrmann
> The {{PojoSerializer}} stores internally the fields of a pojo as {{Field}} instances.
These field instances are serialized via the {{FieldSerializer}}. The {{FieldSerializer}}
simply writes out the name of the field. When being deserialized, the serializer reads the
name and then looks up the field using the dynamically loaded class. If the underlying class
changes, e.g. type of fields change, then this won't be noticed, because we don't check the
field types. In order to catch errors early and to give meaningful error messages, I think
we should add type checks for the reloaded fields.

This message was sent by Atlassian JIRA

View raw message