[Feature Request][Flink] Upgrade Flink source connector to use Delta protocol version (3, 7) #2874
Open
2 of 8 tasks
Labels
enhancement
New feature or request
Feature request
Which Delta project/connector is this regarding?
Overview
Attempting to read from a Delta table with
enableDeletionVectors=true
using Flink, but running into the following error message:Motivation
Flink connectors should be updated to a newer version of Delta so they can read/write to tables using the latest protocol.
Further details
Logs from Flink job attempting to read from Delta table:
I encountered this error when using delta-flink version 3.0.0 as well as building directly from the latest source (commit
d330cb18e390b8c431697436e9828659be51b26e
).Willingness to contribute
The Delta Lake Community encourages new feature contributions. Would you or another member of your organization be willing to contribute an implementation of this feature?
The text was updated successfully, but these errors were encountered: