Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-18192][1.11 Backport] Upgrade avro to 1.10 #13903

Closed
wants to merge 5 commits into from

Commits on Nov 3, 2020

  1. [hotfix] Fix Pojo comparator field access

    The PojoComparator assumes it can access a field of a pojo directly. It assumes the field is either public or setAccessible was called before. This is the case though only if  the record went through serialization. This is not the case e.g. in CollectionExecution mode.
    
    Starting from this commit we make all fields accessible in
    PojoComparator constructor.
    dawidwys authored and rmetzger committed Nov 3, 2020
    Copy the full SHA
    3422991 View commit details
    Browse the repository at this point in the history
  2. Copy the full SHA
    57914c1 View commit details
    Browse the repository at this point in the history
  3. Copy the full SHA
    06ea27b View commit details
    Browse the repository at this point in the history
  4. Copy the full SHA
    afd72ad View commit details
    Browse the repository at this point in the history
  5. [FLINK-18192] Upgrade avro to 1.10

    This commit upgrades the default version of avro that flink-avro will use. It should be possible to downgrade the avro version in a user job as the binary format is compatible and we do not expose any dependencies on avro in the API.
    
    Additionally this commit fixes handling of logical types: time-micros and timestamp-micros as well as interpretation of timestamp-millis in the AvroRowDataDeserializationSchema.
    dawidwys authored and rmetzger committed Nov 3, 2020
    Copy the full SHA
    5c71f6e View commit details
    Browse the repository at this point in the history