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)
