flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rinat Sharipov (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized
Date Wed, 10 Oct 2018 14:55:00 GMT
Rinat Sharipov created FLINK-10525:
--------------------------------------

             Summary: Deserialization schema, skip data, that couldn't be properly deserialized
                 Key: FLINK-10525
                 URL: https://issues.apache.org/jira/browse/FLINK-10525
             Project: Flink
          Issue Type: Improvement
          Components: Core
            Reporter: Rinat Sharipov


Hi mates, in accordance with the contract of org.apache.flink.formats.avro.DeserializationSchema,
it should return *null* value, when content couldn’t be deserialized.
But in most cases (for example org.apache.flink.formats.avro.AvroDeserializationSchema) method
fails if data is corrupted. 
 
We’ve implemented our own SerDe class, that returns null, if data doesn’t satisfy avro
schema, but it’s rather hard to maintain this functionality during migration to the latest
Flink version.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message