Skip to content

Flink: Fix the avro reader issue when reading v2 position deletes.#3540

Merged
rdblue merged 1 commit into
apache:masterfrom
openinx:flink-avro-v2-reader
Nov 14, 2021
Merged

Flink: Fix the avro reader issue when reading v2 position deletes.#3540
rdblue merged 1 commit into
apache:masterfrom
openinx:flink-avro-v2-reader

Conversation

@openinx
Copy link
Copy Markdown
Member

@openinx openinx commented Nov 12, 2021

This is trying to fix the flink's v2 avro reader bug #3477 (comment)

The problem is that the Flink Avro readers do not implement SupportsRowPosition so the position is always null.

Copy link
Copy Markdown
Contributor

@rdblue rdblue left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The changes look safe to me. I'm assuming that the changes to FileHelpers extend existing tests to use Parquet, Avro, and ORC delete files.

@rdblue rdblue merged commit beb5d6a into apache:master Nov 14, 2021
@openinx
Copy link
Copy Markdown
Member Author

openinx commented Nov 15, 2021

@rdblue , Yes, it's correct. The previous unit tests only cover the parquet cases, now we have extended them to cover all the parquet, orc, avro cases. Thanks @rdblue for the merging !

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants