Skip to content

Pravega Flink Connectors 0.13.0

Latest
Latest
Compare
Choose a tag to compare
@crazyzhou crazyzhou released this 08 Oct 13:40
· 4 commits to master since this release
v0.13.0
ebd8563

This release supports Flink 1.14, 1.15 and 1.16, and it is tested and validated with Pravega 0.13.0 release. The release artifacts of the supported Flink versions are available on Maven Central.
For more detail, please read the documentation on Pravega official website: http://pravega.io/docs/latest/connectors/flink-connector

Highlight features

  • (#702) Support Flink 1.16

The connector fixes the compatibility issues and updates its API to adapt Flink 1.16

Enhancements

  • (#709) Leverage DeliveryGuarantee in new sink API
  • (#705) Implement sink metrics in the new sink API

Bugfixes

  • (#719) Explicitly cancel outstanding checkpoints when checkpoints get stuck

Flink 1.16 connector source code and artifacts are listed in the assets.
Here is the complete list of commits: changelog-flink.txt

Assets 14
Loading