Skip to content

Pravega Flink Connectors 0.6.0
Compare
Choose a tag to compare
@crazyzhou crazyzhou released this 07 Nov 14:25
· 9 commits to r0.6 since this release
v0.6.0
363a7f8
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Verified
Learn about vigilant mode.

Release 0.6.0 of Flink Pravega Connectors

Some highlights of this release:

  • Supported multiple Flink versions.
    Flink major-minor version and Scala version should be provided to the artifact name (e.g. pravega-connectors-flink-1.9_2.12). This release support Flink version 1.7, 1.8 and 1.9 on Scala 2.12.

  • Integrated Pravega watermarking.
    Pravega provide a time bound from the writers to the readers so that they can identify where they are in the stream. (https://github.com/pravega/pravega/wiki/PDP-33:-Watermarking) The connector exposes this to Flink as a watermark in the streaming reader and propagates the Flink watermark into Pravega in the streaming writer.

  • Tested and validated with Pravega 0.6.0 release

Here is the complete list of commits
changelog-0.6-flink-1.9.txt

Assets 22
Loading