Pravega Flink Connectors 0.6.2

0.6.2 is a bug-fix release for the r0.6 branch to support Pravega 0.6.2 release (https://github.com/pravega/pravega/releases/tag/v0.6.2)

• Better TruncatedDataException handling(#319)
• Updated Pravega dependency to 0.6.2

Pravega Flink Connectors 0.6.1

0.6.1 is a bug-fix release for the r0.6 branch to support Pravega 0.6.1 release (https://github.com/pravega/pravega/releases/tag/v0.6.1)

• Some minor bugfixes for the connector
• Updated Pravega dependency to 0.6.1

Pravega Flink Connectors 0.6.0

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

Pravega Flink Connectors 0.5.1

0.5.1 is a bug-fix release for the r0.5 branch to support Pravega-0.5.1 release (https://github.com/pravega/pravega/releases/tag/v0.5.1)

No new changes added to the connector component
Updated Pravega dependency to 0.5.1

Pravega Flink Connectors 0.5.0

Release 0.5.0 of Flink Pravega Connectors

Some highlights of this release:

• Updated Flink version from 1.6.0 to 1.7.2
• Added Flink TableFactory support for Pravega
• Enabled Flink SQL Client support for Pravega
• Resolved integration test stability issues
• Tested and validated with Pravega 0.5.0 release

Here is the complete list of commits

flink-connector-0.5.0-release-notes.txt

Pravega Flink Connectors 0.4.0

This is a feature release of Flink Pravega Connectors and it contains the following highlights

• Updated connector to support Flink 1.6.0
• Added Pravega OutputFormat support
• Added table sink support for batch operation
• Added processing/event time support to table source connector
• Added support to publish Pravega metrics for reader and writer
• Enabled documentation to be part of source code
• Added mkdocs plugin support to produce connector documentation for publishing
• Tested and validated with Pravega 0.4.0 release

Here is the complete list of commits
flink-connector-0.4.0-release-notes.txt

Pravega Flink Connectors 0.4.0 (Release Candidate 0)

This is the first release candidate of the 0.4.0 version of Flink Pravega Connector

Some highlights of this release:

• Updated connector to support Flink 1.6.0
• Added Pravega OutputFormat support
• Added table sink support for batch operation
• Added processing/event time support to table source connector
• Added support to publish Pravega metrics for reader and writer
• Tested and validated with Pravega 0.4.0 release

Pravega Flink Connectors 0.3.2

0.3.2 is a bug-fix release for the r0.3 branch to support Pravega 0.3.2 release

• No new changes added to the connector component
• Updated Pravega dependency to 0.3.2

Pravega Flink Connectors 0.3.2 (Release Candidate 0)

0.3.2 is a bug-fix release for the r0.3 branch to support Pravega 0.3.2 release

• No new changes added to the connector component
• Updated Pravega dependency to 0.3.2

Pravega Flink Connectors 0.3.1

0.3.1 is a bug-fix release for the r0.3 branch to support Pravega-0.3.1 release (https://github.com/pravega/pravega/releases/tag/v0.3.1)

• No new changes added to the connector component
• Updated Pravega dependency to 0.3.1