ASF GitHub Bot commented on FLINK-6022:

Github user shashank734 commented on the issue:

    @zentol Thanks, I think it's the wrong place to ask But Actually We have 
tried to use AvroTypeInfo, But it was unable to restore from the savepoint 
(Note we have changed the schema and class with 1 extra variable) So why I was 
asking if I can get a very minimal example or hint to check Am I am doing 
something wrong? I am using Scala.

> Don't serialise Schema when serialising Avro GenericRecord
> ----------------------------------------------------------
>                 Key: FLINK-6022
>                 URL: https://issues.apache.org/jira/browse/FLINK-6022
>             Project: Flink
>          Issue Type: Improvement
>          Components: Type Serialization System
>            Reporter: Robert Metzger
>            Assignee: Stephan Ewen
>            Priority: Major
>             Fix For: 1.5.0
> Currently, Flink is serializing the schema for each Avro GenericRecord in the 
> stream.
> This leads to a lot of overhead over the wire/disk + high serialization costs.
> Therefore, I'm proposing to improve the support for GenericRecord in Flink by 
> shipping the schema to each serializer  through the AvroTypeInformation.
> Then, we can only support GenericRecords with the same type per stream, but 
> the performance will be much better.

This message was sent by Atlassian JIRA

Reply via email to