mxm opened a new pull request, #13714: URL: https://github.com/apache/iceberg/pull/13714
Flink 2.1.0 has been released: https://flink.apache.org/2025/07/31/apache-flink-2.1.0-ushers-in-a-new-era-of-unified-real-time-data--ai-with-comprehensive-upgrades/ Most notably, a Variant data type has been added. I have not added support for the Variant data type yet. I think it is best to do that separately. For now, I've ported the existing code to Flink 2.1.0 with the biggest change being that Flink now longer allows using `Long.MAX_VALUE` as the checkpoint id when flushing state on shutdown via `prepareSnapshotBarrier(checkpointId)`. The checkpoint id needs to be increasing by 1 and any messages for higher checkpoint ids are going to be ignored. The correct checkpoint id needs to be restored from state when the job is recovered. The following commits have been added to preserve the Git history as best as possible, similarly to how previous Flink upgrades have been done. Since we manage a maximum of three releases, I'm removing support for Flink 1.19. 1. Flink: Move Flink v2.0 to v2.1 directory 2. Flink: Add back v2.0 directory 3. Flink: Adjust build scripts for Flink 2.1 4. Flink: Code changes for Flink 2.1 5. Flink: Remove support for Flink 1.19 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
