Re: [deserialization schema] skip data, that couldn't be properly deserialized

Hi Fabian, I have created the issue, https://issues.apache.org/jira/browse/FLINK-10525 Thx ! > On 10 Oct 2018, at 16:47, Fabian Hueske wrote: > > Hi Rinat, > > Thanks for discussing this idea. Yes, I think this would be a good feature. > Can you open a Jira issue and describe the feature? >

Re: [deserialization schema] skip data, that couldn't be properly deserialized

Hi Rinat, Thanks for discussing this idea. Yes, I think this would be a good feature. Can you open a Jira issue and describe the feature? Thanks, Fabian Am Do., 4. Okt. 2018 um 19:28 Uhr schrieb Rinat : > Hi mates, in accordance with the contract of >

[deserialization schema] skip data, that couldn't be properly deserialized

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.